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

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

  •  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')