Inflxudb2 任务使用简介之1.0版本中连续查询如何转换为任务
Publish: December 1, 2020 Category: 编程,运维 No Comments
influxdb1.x版本中支持的CQs(连续查询)在influxdb2.x中被task取代,全新定义了一套新的规则,我们暂且称之为任务规则。
如果你是从1.x版本中迁移数据,可以直接将1.x中的CQs直接转换成task来执行比如我之前的一段CQs:
create continuous query flow_rx_cq on multiwan
begin
select sum(value)
into "multiwan_inf"."autogen"."flow_rx_cq_result"
from multiwan_raw_rx
group by time(30m), flashid,imei,imsi,iccid
end
转换之后对应的是
from(bucket: "multiwan/")
|> range(start: -3d)
|> filter(fn: (r) => r._measurement == "multiwan_raw_rx")
|> filter(fn: (r) => r._field == "value")
|> aggregateWindow(every: 1m, fn: sum)
|> set(key: "_measurement", as: "flow_rx_cq_result")
|> to(
org: "example-org",
bucket: "multiwan/flow_rx_cq"
)
上面的命令是如下意思:
在multiwan的bucket中,创建一个连续查询结果存放在multiwan_rx_cq_result中,数据来源是multiwan_raw_rx 每一分钟执行一次计算value字段的累计结果值。
在命令行中执行
使用raw Flux创建一个任务
influx task create --org my-org - # <return> to open stdin pipe
options task = {
name: "flow_rx_task_result",
every: 6
}
# <ctrl-d> to close the pipe and submit the command 按ctrl+d 关闭管道并提交
Related Posts: