这个问题通常发生在对Airflow进行本地调试时。要解决这个问题,需要在DAG文件的头部加入以下代码:
import sys
sys.path.insert(0, '/path/to/dag/folder')
这个代码会将指定路径下的文件夹添加到Python模块搜索路径中,使得Airflow能够找到本地模块。需要注意的是,代码中的/path/to/dag/folder
需要替换成你自己的DAG文件所在路径。
另一种解决方法是使用Airflow的PythonVirtualenvOperator
或PythonOperator
,它们支持在本地环境中运行Python代码。但是需要注意的是,这种方法只适用于独立的Python文件,不适用于整个DAG文件。