python - Apache Airflow Dag 未列出

Question

我无法列出我新创建的 dag。出现导入错误。请帮助我解决以下错误

:/$ airflow list_dags
[2019-12-27 21:07:50,125] {__init__.py:51} INFO - Using executor SequentialExecutor
[2019-12-27 21:07:50,127] {dagbag.py:403} INFO - Filling up the DagBag from /home/muniaraj/airflow/dags
[2019-12-27 21:07:50,134] {dagbag.py:246} ERROR - Failed to import: /home/muniaraj/airflow/dags/myfirstjob.py
Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/airflow/models/dagbag.py", line 243, in process_file
    m = imp.load_source(mod_name, filepath)
  File "/home/muniaraj/airflow/dags/myfirstjob.py", line 1
    Code that goes along with the Airflow tutorial located at:
            ^
SyntaxError: invalid syntax

Answer 1

你能告诉我你把dag_file.py放在哪里了吗？
您的 dag 文件应位于 airflow-dir/dags 下。

此处，airflow-dir 是您针对环境变量 AIRFLOW_HOME 指定的文件夹。

另外，请确保 dag 的所有者是 dag 文件夹所在的用户，例如，如果它位于 /home/username/ 下的某个位置，则 owner dag 定义的 default_args 应该是 username。

访问FAQs了解更多这样的点。