Python 客户端库

使用 InfluxDB Python 客户端库 将 InfluxDB 集成到 Python 脚本和应用程序中。

本指南假设您对 Python 和 InfluxDB 有一定的了解。如果您刚开始接触，请参阅 InfluxDB 入门。

开始之前

您需要以下先决条件

1. 安装 InfluxDB Python 库

   pip install influxdb-client

2. 使用 HTTPS 协议的 InfluxDB Cloud Dedicated 集群 URL – 例如

   https://:8181

3. 要写入的 数据库名称。

4. 具有写入数据库权限的 InfluxDB 数据库令牌。出于安全原因，我们建议将环境变设置为存储您的令牌，并避免在脚本中暴露原始令牌值。

使用 Python 将数据写入 InfluxDB

按照以下步骤将 行协议 数据写入 InfluxDB Cloud Dedicated 数据库。

1. 在您的编辑器中，为您的 Python 程序创建一个文件 – 例如：write.py。

2. 在该文件中，导入 InfluxDB 客户端库。

   import influxdb_client
   from influxdb_client.client.write_api import SYNCHRONOUS
   import os

3. 定义您的 数据库名称、组织（必需，但将被忽略）和 数据库令牌 的变量。

   database = "DATABASE_NAME"
   org = "ignored"
   # INFLUX_TOKEN is an environment variable you created for your database WRITE token
   token = os.getenv('INFLUX_TOKEN')
   url="https://:8181"

4. 要实例化客户端，请使用以下关键字参数调用 influxdb_client.InfluxDBClient() 方法：url、org 和 token。

   client = influxdb_client.InfluxDBClient(
      url=url,
      token=token,
      org=org
   )

   InfluxDBClient 对象有一个 write_api 方法，用于配置。

5. 通过调用 client.write_api() 方法并传入写入配置选项来实例化一个写入客户端。

   write_api = client.write_api(write_options=SYNCHRONOUS)

6. 创建一个 点 对象，并使用 API 写入对象的 write 方法将其写入 InfluxDB。写入方法需要三个参数：bucket、org 和 record。

   p = influxdb_client.Point("my_measurement").tag("location", "Prague").field("temperature", 25.3)
   write_api.write(bucket=database, org=org, record=p)

完整的示例写入脚本

import influxdb_client
from influxdb_client.client.write_api import SYNCHRONOUS
import os

database = "DATABASE_NAME"
org = "ignored"
# INFLUX_TOKEN is an environment variable you created for your database WRITE token
token = os.getenv('INFLUX_TOKEN')
url="https://:8181"

client = influxdb_client.InfluxDBClient(
    url=url,
    token=token,
    org=org
)

# Write script
write_api = client.write_api(write_options=SYNCHRONOUS)

p = influxdb_client.Point("my_measurement").tag("location", "Prague").field("temperature", 25.3)
write_api.write(bucket=database, org=org, record=p)

使用 Python 从 InfluxDB 查询数据

InfluxDB v2 Python 客户端无法查询 InfluxDB Cloud Dedicated。要查询您的专用实例，请使用支持 gRPC 的 Python Flight SQL 客户端。