如何在查询InfluxDB中添加变量bucket名称？

Question

在第 6 行中，query = 'from(bucket: "my-bucket")\ 我们如何将存储桶作为变量传递而不是对其进行硬编码？

代码源 -> https://www.influxdata.com/blog/getting-started-with-python-and-influxdb-v2-0/ 使用 Python 客户端写入和查询指向 InfluxDB 的脚本

from influxdb_client import InfluxDBClient

org = "my-org"
bucket = "my-bucket"
token = $my-token
query = 'from(bucket: "my-bucket")\
|> range(start: -10m)\
|> filter(fn: (r) => r._measurement == "h2o_level")\
|> filter(fn: (r) => r._field == "water_level")\
|> filter(fn: (r) => r.location == "coyote_creek")'

注意 - 查询的语法样式可以采用此处提到的两种方式 - https://community.influxdata.com/t/query-throws-rparen-got-eof-error/18940

我尝试了此处提到的多种方法如何创建带有内联变量的多行Python字符串？，但出现错误。

Answer 1

这可以通过使用连接字符串和变量来解决。

org = "my-org"
bucket = "my-bucket"
token = $my-token
query = 'from(bucket: "' + my-bucket + '")\
|> range(start: -10m)\
|> filter(fn: (r) => r._measurement == "h2o_level")\
|> filter(fn: (r) => r._field == "water_level")\
|> filter(fn: (r) => r.location == "coyote_creek")'

Answer 2

谢谢！效果很好！ 海因HH