以下是使用 Python influxdb_client 向 InfluxDB 写入和查询 GPS 数据的步骤:

  1. 安装 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)

使用 Python InfluxDB Client 向 InfluxDB 写入和查询 GPS 数据

原文地址: https://www.cveoy.top/t/topic/nggY 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录