Airflow dags 生命周期事件

我正在尝试通过java后端管理气流dags（创建、执行等）。目前，在创建 dag 并将其放入气流的 dags 文件夹中之后，我的后端不断尝试运行 dag。但在气流调度程序接收到它之前它无法运行它，如果 dag 的数量较多，这可能需要相当长的时间。我想知道气流是否发出任何事件，我可以点击这些事件来检查调度程序处理的新 dag，然后触发，从后端执行命令。或者是否有一种方法或配置可以让气流在处理后自动启动 dag，而不是我们触发它？

有没有一种方法或配置可以让气流在处理后自动启动 dag，而不是我们触发它？

是的，您可以定义的参数之一是is_paused_upon_creation.

如果您将 DAG 设置为：

DAG(
    dag_id='tutorial',
    default_args=default_args,
    description='A simple tutorial DAG',
    schedule_interval="@daily",
    start_date=datetime(2020, 12, 28),
    is_paused_upon_creation=False
)

DAG 将在调度程序接收后立即启动（假设满足运行条件）

我想知道气流是否发出任何事件，我可以点击这些事件来检查调度程序处理的新 dags

在 Airflow >=2.0.0 中，您可以使用 API -列出 dags 端点 http://%20I%20am%20wondering%20if%20there%20any%20events%20that%20airflow%20emits%20which%20I%20can%20tap%20to%20check%20for%20new%20dags%20processed%20by%20scheduler获取 dagbag 中的所有 dags

在任何 Airflow 版本中，您都可以使用以下代码列出 dag_ids：

from airflow.models import DagBag
print(DagBag().dag_ids())