使用Airflow的MysqlOperator与PostgresOperator时遇模块找不到错误

问题说明 #

使用Airflow的PostgresOperator和MySqlOperator时，导入代码如下：

from airflow.operators.postgres_operator import PostgresOperator
from airflow.providers.mysql.operators.mysql import MySqlOperator

已安装所有依赖，但仍触发报错：

ModuleNotFoundError: No module named 'airflow.providers.postgres.operators'

解决步骤 #

• 统一Airflow 2.x导入路径
  Airflow 2.x将第三方数据库集成全部迁移至airflow.providers命名空间，你的Postgres导入仍使用了1.x的旧路径，导致路径不匹配。修正后的标准导入写法：

  from airflow.providers.postgres.operators.postgres import PostgresOperator
  from airflow.providers.mysql.operators.mysql import MySqlOperator
  

• 验证Postgres Provider安装状态
  重新安装Postgres的Airflow Provider包，确保依赖正确加载：

  pip install apache-airflow-providers-postgres
  

  若需适配指定Airflow版本，需安装兼容的Provider版本：

  pip install apache-airflow-providers-postgres==<对应兼容版本号>
  

• 检查环境一致性
  确认运行Airflow的Python环境与安装依赖的环境一致，避免虚拟环境、全局环境混用导致模块无法找到。比如在虚拟环境中安装依赖后，需确保Airflow也在该虚拟环境中启动。

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