如何在Airflow中正确配置plugins文件夹并解决模块导入报错问题

检查airflow.cfg配置与服务重启 #

• 确认airflow.cfg中的dags_folder配置项为你的DAG目录绝对路径，比如/home/xxx/airflow/dags_folder
• 修改配置后必须重启Airflow的webserver、scheduler、worker所有服务，配置才会生效

调整Python路径与导入方式 #

如果你的plugins目录在dags_folder下，可通过以下方式让Python识别到该模块：
在DAG文件开头添加路径配置代码：

import sys
from pathlib import Path

# 将dags_folder加入Python路径
dags_dir = Path(__file__).parent
sys.path.append(str(dags_dir))

# 现在可以直接导入plugins下的模块
from plugins import fetchingData

或者，将plugins目录迁移到Airflow默认插件目录（通常为$AIRFLOW_HOME/plugins），Airflow会自动加载该目录下的插件，无需手动配置路径

确认conda环境一致性 #

• 执行which airflow检查Airflow启动路径，确保其指向conda环境的bin目录
• 若路径不对，先激活目标conda环境：conda activate your_env，再重启Airflow服务

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