在influx中使用flux语言修改系列数据答案

【问题标题】：Modifying the series data using flux language in influx在influx中使用flux语言修改系列数据
【发布时间】：2019-05-09 06:52:26
【问题描述】：

我有一个函数，它每 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?)

【问题讨论】：

标签： influxdb influxql fluxlang

【解决方案1】：

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

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

【讨论】：