芹菜的气流无法连接
Airflow with Celery not able to connect
每次我开始 airflow worker 我总是收到这个错误
[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...
我已按照说明在 Airflow 上安装 CeleryExecutors 以及使用此 documentation 安装 RabbitMQ。
我已经配置了我的 airflow.cfg 以通过更改 celery_result_backend 和 broker_url 指向正确的地址（例如 amqp://myuser:mypassword@localhost:8793/myvhost，从文档）。我在某个时候和更改 DAG 目录时设置了 运行。除了更改 DagBag 中的内容之外，更改 DAG 目录应该不会对其产生影响。
还有什么我应该查看以调试和启动 Celery Worker 以及 运行 吗？
关注帖子here and here，因为我是运行Celery4.1.0。我降级到Celery3.1.7，现在可以使用了。
每次我开始 airflow worker 我总是收到这个错误
[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...
我已按照说明在 Airflow 上安装 CeleryExecutors 以及使用此 documentation 安装 RabbitMQ。
我已经配置了我的 airflow.cfg 以通过更改 celery_result_backend 和 broker_url 指向正确的地址（例如 amqp://myuser:mypassword@localhost:8793/myvhost，从文档）。我在某个时候和更改 DAG 目录时设置了 运行。除了更改 DagBag 中的内容之外，更改 DAG 目录应该不会对其产生影响。
还有什么我应该查看以调试和启动 Celery Worker 以及 运行 吗？
关注帖子here and here，因为我是运行Celery4.1.0。我降级到Celery3.1.7，现在可以使用了。