Airflow新手求助：airflow.decorators等模块导入失败问题

1. 修正导入语句拼写错误 #

你写的airflow.operators.pythonOperators是错误路径，正确的PythonOperator位于airflow.operators.python模块下，且类名首字母大写：

# 正确导入PythonOperator
from airflow.operators.python import PythonOperator
# 正确导入装饰器
from airflow.decorators import dag, task

2. 确认Python解释器与Airflow环境匹配 #

• 激活你安装Airflow的虚拟环境，运行which python（Linux/macOS）或where python（Windows），获取当前环境的Python路径。
• 在代码编辑器（如VS Code）中，将解释器切换为上述路径，避免编辑器使用系统默认Python导致找不到Airflow包。

3. 验证Airflow环境配置 #

• 终端运行echo $AIRFLOW_HOME（Linux/macOS）或echo %AIRFLOW_HOME%（Windows），确认环境变量指向你的Airflow配置目录。
• 执行airflow info，检查输出中的Airflow Version是否为2.3.4，Python Version是否与当前激活环境一致。

4. 重新安装Airflow（必要时） #

如果环境存在依赖损坏，可在虚拟环境中重装：

pip uninstall apache-airflow -y
pip install apache-airflow==2.3.4 --constraint "https://raw.githubusercontent.com/apache/airflow/constraints-2.3.4/constraints-3.7.txt"

注意将constraints-3.7.txt替换为你实际使用的Python版本对应的约束文件（如3.8对应constraints-3.8.txt）。

5. 重启Airflow服务 #

修改配置或重装后，重启webserver和scheduler：

airflow webserver -p 8080 -D
airflow scheduler -D

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