如何在Flux查询中获取不受时间范围限制的IoT传感器最新值

Flux本身不支持无界range查询，可通过以下两种方案实现不受时间范围限制获取最新测量值：

• 方案1：设置匹配存储周期的超大时间范围
  该方案是兼容性最强的常用方案，将range的start参数设置为大于等于你的bucket数据保留时长的时间跨度即可，实际使用效果和无界查询完全一致。如果你的bucket是永久存储，设置start: -100y即可覆盖所有可能的IoT传感器历史数据。
  修改后的查询代码如下：

from(bucket:"mqtt-bucket")
|> range(start:-100y )
|> filter(fn: (r) => r["_measurement"] == "mqtt_consumer")
|> filter(fn: (r) => r["thingy"] == "things/green-1/shadow/update"
                  or r["thingy"] == "things/green-3/shadow/update" 
                  or r["thingy"] == "things/green-2/shadow/update")
|> filter(fn: (r) => r["_field"] == "data")
|> filter(fn: (r) => r["appId"] == "TEMP" or r["appId"] == "HUMID")
|> toFloat()
|> last()

如果你的传感器上报频率有明确规律，比如最长7天内一定会上报一次数据，可将时间范围调整为start: -7d，进一步提升查询性能。

• 方案2：使用getLastPoint函数（适配InfluxDB 2.4及以上版本）
  如果你的InfluxDB版本不低于2.4，也可以用官方提供的getLastPoint函数，不需要显式设置超大时间范围，函数内部会自动处理范围查询拉取最新值：

import "influxdata/influxdb"

influxdb.getLastPoint(
  bucket: "mqtt-bucket",
  predicate: (r) => r["_measurement"] == "mqtt_consumer"
    and (r["thingy"] == "things/green-1/shadow/update" or r["thingy"] == "things/green-3/shadow/update" or r["thingy"] == "things/green-2/shadow/update")
    and r["_field"] == "data"
    and (r["appId"] == "TEMP" or r["appId"] == "HUMID")
)
|> toFloat()

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