Airflow是否支持无需调度、仅手动或程序化触发的工作流？

绝对可以！Airflow完全支持创建不需要绑定任何固定调度的工作流（DAG），这类DAG不会自动按照周期运行，只能通过手动触发或者程序化的方式执行，完全匹配你的需求。

核心配置实现 #

要打造这类按需执行的DAG，关键是在定义DAG时将schedule_interval参数设置为None，具体示例如下：

from airflow import DAG
from airflow.operators.python import PythonOperator
from datetime import datetime

def run_my_task():
    print("执行按需触发的任务逻辑")

with DAG(
    dag_id="on_demand_manual_trigger_dag",
    start_date=datetime(2024, 1, 1),
    schedule_interval=None,  # 核心设置：无自动调度
    catchup=False,  # 建议关闭，避免历史任务自动补跑
    tags=["manual", "on-demand"]
) as dag:
    core_task = PythonOperator(
        task_id="core_business_task",
        python_callable=run_my_task
    )

触发方式 #

1. 手动触发 #

• Airflow UI操作：进入DAG列表页面，找到目标DAG，点击右侧的「Trigger DAG」按钮即可立即启动执行。
• CLI命令触发：通过终端执行Airflow命令：

  airflow dags trigger on_demand_manual_trigger_dag
  

2. 程序化触发 #

你可以通过Airflow的REST API或者Python客户端实现代码层面的触发：

• REST API示例（curl）：

  curl -X POST "http://<你的Airflow服务地址>/api/v1/dags/on_demand_manual_trigger_dag/dagRuns" \
       -H "Content-Type: application/json" \
       -d '{"conf": {"key": "value"}}'  # 可传入自定义参数
  

• Python客户端示例：

  from airflow.api.client.local_client import Client
  
  client = Client(None, None)
  # 触发DAG，可传入配置参数
  client.trigger_dag(dag_id="on_demand_manual_trigger_dag", conf={"custom_param": "test"})
  

常见误区澄清 #

你提到“似乎每个工作流都必须绑定调度”，大概率是因为很多示例模板默认带有调度配置，但实际上schedule_interval=None是Airflow官方支持的标准配置，专门用于这类按需执行的场景。另外要注意：

• 不要混淆schedule_interval=None和@once：@once会在DAG创建完成后自动执行一次，而None则完全不会自动运行，只有触发时才会执行。
• 务必设置catchup=False：即使你指定了start_date，也不会自动补跑历史周期的任务。

内容的提问来源于stack exchange，提问作者Viacheslav V Kovalevskyi