| 声明 | option task = {name: "cpu-downsample", every: 1h, offset: 5m} |
|---|---|
| 逻辑 | from(高精度 bucket) |> range(start: -task.every) |> aggregateWindow(every: 1h, fn: mean) |> to(bucket: "downsampled") |
| 管理 | influx task create/list/run；日志用 influx task log 查看 |
示例
示例
option task = {name: "cpu-downsample", every: 1h, offset: 5m}
from(bucket: "metrics")
|> range(start: -task.every)
|> filter(fn: (r) => r._measurement == "cpu")
|> aggregateWindow(every: 1h, fn: mean, createEmpty: false)
|> to(bucket: "downsampled", org: "my-org")写入 downsampled 的结果保留原测量与标签，同名时间点重复执行会覆盖为同样内容，任务重跑是幂等的。