管理 Kapacitor Flux 任务运行
使用 kapacitor CLI 或 Kapacitor HTTP API 来管理 Kapacitor Flux 任务运行。每个 Flux 任务执行都被视为“运行”。
使用 kapacitor flux task run list 命令及其子命令来管理 Kapacitor Flux 任务运行。
列出 Kapacitor Flux 任务运行
使用 kapacitor flux task run list 命令来输出 Kapacitor Flux 任务日志。提供以下标志
* 必需
- *
--task-id: 任务 ID --run-id: 按运行 ID 筛选--before: 返回在此时间之前发生的任务运行 (RFC3339 时间戳)--after: 返回在此时间之后发生的任务运行 (RFC3339 时间戳)--limit: 限制返回的任务运行数量 (默认为 100)
CLI 示例
列出 Flux 任务的运行
kapacitor flux task run list --task-id 000x00xX0xXXx00
列出在时间范围内发生的 Flux 任务运行
kapacitor flux task run list \
--task-id 000x00xX0xXXx00 \
--after 2021-01-01T00:00:00Z \
--before 2021-01-31T00:00:00Z
列出有限数量的 Flux 任务运行
kapacitor flux task run list \
--task-id 000x00xX0xXXx00 \
--limit 10
重试 Kapacitor Flux 任务运行
使用 kapacitor flux task run retry 命令来重试 Kapacitor Flux 任务运行。提供以下标志
* 必需
- *
--task-id: 任务 ID - *
--run-id: 运行 ID
kapacitor flux task run retry \
--task-id 000x00xX0xXXx00 \
--run-id XXX0xx0xX00Xx0X
列出 Kapacitor Flux 任务运行
使用以下请求方法和端点来列出 Kapacitor Flux 任务运行。
GET /kapacitor/v1/api/v2/tasks/{taskID}/runs在您的请求中提供以下内容 (* 必需)
标头
- * Content-type: application/json
路径参数
- * taskID: 任务 ID
查询参数
- after: 列出在特定运行 ID 之后的任务运行
- afterTime: 返回在此时间之后发生的任务运行 (RFC3339 时间戳)
- beforeTime: 返回在此时间之前发生的任务运行 (RFC3339 时间戳)
- limit: 限制返回的任务运行数量 (默认为 100)
API 示例
以下示例使用任务 ID 000x00xX0xXXx00。
列出 Flux 任务的所有运行
curl --GET 'http://localhost:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00/runs' \
--header 'Content-Type: application/json'
列出 Flux 任务的有限数量的运行
curl --GET 'http://localhost:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00/runs' \
--header 'Content-Type: application/json' \
--data-urlencode "limit=10"
列出特定运行 ID 之后的 Flux 任务运行
curl --GET 'http://localhost:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00/runs' \
--header 'Content-Type: application/json' \
--data-urlencode "after=XXX0xx0xX00Xx0X"
列出在时间范围内发生的 Flux 任务运行
curl --GET 'http://localhost:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00/runs' \
--header 'Content-Type: application/json' \
--data-urlencode 'afterTime=2021-01-01T00:00:00Z' \
--data-urlencode 'beforeTime=2021-01-31T00:00:00Z'
重试 Kapacitor Flux 任务运行
使用以下请求方法和端点来重试 Kapacitor Flux 任务运行。
POST /kapacitor/v1/api/v2/tasks/{taskID}/runs/{runID}/retry在您的请求中提供以下内容 (* 必需)
路径参数
- * taskID: 任务 ID
- * runID: 要重试的运行 ID
# Retry run ID XXX0xx0xX00Xx0X for task ID 000x00xX0xXXx00
curl --request POST \
'http://localhost:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00/runs/XXX0xx0xX00Xx0X'
对于重试所有失败的任务运行的简便方法，请参阅 重试失败的 Kapacitor 任务。
此页是否对您有帮助？
感谢您的反馈！