Apache Airflow 不显示 DAG

问题描述 投票:0回答:2

我在尝试在 Airflow 内设置基本 DAG 文件时遇到一些问题(但我还有其他两个文件)。

我通过 Ubuntu 使用 LocalExecutor 并将我的文件保存在“C:\Users damasce\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 保持这样:

enter image description here

如果需要任何添加信息,请告诉我

airflow
2个回答
1
投票

根据您更新的问题,我可以看到您将 DAg 放置在目录下

“C:\Users damasce\Documents\workspace”以及 dag 和日志文件 里面。

您需要将 dags 添加到 dags_folder(在airflow.cfg 中指定。默认情况下它是 $AIRFLOW_HOME/dags 子文件夹)。查看您的 AIRFLOW_HOME 变量,您应该在那里找到一个 dag 文件夹。

您还可以检查

airflow list_dags
- 这将列出所有的DAG,

您仍然无法在 UI 中获取该信息,然后重新启动服务器。


0
投票

对于那些像我一样后来来到这个线程并发现所有潜在解决方案都不起作用的人(

airflow dags list
返回预期值,重新启动所有容器/服务,重新创建数据库)-我刚刚在以下位置找到了问题的根本原因:至少在六个非常令人沮丧的小时之后......

如果代理阻止 Web 服务器连接到其他容器,则 Web 服务器不会抛出错误 - 从前端看来,它工作正常,甚至可以从 UI 创建连接和变量,并看到它们出现在数据库中,因此设定了连接存在的期望,而其他问题则是问题

似乎 DAG 页面必须在后台使用 API,而创建变量/连接会触发 CLI 界面(未经证实 - 这只是基于对最终修复内容的假设) - 修复代理修复了问题并且 dags 重新出现在用户界面中

© www.soinside.com 2019 - 2024. All rights reserved.