无法连接到 amqp://user:**@ip-11-222-12-117:5672//：无法登录：发生套接字错误

Question

我正在尝试在EC2上使用芹菜和兔子Mq来扩展气流。

我遵循以下代码：http://site.clairvoyantsoft.com/setting-apache-airflow-cluster/

以下是主节点中的代码。

sql_alchemy_conn = postgresql+psycopg2://user:gues@localhost:5432/airflow
executor = CeleryExecutor
broker_url = amqp://user:gues@ip-11-222-12-117:5672
celery_result_backend = db+postgresql://user:gues@localhost:5432/airflow

以下是药膏节点的代码：

sql_alchemy_conn = postgresql+psycopg2://user:gues@ip-11-222-12-117:5432/airflow
executor = CeleryExecutor
broker_url = amqp://user:gues@ip-11-222-12-117:5672
celery_result_backend = db+postgresql://user:gues@localhost:5432/airflow

当我运行airflow scheduler时，它工作正常。但是在从属节点上，我收到以下错误：

[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..

但是，我能够在 rabbitMQ UI 上看到使用 rabbitMq 连接的两个节点。

我做错了什么？

Answer 1

您是否检查过是否允许 amqp 服务器侦听环回以外的任何内容？请检查此答案：全新安装后无法访问 RabbitMQ Web 管理界面