fluxql使用样本和组创建新任务FLUX

Question

我6个小时尝试将influxQL转换为FLUX查询。谁能做?

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在他们的文档中提供的示例(在这里)，我将这个连续查询拆分为四个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并不严重。我尝试从1.8迁移到2.0，但这是一场噩梦:无法在1.8中测试flux任务，无法在2.0中使用CQ来简化迁移。每个CQ都必须手动重写，我有数百个CQ…