У меня есть кластер воздушного потока с использованием сельдерея и Redis. У меня есть одна задача, которую я хочу запустить для всех рабочих. Как я могу это сделать ?
Причина: мы добавляем и уменьшаем воздушный поток в зависимости от нагрузки. Мне нужно запустить одну задачу на всех узлах.
Спасибо за помощь.
Похоже, вы пытаетесь контролировать свои рабочие узлы в кластере Airflow, увеличивая рабочие узлы / исполнителя, если рабочий находится под высокой нагрузкой? Это то, что вы пытаетесь сделать?
Если это так, я думаю, что такую работу следует выполнять с помощью другого инструмента, например Jenkins + Ansible.
Если нет, проигнорируйте это или обновите свой вопрос, добавив дополнительную информацию.
