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

以下是一个简单的示例，展示如何使用 Python 的 influxdb_client 库来写入和读取 GPS 数据。

写入数据：

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

# 创建 InfluxDBClient 对象
client = InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org")
# 创建写入 API 对象
write_api = client.write_api(write_options=SYNCHRONOUS)

# 创建 Point 对象，设置 GPS 数据
point = Point("gps_data").tag("location", "my_location").field("latitude", 40.7128).field("longitude", -74.0060)

# 写入数据
write_api.write(bucket="my-bucket", record=point)

读取数据：

from influxdb_client import InfluxDBClient

# 创建 InfluxDBClient 对象
client = InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org")

# 查询 GPS 数据
query = f'from(bucket:"my-bucket") |> range(start: -1h) |> filter(fn: (r) => r._measurement == "gps_data" and r.location == "my_location")'
tables = client.query_api().query(query)

# 打印 GPS 数据
for table in tables:
    for record in table.records:
        print(f"Time: {record.time}, Latitude: {record.latitude}, Longitude: {record.longitude}")

在这个例子中，我们使用 InfluxDBClient 创建了一个 InfluxDB 客户端对象。然后，我们使用写入 API 写入一个 GPS 数据点。最后，我们使用查询 API 从 InfluxDB 中查询 GPS 数据，并打印出结果。