使用 Python InfluxDB Client 向 InfluxDB 写入和查询 GPS 数据
以下是使用 Python influxdb_client 向 InfluxDB 写入和查询 GPS 数据的步骤:
-
安装 influxdb_client 库:
pip install influxdb_client
2. 导入库和创建 InfluxDB 的客户端:
from influxdb_client import InfluxDBClient client = InfluxDBClient(url='http://localhost:8086', token='my-token', org='my-org')
其中,url 是 InfluxDB 的地址,token 是用户的访问令牌,org 是组织名称。
3. 创建数据库:
client.create_database('my-database')
4. 写入数据:
from datetime import datetime from influxdb_client import Point
point = Point('gps_data')
.tag('vehicle_id', '123')
.field('latitude', 37.7749)
.field('longitude', -122.4194)
.time(datetime.utcnow())
write_api = client.write_api() write_api.write('my-database', 'my-org', point)
上面的代码创建了一个名为 gps_data 的测量值,包含一个名为 vehicle_id 的标签和两个名为 latitude 和 longitude 的字段。时间戳使用了当前时间的 UTC 时间格式。
5. 查询数据:
from influxdb_client import Query
query = Query('SELECT * FROM 'gps_data' WHERE 'vehicle_id' = '123'', 'my-database') result = client.query_api().query(query) print(result)
上面的代码查询了 gps_data 测量值中 vehicle_id 为 123 的数据,并打印了结果。
完整代码示例:
from influxdb_client import InfluxDBClient, Point from influxdb_client import Query from datetime import datetime
创建客户端
client = InfluxDBClient(url='http://localhost:8086', token='my-token', org='my-org')
创建数据库
client.create_database('my-database')
写入数据
point = Point('gps_data')
.tag('vehicle_id', '123')
.field('latitude', 37.7749)
.field('longitude', -122.4194)
.time(datetime.utcnow())
write_api = client.write_api() write_api.write('my-database', 'my-org', point)
查询数据
query = Query('SELECT * FROM 'gps_data' WHERE 'vehicle_id' = '123'', 'my-database') result = client.query_api().query(query) print(result)
原文地址: https://www.cveoy.top/t/topic/nggY 著作权归作者所有。请勿转载和采集!