如何使用Python在Airflow DAG中导入外部脚本？
如何使用Python在Airflow DAG中导入外部脚本？
提问于 2019-05-15 00:18:20
我有以下结构：
我尝试在inbound_layer的一些文件中导入脚本，如下所示：
import calc然而，我在Airflow web上收到以下错误信息：
有什么想法吗？
回答 2
Stack Overflow用户
回答已采纳
发布于 2019-05-15 03:25:31
我需要在ren.py的顶部插入以下脚本：
import sys, os
from airflow.models import Variable
DAGBAGS_DIR = Variable.get('DAGBAGS_DIR')
sys.path.append(DAGBAGS_DIR + '/bi/inbound_layer/')这样，我就可以使用当前的文件夹包。
Stack Overflow用户
发布于 2021-04-01 23:27:29
Airflow默认情况下会将Airflow主目录中的dags/, plugins/, and config/目录添加到PYTHONPATH，因此您可以例如在dags文件夹下创建文件夹commons，在那里创建文件(scriptFileName )。假设脚本中有一些您想要导入到DAG中的类(GetJobDoneClass)，您可以这样做：
from common.scriptFileName import GetJobDoneClass页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/56134683
复制相关文章
相似问题