Jedes Mal, wenn ich airflow worker beginne ich erhalte diesen FehlerAirflow mit Sellerie nicht in der Lage zu verbinden
[2017-11-07 16:24:12,354: ERROR/MainProcess] consumer: Cannot connect to amqp://myuser:**@127.0.0.1:8793/myvhost: timed out. Trying again in 26.00 seconds...
Ich habe die Anweisungen befolgt CeleryExecutors auf Airflow sowie die Installation von RabbitMQ mit dieser documentation zu installieren.
Ich habe gegangen und konfiguriert meine airflow.cfg dies widerzuspiegeln, indem die celery_result_backend und broker_url Punkt an der richtigen Adresse (amqp://myuser:[email protected]:8793/myvhost zum Beispiel aus der Dokumentation) zu ändern. Ich hatte dies zu einem Zeitpunkt und als ich das DAG-Verzeichnis änderte. Das Ändern des DAG-Verzeichnisses sollte keinen Einfluss darauf haben, außer das Ändern des Inhalts des DagBags.
Gibt es noch etwas, das ich untersuchen sollte, um zu debuggen und die Selleriearbeiter zum Laufen zu bringen?