InfluxDB查询报错：缺失必填参数q（400错误）及404错误的解决求助

我来帮你拆解下遇到的两个问题，都是和InfluxDB的请求格式、API使用规范有关的：

一、requests.get请求返回400（缺失q参数） #

你这里的核心问题是GET请求的参数传递方式错误：

当用requests.get发起请求时，data参数是用来传递请求体数据的，但GET请求的查询参数（比如q、db）应该放在params字典里，或者直接拼在URL的query string中。你之前把q放在data里，服务器根本识别不到这个参数，所以返回"missing required parameter 'q'"。

另外注意你的第一个请求URL写错了：https://<hostname>8086/query里<hostname>和端口8086之间少了冒号，正确格式应该是https://<hostname>:8086/query，这可能也是后续出现404的原因之一。

修正后的requests代码： #

import requests

# 先修正URL格式，加上端口前的冒号
url='https://<hostname>:8086/query'
headers = { 'Content-Type': 'application/x-www-form-urlencoded', }
# 把db和q参数都放到params字典里
params = {
    'db': 'tail_screw_20',
    'q': 'select time, "RH(%)", "T(C)" from PM_histo WHERE time >= \'2022-05-04T11:00:00Z\' and time <= \'2022-05-04T11:10:00Z\' order by time asc'
}
# GET请求不需要传data，直接用params传递查询参数
response = requests.get(url=url, params=params, headers=headers, verify=False)
print(response.text)
print(response)

如果你的查询语句很长，也可以改用POST请求，此时q参数可以放在data里，请求格式依然有效。

二、influxdb_client查询返回错误 #

你这段代码的问题比较多，主要是混淆了InfluxDB 1.x和2.x的API规范，且查询语句语法错误：

1. URL格式错误：InfluxDB 2.x的URL不需要带?db=xxx，1.x兼容模式也不需要，这个参数应该通过查询语句或者客户端配置传递。
2. Token设置错误：不能填'None'，如果是InfluxDB 1.x，token格式是"username:password"（没有认证的话可以留空字符串''）；如果是2.x，必须填写有效的组织token。
3. 查询语句混用语法：你写的是Flux查询，但语法错误百出（比如r["time"] == "time"完全不符合逻辑，range的start参数未定义，sort的desc参数应该是布尔值），而且如果是1.x版本，默认用的是InfluxQL，不是Flux。
4. API使用错误：query_api.query()返回的是ResultSet对象，不能直接传给query_csv()，query_csv()需要传入字符串格式的查询语句。

分版本修正代码： #

如果是InfluxDB 1.x（推荐用InfluxQL）：

from influxdb_client import InfluxDBClient

# 修正URL，去掉末尾的?db=xxx
url='https://<localHost>:8086'
# 1.x兼容模式下，token格式为"username:password"，无认证则填''
client = InfluxDBClient(
    url=url,
    token='<your-username>:<your-password>',
    ssl=False,
    verify_ssl=False,
    org='--'  # 1.x兼容模式下org随便填一个即可，比如'--'
)

query_api = client.query_api()
# 用标准的InfluxQL查询语句
query = '''
select time, "RH(%)", "T(C)" from PM_histo WHERE time >= '2022-05-04T11:00:00Z' and time <= '2022-05-04T11:10:00Z' order by time asc
'''
# 直接传入查询字符串获取CSV结果
resultsA = query_api.query_csv(query=query)
for row in resultsA:
    print(row)

如果是InfluxDB 2.x（用Flux查询）：

from influxdb_client import InfluxDBClient

url='https://<localHost>:8086'
client = InfluxDBClient(
    url=url,
    token='<your-valid-token>',  # 必须填真实有效的token
    ssl=False,
    verify_ssl=False,
    org='<your-org-name>'  # 必须填写你的组织名称
)

query_api = client.query_api()
# 正确的Flux查询语法
query = '''
from(bucket: "tail_screw_20")  # bucket对应1.x的数据库名
|> range(start: 2022-05-04T11:00:00Z, stop: 2022-05-04T11:10:00Z)
|> filter(fn: (r) => r._measurement == "PM_histo")
|> filter(fn: (r) => r._field == "RH(%)" or r._field == "T(C)")
|> sort(columns: ["_time"], desc: false)
|> pivot(rowKey: ["_time"], columnKey: ["_field"], valueColumn: "_value")  # 把字段转成列，和InfluxQL结果格式一致
'''
resultsA = query_api.query_csv(query=query)
for row in resultsA:
    print(row)

总结几个关键注意点 #

• 检查URL格式：必须包含://<hostname>:<port>，端口前的冒号不能丢，否则会导致404错误。
• 区分请求方式：GET请求的查询参数要放在params里，POST请求可以放在data或json里（根据Content-Type调整）。
• 匹配InfluxDB版本：1.x用InfluxQL，2.x用Flux，客户端配置要对应版本要求，token不能随便填'None'。

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