Параметры потока Азкабан

Question

Как вы устанавливаете параметры потока для каждой работы? Я пытаюсь настроить собственный оповещатель и хочу, чтобы каждая работа вызывала его. Похоже, что он ищет свойство "alert.type" из параметров потока, но сейчас я могу только вызвать его через интерфейс. Есть идеи?

Answer 1

Вы можете использовать REST API:

curl -k -d flowOverride[alert.type]=my-alerter -d scheduleDate=01/30/2017 -d scheduleTime=03,44,pm,PDT -d is_recurring=off -d projectId=1 -d ajax=scheduleFlow -d projectName=myproject -d flow=myflow -b "azkaban.browser.session.id=..." http://localhost:8081/schedule

Пожалуйста, обратите внимание на параметр

flowOverride[alert.type]=alerter-name

https://groups.google.com/forum/

Answer 2

В моем случае я изменил исходный код модуля:azkaban-common, сорт:azkaban.server.HttpRequestUtilsпосле строки номер 104 добавьте этот код:flowParamGroup.put("alert.type", "XXX");