influxdb - 在influx中使用flux语言修改系列数据

Question

我有一个函数，它每 5 分钟从一次测量中获取第一个值。

ever5Mins1st = from(bucket: "Historian/oneday")
  |> range(start: dashboardTime)
  |> filter(fn: (r) => 
    r._measurement == "InventoryStock" and
    r._field =="Value"  and
    r.Location=="NYC"
  )
 |>window(every:5m)
 |>first()
 |>window(every:inf)

现在如果我想对两个连续点进行差分，我可以使用差分函数

 ever5Mins1st
 |>difference()

但是如果我这样做，我想要每个连续点或每 5 个点的总和。

我知道我可以编写接收管道数据的自定义函数。但是我需要写一个for循环吗？有没有 for 循环和条件语句的例子？

// Function definition
add = (tables=<-) =>
  tables
    |> map(fn: (r) => //What should I do here, for loop?)

Answer 1

我不相信目前这是可能的。这将需要一个chunk函数，将列表拆分为列表块。

我将向 Flux 添加一个问题并开始实现此功能：+1：