Apache 气流不显示 DAG
Apache airflow doens't display the DAG
我在尝试在 Airflow 中设置基本 DAG 文件时遇到了一些问题(但我还有其他两个文件)。
我通过 Ubuntu 使用 LocalExecutor 并将我的文件保存在“C:\Users\tdamasce\Documents\workspace”,其中包含 dag 和日志文件。
我的剧本是
# step 1 - libraries
from email.policy import default
from airflow import DAG
from datetime import datetime, timedelta
from airflow.operators.dummy_operator import DummyOperator
# step 2
default_args = {
'ownwer': 'airflow',
'depends_on_past': False,
'start_date': days_ago(2),
'retries':0
}
# step 3
dag = DAG(
dag_id='DAG-1',
default_args=default_args,
catchup=False,
schedule_interval=timedelta(minutes=5)
)
# step 4
start = DummyOperator(
task_id='start',
dag=dag
)
end = DummyOperator(
task_id='end',
dag=dag
)
我的 DAG 一直这样:
如果需要任何添加信息,请告诉我
根据你更新的问题,我可以看到你将 DAg 放在一个目录下
"C:\Users\tdamasce\Documents\workspace" with the dag and log file
inside it.
您需要将 dag 添加到 dags_folder(在 airflow.cfg 中指定。默认情况下它是 $AIRFLOW_HOME/dags 子文件夹)。查看您的 AIRFLOW_HOME 变量,您应该在那里找到一个 dag 文件夹。
您还可以检查 airflow list_dags
- 这将列出所有 dags,
你仍然无法在 UI 中获取它,然后重新启动服务器。
我在尝试在 Airflow 中设置基本 DAG 文件时遇到了一些问题(但我还有其他两个文件)。
我通过 Ubuntu 使用 LocalExecutor 并将我的文件保存在“C:\Users\tdamasce\Documents\workspace”,其中包含 dag 和日志文件。
我的剧本是
# step 1 - libraries
from email.policy import default
from airflow import DAG
from datetime import datetime, timedelta
from airflow.operators.dummy_operator import DummyOperator
# step 2
default_args = {
'ownwer': 'airflow',
'depends_on_past': False,
'start_date': days_ago(2),
'retries':0
}
# step 3
dag = DAG(
dag_id='DAG-1',
default_args=default_args,
catchup=False,
schedule_interval=timedelta(minutes=5)
)
# step 4
start = DummyOperator(
task_id='start',
dag=dag
)
end = DummyOperator(
task_id='end',
dag=dag
)
我的 DAG 一直这样:
如果需要任何添加信息,请告诉我
根据你更新的问题,我可以看到你将 DAg 放在一个目录下
"C:\Users\tdamasce\Documents\workspace" with the dag and log file inside it.
您需要将 dag 添加到 dags_folder(在 airflow.cfg 中指定。默认情况下它是 $AIRFLOW_HOME/dags 子文件夹)。查看您的 AIRFLOW_HOME 变量,您应该在那里找到一个 dag 文件夹。
您还可以检查 airflow list_dags
- 这将列出所有 dags,
你仍然无法在 UI 中获取它,然后重新启动服务器。