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

Question

我有以下结构：

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

import calc

但是我在 Airflow 网站上收到以下错误消息：

任何想法？

Answer 1

我需要在顶部插入以下脚本ren.py：

import sys, os
from airflow.models import Variable

DAGBAGS_DIR = Variable.get('DAGBAGS_DIR')
sys.path.append(DAGBAGS_DIR + '/bi/inbound_layer/')

这样我就可以使用当前的文件夹包。