InfluxDB嵌套查询实现:基于小时首值计算日均温度
如何合并查询计算每日平均温度?
当然可以把这两个步骤合并成一个查询!在InfluxDB中,我们可以利用嵌套子查询来实现这个需求——先在子查询里完成每小时取第一个值的操作,再在外层查询基于这些结果计算每日平均值。
合并后的完整查询语句
SELECT MEAN("first_value") AS "daily_avg_temp" FROM ( -- 子查询:每小时取第一个温度值 SELECT FIRST("value") AS "first_value" FROM "externaltemp" WHERE $timeFilter GROUP BY time(1h) fill(none) ) -- 外层查询:基于每小时的第一个值计算每日平均值 GROUP BY time(1d) fill(none)
查询逻辑拆解
- 内层子查询:按照1小时的时间粒度分组,为每个小时窗口提取第一条记录的
value值(也就是你要的每小时第一个温度值),并将这个值命名为first_value。$timeFilter保留了你原有的时间范围过滤逻辑,fill(none)确保没有数据的小时不会生成无效的空值行。 - 外层查询:以子查询的结果为数据源,按照1天的时间粒度重新分组,计算每个日期内所有小时第一个值的平均值,最终得到每日平均温度,命名为
daily_avg_temp。同样用fill(none)避免无数据日期生成空行。
结合你的数据示例说明
比如你提供的2018-04-04 07点的多条数据,子查询会提取该小时的第一条记录对应的value作为该小时的first_value,之后和当天其他23个小时的first_value一起,由外层查询计算出4月4日的每日平均温度。
额外提示
- 确保你的InfluxDB版本在1.2及以上(这个版本开始支持嵌套子查询)。
- 如果需要处理无数据的时间段,可以调整
fill()的参数,比如fill(0)用0填充,fill(previous)用上一个有效值填充,根据业务需求选择即可。
内容的提问来源于stack exchange,提问作者Simon Milvert
相关产品推荐
相关产品推荐

