0
セロリとrabbitMqを使用して気流を拡大しようとしていますEC2。amqp：// userに接続できません：** @ ip-11-222-12-117：5672 //：ログインできませんでした：ソケットエラーが発生しました
私は、次の午前、以下のコード： http://site.clairvoyantsoft.com/setting-apache-airflow-cluster/
後は、マスターノード内のコードです。
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
続いてスレーブノードのためのコードです：
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
私はairflow schedulerを実行すると、それが正常に動作します。私はRabbitMQのUI上でのRabbitMQを使用して接続し、両方のノードを見ることができていますが
[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..
：しかし、スレーブノード上で、私は、次のエラーを取得しています。
私は間違っていますか？
ありがとう、私は以下のように許可を忘れてしまった：rabbitmqctl set_permissions -p/test "。*" "。*" "。*" –