订阅 Task/Batch 事件

您可以在启动 Task 时,设置各种 Task/Batch Events。如果 Task 配置启用了事件(如果 Kafka 作为 binder ,需要依赖spring-cloud-task-stream 以及spring-cloud-stream-binder-kafka),那么这些启用的事件将在 Task 执行过程中触发。默认情况下,destination 的名称就是 events 的名称(例如:task-eventsjob-execution-events等等)。

dataflow:>task create myTask --definition "myBatchJob"
dataflow:>stream create task-event-subscriber1 --definition ":task-events > log" --deploy
dataflow:>task launch myTask

您可以通过在启动任务时可以配置事件的名称,如下所示:

dataflow:>stream create task-event-subscriber2 \
--definition ":myTaskEvents > log" --deploy
dataflow:>task launch myTask \
--properties "app.myBatchJob.spring.cloud.stream.bindings.task-events.destination=myTaskEvents"

下表列出了代理上的默认任务和批处理事件和目标名称:

Event

Destination

Task events

task-events

Job Execution events

job-execution-events

Step Execution events

step-execution-events

Item Read events

item-read-events

Item Process events

item-process-events

Item Write events

item-write-events

Skip events

skip-events

Last updated

Was this helpful?