管理 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在请求中提供以下信息（* 必填）
Headers
- * Content-type: application/json
路径参数
- * taskID: 任务 ID
查询参数
- after: 列出特定运行 ID 之后的任务运行
- afterTime: 返回在此时间之后发生的任务运行（RFC3339 时间戳）
- beforeTime: 返回在此时间之前发生的任务运行（RFC3339 时间戳）
- limit: 限制返回的任务运行数量（默认为 100）
API 示例
以下示例使用了任务 ID 000x00xX0xXXx00。
列出 Flux 任务的所有运行
curl --GET 'https://:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00/runs' \
--header 'Content-Type: application/json'列出 Flux 任务的有限数量的运行
curl --GET 'https://:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00/runs' \
--header 'Content-Type: application/json' \
--data-urlencode "limit=10"列出特定运行 ID 之后的 Flux 任务运行
curl --GET 'https://:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00/runs' \
--header 'Content-Type: application/json' \
--data-urlencode "after=XXX0xx0xX00Xx0X"列出在某个时间范围内的 Flux 任务运行
curl --GET 'https://: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 \
'https://:9092/kapacitor/v1/api/v2/tasks/000x00xX0xXXx00/runs/XXX0xx0xX00Xx0X'要轻松重试所有失败的任务运行，请参阅 重试失败的 Kapacitor 任务。
此页面是否有帮助？
感谢您的反馈！
支持和反馈
感谢您成为我们社区的一员！我们欢迎并鼓励您对 Kapacitor 和本文档提供反馈和错误报告。要获取支持，请使用以下资源：