具有连续计数器的内流aggregateWindow
具有连续计数器的内流aggregateWindow
提问于 2022-02-07 11:36:43
流入2数据库存储来自机械计数器(气体计数器)的增量值。目标是构建一个查询，以获得某一时间间隔(例如某一天)的消耗。使用SQL，我将将数据分组到所需的间隔中，而不是计算该间隔的max() - min() +1。使用通量查询语言进行这一操作的首选方法是什么？
from(bucket: "Energy")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["_measurement"] == "gas")
|> filter(fn: (r) => r["kind"] == "count")
|> aggregateWindow(every: 24h, fn: difference, createEmpty: false)
|> yield(name: "interval")不工作，错误@5:6-5:69:缺少必需的参数列(参数fn)
回答 1
Stack Overflow用户
发布于 2022-02-07 17:31:32
解决方案是在aggregateWindow之前检查difference()，并将其作为聚合函数使用sum。
from(bucket: "Energy")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["_measurement"] == "gas")
|> filter(fn: (r) => r["_field"] == "count")
|> difference()
|> aggregateWindow(every: 1h, fn: sum, createEmpty: false)
|> yield(name: "consumption")页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/71017908
复制相关文章
相似问题
腾讯云开发者
