Как включить административные функции для уведомления о статусе пакетного задания в распределенной системе выполнения Spring XD

У нас есть небольшой кластер. В котором распределенная архитектура времени выполнения spring xd является компонентом для ETL. Мы запланировали пакетное задание в нем с помощью cron. Но когда задание завершается сбоем или прерывается, мы не получаем уведомления по именованному каналу или электронной почте, и возможно ли запускать пакетные задания, отправляя сообщения на именованные каналы?

В настоящее время работает в следующей среде:

Распределенная среда выполнения Spring XD — 1.2.1

Распределение Hadoop — PHD3.0

Любая помощь в этом будет высоко оценена.


person NEO    schedule 25.09.2015    source источник


Ответы (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 Batch.

person Ali    schedule 27.09.2015
comment
Спасибо, за направление дал нам. - person NEO; 04.10.2015