InfluxDB：如何编写Flux查询仅返回增量值？

嗨，我来帮你搞定这个需求！你想要保留那些满足「当前数据点的值小于下一个数据点的值」的记录，过滤掉不符合条件的，对吧？结合你的基础查询，我们可以通过Flux的几个内置函数来实现这个逻辑，具体步骤如下：

实现思路 #

要完成这个筛选，核心是让每个数据点能和它的下一个数据点的值做对比，然后只保留符合条件的记录。我们可以用shift()函数来获取下一个点的值，再通过filter()完成筛选，同时还要确保数据是按时间顺序排列的（这一步很重要，不然前后对比就乱了）。

修改后的完整查询 #

from(bucket:"main")
  |> range(start:v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "AnalogChannels")
  |> filter(fn: (r) => r["channelName"] == "RandoAna1")
  |> filter(fn: (r) => r["_field"] == "value")
  |> sort(columns: ["_time"]) // 确保数据按时间正序排列，保证前后对比的正确性
  |> shift(n: 1, columns: ["_value"], as: "next_value") // 将下一个点的_value存入新字段next_value
  |> filter(fn: (r) => r._value < r.next_value) // 只保留当前值小于下一个值的记录
  |> drop(columns: ["next_value"]) // 可选：移除辅助字段next_value，让结果更简洁
  |> yield()

关键步骤解释 #

• sort(columns: ["_time"])：必须先按时间排序，因为我们要基于时间顺序来对比前后数据点，避免因为数据乱序导致对比错误。
• shift(n: 1, columns: ["_value"], as: "next_value")：shift(n:1)表示将数据向下偏移1位，这样每个记录的next_value字段就会存储下一个时间点的_value值。
• filter(fn: (r) => r._value < r.next_value)：这一步就是核心筛选逻辑，只保留当前值小于下一个值的记录。
• drop(columns: ["next_value"])：这是可选步骤，如果你不需要这个辅助字段，可以用它来移除，让返回的结果更干净。

如果之后你需要调整逻辑（比如保留比前一个值大的记录），只需要把shift(n:1)改成shift(n:-1)，同时把筛选条件改成r._value > r.prev_value就可以啦。

备注：内容来源于stack exchange，提问作者Sirosimo