如何在Spring XD分布式运行时系统中启用批处理作业状态通知的管理功能

Question

我们有一个小集群。其中spring xd分布式运行时架构是ETL的组件。我们使用cron在其中调度批处理作业。但是，当作业失败或中断时，我们不会通过指定通道或电子邮件收到通知，是否可以通过向指定通道发送消息来触发批处理作业?

当前在以下环境下运行:

Spring XD Distributed Runtime - 1.2.1

Hadoop发行版- PHD3.0

Answer 1

您可能需要编写自己的步骤来处理通知。因此，在批处理流程中，您将配置一些只在其他步骤失败时执行的步骤。

之类的…

<job id="job">
    <step id="stepA">
        <next on="*" to="stepB" />
        <next on="FAILED" to="NotifyErrorEmail" />
    </step>
    <step id="stepB".. />
    <step id="NotifyErrorEmail" />
</job>

您可以在Spring批量配置步骤