更新 Kapacitor Flux 任务
使用 kapacitor CLI 或 Kapacitor HTTP API 更新 Kapacitor Flux 任务。
使用 kapacitor flux task update 命令更新 Kapacitor Flux 任务。 提供以下标志
* 必需
- *
-i,--id: 任务 ID --status: 更新的任务状态 (active或inactive)-f,--file: 更新的 Flux 脚本文件路径
示例
更新 Flux 任务代码
kapacitor flux task update \
--id 000x00xX0xXXx00 \
--file /path/to/updated-task.flux
启用或禁用 Flux 任务
kapacitor flux task update \
--id 000x00xX0xXXx00 \
--status inactive
使用以下请求方法和端点更新新的 Kapacitor Flux 任务。
PATCH /kapacitor/v1/api/v2/tasks/{taskID}在您的请求中提供以下内容 (* 必需)
标头
- * Content-type: application/json
路径参数
- * taskID: 要更新的任务 ID
请求正文
具有以下架构的 JSON 对象
- cron: 覆盖
cronFlux 任务选项 - description: 新任务描述
- every: 覆盖
everyFlux 任务选项 - flux: 新 Flux 任务代码
- name: 覆盖
nameFlux 任务选项 - offset: 覆盖
offsetFlux 任务选项 - status: 新 Flux 任务状态 (
active或inactive)
API 示例
以下示例使用任务 ID 000x00xX0xXXx00。
更新 Flux 任务代码
curl --request PATCH 'http://localhost:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00' \
--header 'Content-Type: application/json' \
--data-raw '{
"flux": "option task = {name: \"Updated task name\", 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)"
}'
启用或禁用 Flux 任务
curl --request PATCH 'http://localhost:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00' \
--header 'Content-Type: application/json' \
--data-raw '{"status": "inactive"}'
覆盖 Flux 任务选项
curl --request PATCH 'http://localhost:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00' \
--header 'Content-Type: application/json' \
--data-raw '{
"every": "1d",
"name": "New task name",
"offset": "15m"
}'
此页面是否对您有帮助？
感谢您的反馈！
支持与反馈
感谢您成为我们社区的一份子！ 我们欢迎并鼓励您对 Kapacitor 和本文档提供反馈和错误报告。 要获得支持，请使用以下资源