首页 文章

InfluxDB:如何创建连续查询来计算delta值?

提问于
浏览
0

我想计算存储在InfluxDB中的一系列测量的delta值 . 这些值是每5分钟取一次电表的读数 . 值随时间增加 . 以下是为您提供想法的数据子集(下面显示的命令在InfluxDB CLI中执行):

> SELECT "Haushaltstromzaehler - cnt" FROM "myhome_measurements" WHERE time >= '2018-02-02T10:00:00Z' AND time < '2018-02-02T11:00:00Z'
name: myhome_measurements
time                           Haushaltstromzaehler - cnt
----                           --------------------------
2018-02-02T10:00:12.610811904Z 11725.638
2018-02-02T10:05:11.242021888Z 11725.673
2018-02-02T10:10:10.689827072Z 11725.707
2018-02-02T10:15:12.143326976Z 11725.736
2018-02-02T10:20:10.753357056Z 11725.768
2018-02-02T10:25:11.18448512Z  11725.803
2018-02-02T10:30:12.922032896Z 11725.837
2018-02-02T10:35:10.618788096Z 11725.867
2018-02-02T10:40:11.820355072Z 11725.9
2018-02-02T10:45:11.634203904Z 11725.928
2018-02-02T10:50:11.10436096Z  11725.95
2018-02-02T10:55:10.753853952Z 11725.973

使用 difference() 函数计算InfluxDB CLI中的差异非常简单 . 这给了我5分钟间隔内消耗的电量:

> SELECT difference("Haushaltstromzaehler - cnt") FROM "myhome_measurements" WHERE time >= '2018-02-02T10:00:00Z' AND time < '2018-02-02T11:00:00Z'
name: myhome_measurements
time                           difference
----                           ----------
2018-02-02T10:05:11.242021888Z 0.03499999999985448
2018-02-02T10:10:10.689827072Z 0.033999999999650754
2018-02-02T10:15:12.143326976Z 0.02900000000045111
2018-02-02T10:20:10.753357056Z 0.0319999999992433
2018-02-02T10:25:11.18448512Z  0.03499999999985448
2018-02-02T10:30:12.922032896Z 0.033999999999650754
2018-02-02T10:35:10.618788096Z 0.030000000000654836
2018-02-02T10:40:11.820355072Z 0.03299999999944703
2018-02-02T10:45:11.634203904Z 0.028000000000247383
2018-02-02T10:50:11.10436096Z  0.02200000000084401
2018-02-02T10:55:10.753853952Z 0.02299999999922875

我努力的地方是让它在连续查询中工作 . 这是我用来设置连续查询的命令:

CREATE CONTINUOUS QUERY cq_Haushaltstromzaehler_cnt ON myhomedb 
BEGIN
    SELECT difference(sum("Haushaltstromzaehler - cnt")) AS "delta" INTO "Haushaltstromzaehler_delta" FROM "myhome_measurements" GROUP BY time(1h)
END

查看InfluxDB日志文件,我发现在连续查询执行的新“delta”度量中没有写入数据:

...finished continuous query cq_Haushaltstromzaehler_cnt, 0 points(s) written...

经过多次故障排除和实验后,我现在明白了为什么没有生成数据 . 设置连续查询需要使用 GROUP BY time() 语句 . 这又需要在 differences() 函数中使用聚合函数 . 现在的问题是聚合函数只返回 GROUP BY time() 指定的时间段内的一个值 . 显然, differences() 函数无法仅计算一个值的差异 . 本质上,连续查询执行如下命令:

> SELECT difference(sum("Haushaltstromzaehler - cnt")) FROM "myhome_measurements" WHERE time >= '2018-02-02T10:00:00Z' AND time < '2018-02-02T11:00:00Z' GROUP BY time(1h)
>

我现在对于如何完成这项工作并且感谢你可能有的任何建议毫无头绪 .

1 回答

相关问题