如何使用InfluxDB OSS v1.8.10的Python客户端库执行查询操作？

我完全明白你的困扰——InfluxDB 1.8和2.x的架构差异（尤其是bucket vs database的区别），加上新客户端库的文档侧重2.x，很容易让人摸不着头脑。其实influxdb-client-python完全支持1.8的查询操作，只是需要用对适配1.x的语法和参数，下面一步步给你讲清楚：

核心思路 #

InfluxDB 1.8没有bucket的概念，使用的是database+retention policy+measurement的层级结构，查询语言用的是InfluxQL（而非2.x的Flux）。influxdb-client-python提供了V1兼容层，能直接执行InfluxQL查询，不需要适配bucket相关的逻辑。

具体实现步骤 #

1. 初始化适配1.8的客户端 #

初始化时不需要传入2.x的token和org参数，而是用1.8的username、password和database：

from influxdb_client import InfluxDBClient
from influxdb_client.client.query_api import QueryApi

# 替换成你的InfluxDB 1.8地址、账号密码和目标数据库
client = InfluxDBClient(
    url="http://localhost:8086",
    username="your_username",
    password="your_password",
    org="",  # 1.8无org概念，留空即可
    database="your_target_db"
)

2. 执行InfluxQL查询 #

使用QueryApi执行标准的InfluxQL语句，记得指定要查询的database（如果初始化时没指定，就需要在query方法里传入）：

query_api = QueryApi(client)

# 编写InfluxQL查询语句，替换成你的measurement和查询条件
influxql_query = '''
SELECT "temperature" FROM "env_sensor" 
WHERE time > now() - 24h AND "location" = "office"
'''

# 执行查询
result = query_api.query(query=influxql_query, database="your_target_db")

# 遍历并处理查询结果
for table in result:
    for record in table.records:
        print(f"时间: {record.time}, 温度: {record.get_value()}")

更贴近1.x风格的兼容写法 #

如果你习惯旧版influxdb-python客户端的使用方式，可以直接用InfluxDBClientV1类，它是专门为兼容1.x版本设计的：

from influxdb_client import InfluxDBClientV1

# 初始化V1兼容客户端
client = InfluxDBClientV1(
    url="http://localhost:8086",
    username="your_username",
    password="your_password",
    database="your_target_db"
)

# 执行查询，返回的结果格式和旧客户端一致
cursor = client.query(influxql_query)

# 遍历结果，用get_points()获取结构化数据
for point in cursor.get_points():
    print(f"时间: {point['time']}, 温度: {point['temperature']}")

关键注意事项 #

• 查询语言用InfluxQL：不要用2.x的Flux语法，遵循InfluxDB 1.8的查询语法规则编写语句
• 权限验证：确保你的账号拥有目标数据库的查询权限
• 避免混淆参数：不要传入2.x的token参数，1.8只认username和password
• 结果处理：query()返回的是结构化的FluxTable对象，而query_raw()可以返回原始JSON格式的响应，适合自定义解析

内容的提问来源于stack exchange，提问作者colonelPanic