使用重采样和分组将InfluxQL添加到新任务流

Question

我花了6个小时尝试将influxQL转换为通量查询。有没有人能做到？

CREATE CONTINUOUS QUERY trade_to_candles_60 ON mydb 
RESAMPLE EVERY 10s FOR 10m 
BEGIN SELECT first(price) AS open, last(price) AS close, max(price) AS high, min(price) AS low, sum(amount) AS volume INTO 
candles_1m FROM trades WHERE 
GROUP BY time(1m), pair, exchange END

Answer 1

按照influxdata在其文档(here)中提供的示例，我将把这个连续的查询分成四个flux任务，如下所示：

import "experimental"

options task = {
  name: "trade_to_candles_60_open",
  every: 10s
}

from(bucket: "mydb/")
  |> range(start: experimental.subDuration(d: 10m, from: now()))
  |> filter(fn: (r) =>
    r._measurement == "trades" and
    r._field == "price"
  )
  |> group(columns: ["pair","exchange"])
  |> aggregateWindow(every: 1m, fn: first)
  |> set(key: "_field", as: "open")
  |> to(bucket: "mydb/candles_1m")

我个人认为，influxdata没有提供任何CQ到flux任务转换器并不严重。我尝试从1.8迁移到2.0，但这是一场噩梦:无法在1.8中测试flux任务，无法在2.0中使用CQ来简化迁移。每个CQ都必须在flux任务中手动重写，我有数百个CQ…