代码之家 › 专栏 › 技术社区 › Nikko

从气流中的dag子文件夹导入文件

airflow-scheduler airflow

0

Nikko · 技术社区 · 5 年前

我正在编写一个python脚本,用于计算某些东西。这就是脚本与dags文件夹分离的原因。在这个脚本中,我必须导入一个文件。但我没有成功,因为它是错误的 FileNotFoundError .

这是我的目录:

dags/
- my_dag.py
  sub_folder/
  - __init__.py
  - my_functions.py
    meta/
    - file.csv

我的_功能。py包含我的DAG中所需的计算脚本。它必须阅读 文件csv 位于元文件夹

在我的功能中。我写道:

file_df = pd.read_csv('meta/file.csv')

但是找不到该文件。

1 回复 | 直到 5 年前

1

5

Nihal Sangeeth 5 年前

使用 AIRFLOW_HOME env变量并提供完整路径。

import os
AIRFLOW_HOME = os.getenv('AIRFLOW_HOME')
file_df = pd.read_csv(AIRFLOW_HOME + '/dags/sub_folder/meta/file.csv')