Мы используем Airflow (1.10.3) с исполнителем сельдерея (4.1.1 (latentcall)) и брокером SQS. При отладке проблемы мы попробовали свои силы на CLI сельдерея и обнаружили, что SQS-брокер не поддерживается ни для одной из команд проверки или, например, инструмента мониторинга. Цветок. Есть ли какой-нибудь способ, которым мы можем отслеживать задачи или события на работниках сельдерея?
Мы попробовали проклятие монитора, как показано ниже:
события сельдерея -b sqs: //
Ноэто показывает, что ни один рабочий не обнаружен, никакие задачи не выбраны. Команды проверки непосредственно показывают:
Доступность: транспорты RabbitMQ (AMQP) и Redis.
Пожалуйста, дайте мне знать, если я что-то упускаю или возможно ли контролировать работников сельдерея с помощью SQS.