Apache Расписание воздушного потока с временной привязкой и запуском

Question

Я использую воздушный поток с использованием сельдерея. Теперь я планирую разработать взаимодействие с пользователем для решения задачи выбора филиала с использованием BranchOperator в DAG. Его работа выполняется путем непрерывного цикла проверки значения в базе данных. Но я считаю, что это не очень хороший подход. Есть ли альтернатива для этого?

И я хочу дождаться этого взаимодействия до определенного времени, иначе я хочу остановиться. Возможно ли это сделать в воздушном потоке? А если возможно, то есть ли возможность изменить это время динамически?

Заранее спасибо.

Answer 1

Для этого не следует использовать BranchOperator. Если вы хотите продолжить работу в своем dag на основе некоторого значения в db, вы должны использовать датчик. В воздухе есть некоторые датчики с полки, и вы также можете посмотреть на некоторые из них, чтобы создать свои собственные. Датчики в основном проводят опрос по определенным критериям и тайм-ауту после настраиваемого периода времени. С вашего вопроса, похоже, это именно то, что вам нужно.