Я новичок в воздушном потоке и пытаюсь настроить кластер воздушного потока. Проблема в том, что когда я пытаюсь запустить работника воздушного потока, я получаю сообщение об ошибке
KeyError: u'Нет такого транспорта: ampq. Вы имели в виду amqp?
Версии:
- apache -поток == 1.10.6
- сельдерей == 4.0.2
- kombu = = 4.0.2
Мой экземпляр rabbitmq запущен и работает. Не уверен, что я делаю не так. Ниже моя конфигурация в файле airflow.cfg.
broker_url = ampq://guest:***@192.168.43.130:5672//
result_backend = db+postgresql://postgres:***@192.168.43.130:5432/postgres