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"]}')