@vitafon007

Как запустить dag airflow по сообщению в kafka?

прошу поделиться примером для решения задачи:
есть несколько машин с воркерами airflow, необходимо по сообщению из кафки, поставить dag в очередь выполнения, чтобы свободная машина забрала его на выполнение.
  • Вопрос задан
  • 36 просмотров
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы