InfluxDB Flux - 将最后一个和第一个值作为列获取

Question

我正在尝试使用last()和first()函数创建两个具有第一个和最后一个值的新列。但是，当我尝试映射新列时，该功能不起作用。下面是示例代码。使用 Flux 可以实现这一点吗？

from(bucket: "bucket")

  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "price_info")
  |> filter(fn: (r) => r["_field"] == "price")
  |> map(fn: (r) => ({r with  
  open: last(float(v: r._value)),
  close: first(float(v: r._value)),
  })

Answer 1

我不会直接回答这个问题，但它可能会有所帮助。 我想在 first 和 last 之间执行一些计算，这是我的方法，我不知道这是否是正确的方法。

想法是创建 2 个表，一个仅包含 first 值，另一个仅包含 last 值，然后在两者之间执行并集。

data = from(bucket: "bucket")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["_measurement"] == "plop")

l = data
|> last()
|> map(fn:(r) => ({ r with _time: time(v: "2011-01-01T01:01:01.0Z") }))

f = data
|> first()
|> map(fn:(r) => ({ r with _time: time(v: "2010-01-01T01:01:01.0Z") }))

union(tables: [f, l])
|> sort(columns: ["_time"])
|> difference()

出于未知原因，我必须设置错误的日期，只是为了能够对值进行排序并考虑到 first 在 last 之前。