我有一个UDP InfluxDB
连接:
client = InfluxDBClient(host='localhost', database='adatabase', use_udp=True, udp_port=1234)
然后,我有以下功能:
def getData(self, measurement, field="*", tag="", timeStart=0, timeEnd=0):
parameters = {"selectedMeasurement": measurement,
"selectedField": field}
print(parameters)
result = self.client.query('SELECT LAST($selectedField) FROM $selectedMeasurement;', params=parameters)
print(list(result.get_points()))
return list(result.get_points())
但我得到了以下错误:
influxdb.exceptions.InfluxDBClientError: 400: {"error":"error parsing query: missing parameter: selectedField"}
我不明白问题出在哪里。还尝试了bind_params
。我使用硬编码字段和测量值,代码运行良好
Influxdb允许在WHERE语句中使用bind_params($variable),而不是在SELECT中使用
Influxdb Docs - Bind Parameter
相关问题 更多 >
编程相关推荐