创建 Kapacitor Flux 任务
使用 kapacitor CLI 或 Kapacitor HTTP API 来创建 Kapacitor Flux 任务。
使用 kapacitor flux task create 命令来创建新的 Kapacitor Flux 任务。提供以下标志
* 必需
- *
-f,--file: 要添加的 Flux 任务的文件路径
kapacitor flux task create --file /path/to/task.flux
默认情况下，新的 Flux 任务设置为 active 状态，并将按照定义的计划开始运行。要禁用 Flux 任务，请 更新任务状态。
使用以下请求方法和端点来创建新的 Kapacitor Flux 任务。
POST /kapacitor/v1/api/v2/tasks在您的请求中提供以下内容（* 必需）
标头
- * Content-type: application/json
请求体
具有以下架构的 JSON 对象
- * flux: Flux 任务代码
- status: Flux 任务状态（
active或inactive，默认为active） - description: Flux 任务描述
curl --request POST 'http://localhost:9092/kapacitor/v1/api/v2/tasks' \
--header 'Content-Type: application/json' \
--data-raw '{
"flux": "option task = {name: \"CPU Total 1 Hour New\", every: 1h}\n\nhost = \"http://localhost:8086\"\ntoken = \"\"\n\nfrom(bucket: \"db/rp\", host:host, token:token)\n\t|> range(start: -1h)\n\t|> filter(fn: (r) =>\n\t\t(r._measurement == \"cpu\"))\n\t|> filter(fn: (r) =>\n\t\t(r._field == \"usage_system\"))\n\t|> filter(fn: (r) =>\n\t\t(r.cpu == \"cpu-total\"))\n\t|> aggregateWindow(every: 1h, fn: max)\n\t|> to(bucket: \"cpu_usage_user_total_1h\", host:host, token:token)",
"status": "active",
"description": "Downsample CPU data every hour"
}'
此页面是否对您有帮助？
感谢您的反馈！
支持和反馈
感谢您成为我们社区的一份子！我们欢迎并鼓励您提供关于 Kapacitor 和本文档的反馈和错误报告。要获得支持，请使用以下资源