python - 如何使用 Python 在 Airflow DAG 中导入外部脚本？

Question

我有以下结构：

我尝试在一些inbound_layer类似的文件中导入脚本：

import calc

但是，我在 Airflow web 上收到以下错误消息：

任何想法？

标签： pythonpython-3.xpython-importairflow

Answer 1

dags/, plugins/, and config/Airflow 默认会在 Airflow 主页中添加目录，PYTHONPATH因此您可以例如在文件夹commons下创建文件dags夹，在那里创建文件 ( scriptFileName)。假设脚本有一些GetJobDoneClass你想要导入的类（）， DAG你可以这样做：

from common.scriptFileName import GetJobDoneClass