0
J'essaye de faire évoluer le débit d'air en utilisant celery et rabbitMq EC2.Impossible de se connecter à amqp: // utilisateur: ** @ ip-11-222-12-117: 5672 //: Connexion impossible: une erreur de socket est survenue
Je suivais le code suivant: http://site.clairvoyantsoft.com/setting-apache-airflow-cluster/
code suivant est dans le nœud maître.
sql_alchemy_conn = postgresql+psycopg2://user:[email protected]:5432/airflow
executor = CeleryExecutor
broker_url = amqp://user:[email protected]:5672
celery_result_backend = db+postgresql://user:[email protected]:5432/airflow
code suivant est pour le noeud Salve:
sql_alchemy_conn = postgresql+psycopg2://user:[email protected]:5432/airflow
executor = CeleryExecutor
broker_url = amqp://user:[email protected]:5672
celery_result_backend = db+postgresql://user:[email protected]:5432/airflow
Quand je lance airflow scheduler, il fonctionne très bien. Mais sur le noeud esclave, je reçois l'erreur suivante:
[2017-05-23 21:47:44,385: ERROR/MainProcess] consumer: Cannot connect to amqp://user:**@ip-11-222-12-117:5672//: Couldn't log in: a socket error occurred.
Trying again in 2.00 seconds..
Cependant, je suis en mesure de voir les deux noeuds connectés en utilisant rabbitmq sur rabbitmq interface utilisateur.
Qu'est-ce que je fais mal?
Merci, j'ai oublié de fournir la permission comme suit rabbitmqctl set_permissions -p/test ". *" ". *" ". *" –