influxdb_client 插入GPS数据并查询

插入GPS数据：

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

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

# Write data
write_api = client.write_api(write_options=SYNCHRONOUS)
point = Point("gps") \
  .tag("vehicle_id", "123") \
  .field("latitude", 39.9) \
  .field("longitude", 116.3) \
  .time('2022-01-01T00:00:00Z')
write_api.write(bucket='my-bucket', record=point)

查询GPS数据：

from influxdb_client import InfluxDBClient

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

# Query data
query_api = client.query_api()
result = query_api.query('from(bucket:"my-bucket") \
  |> range(start: 0, stop: now()) \
  |> filter(fn: (r) => r._measurement == "gps" and r.vehicle_id == "123")')

for table in result:
  for record in table.records:
    print(f"{record.get_field()}: {record.get_value()}")