如何使用python influxdb_client 写入读取数据

使用python influxdb_client 写入数据:

1. 导入库

from influxdb_client import InfluxDBClient
from influxdb_client.client.write_api import SYNCHRONOUS

2. 连接到influxdb

client = InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org")

3. 写入数据

write_api = client.write_api(write_options=SYNCHRONOUS)
write_api.write(bucket="my-bucket", org="my-org", record={"measurement": "my-measurement", "tags": {"my-tag": "my-value"}, "fields": {"my-field": "my-value"}})

使用python influxdb_client 读取数据:

1. 导入库

from influxdb_client import InfluxDBClient
from influxdb_client.client.write_api import SYNCHRONOUS

2. 连接到influxdb

client = InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org")

3. 查询数据

query_api = client.query_api()
result = query_api.query('from(bucket:"my-bucket") |> range(start:-1h) |> filter(fn: (r) => r["_measurement"] == "my-measurement")')
for table in result:
    for record in table.records:
        print(f'{record.time}: {record.values["my-field"]}')