如何解决Apache Airflow 2.0 Celery Executor 安装
我知道对于 Airflow CeleryExecutor,需要 celery 和 rabbitmq(或 redis)。
是否只需运行 pip install apache-airflow[celery,rabbitmq]
即可满足要求,还是需要运行 sudo yum install rabbitmq-server
和 pip install celery
?
我的问题是针对 Airflow 2.0+
解决方法
-
如果您在全新的虚拟环境中安装
apache-airflow[celery]
,您会看到它已经为您安装了celery
。因此,pip install celery
是多余的。 -
您确实需要rabbitMQ 服务器(实际过程)。或者,您可以在 docker 中使用 rabbitMQ。
-
不确定
apache-airflow[rabbitmq]
,因为我知道 Celery 使用amqp
协议与 rabbitMQ 通信。amqp==5.0.6
软件包与celery
的安装一起安装(由pip install apache-airflow[celery]
发生)。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。