python - 无法从 flower.command 导入名称 FlowerCommand

标签 python celery airflow flower

我已经安装了 Apache Airflow 2.1.2 版,但是当我启动工作程序时,它说它无法从flower.command 导入名称 FlowerCommand。
操作系统centos 7,
python版本是3.7.6,
apahce-airflow 版本是 2.1.2,
celery 版本是 4.4.7,
花版是0.9.7
我附上了我的错误截图以供进一步澄清 enter image description here

最佳答案

Airflow 2.1.2 尚不支持 Celery 5。
长话短说:只需降级 Celery 提供程序:

$ pip install --upgrade apache-airflow-providers-celery==2.0.0
更多细节在问题中:
https://github.com/apache/airflow/discussions/18115

关于python - 无法从 flower.command 导入名称 FlowerCommand,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/69149501/

相关文章:

作为包类型的 Python 计数器比较

python - 导入模块属性错误,LPTHW ex47

Python:如何在仅更改特定元素时查找列表的所有组合

django - celery 任务将 python 列表转换为字符串。如何避免这种情况?

python: httplib 错误: 无法发送 header

unix - El-cheapo如何监视群集中的任务并在它们崩溃时重新启动( self 修复)?

python - 如何防止 Celery 定期任务执行延迟?

python - 使用 Airflow MySqlOperator 时插入查询中的语法错误

python - Airflow 中的延迟通知系统

Airflow :通过带有参数/配置的 UI 触发 DAG