Apache Airflow 2.1.2启动worker报错：无法从flower.command导入FlowerCommand

这个报错是Flower版本与Airflow 2.1.2不匹配导致的导入异常。Airflow 2.1.2的Celery Executor组件预期从flower.command模块导入FlowerCommand，而你当前使用的Flower 0.9.7版本中，该类的存放路径和Airflow预期不一致，因此触发导入失败。

• 操作系统：CentOS 7
• Python版本：3.7.6
• Apache Airflow版本：2.1.2
• Celery版本：4.4.7
• 当前Flower版本：0.9.7

1. 卸载当前安装的低版本Flower

pip uninstall -y flower

2. 安装匹配Airflow 2.1.2的Flower版本

pip install flower==1.0.0

3. 重启Airflow Worker节点，即可正常启动

内容的提问来源于stack exchange，提问作者Shafiqul Islam