Airflow DAG开发中的模块导入问题咨询

我在尝试用pip install airflow安装Airflow时，得到提示Please install package apache-airflow instead of airflow。安装apache-airflow是成功的，但当我尝试用from apache-airflow import DAG时，连字符会导致语法错误；而用from airflow import DAG又无法找到airflow模块。请问我该如何在编写DAG时正确引入Airflow的库？

这其实是Airflow包命名和Python模块规则的常见小冲突，我来给你拆解解决：

• 先理清包名和模块名的区别：PyPI上的Airflow包名叫apache-airflow（这是给pip用的安装名称），但Python的模块命名规则不允许出现连字符，所以实际在代码里要导入的模块根名是airflow——这是Airflow包内部定义的合法模块路径，和PyPI的包名是分开的。

• 解决from airflow import DAG找不到模块的问题：
  这种情况大多是因为你的Python运行环境和安装apache-airflow的环境不匹配，给你几个快速排查和解决的方法：

  1. 如果你用了虚拟环境，先确保激活了安装Airflow的那个虚拟环境，再运行DAG脚本；
  2. 检查pip和Python版本是否对应：比如同时装了Python2和Python3时，pip可能对应Python2，pip3对应Python3，你可以用pip3 install apache-airflow安装，再用python3运行脚本；
  3. 验证环境一致性：终端运行pip show apache-airflow查看Airflow的安装路径，然后在DAG脚本开头加这段代码打印当前Python的环境路径，确认Airflow的安装路径在列表里：

     import sys
     print("当前Python环境路径：", sys.path)
     

• 正确的导入示例参考：
  所有Airflow的库都通过airflow根模块导入，比如常用的DAG和操作符导入：

  # 导入核心DAG类
  from airflow import DAG
  # 导入Python执行器
  from airflow.operators.python import PythonOperator
  # 导入日期工具类
  from airflow.utils.dates import days_ago
  

备注：内容来源于stack exchange，提问作者BlueSun