如何手动触发气流 dag？

Question

我已经在 Airflow 上工作了一段时间，调度程序没有问题，但现在我遇到了问题。

基本上，我有一个脚本和 dag 准备好执行任务，但该任务不会定期运行。相反，它需要随机激活。（外部各方会告诉我们时间到了，我们将运行它。在接下来的几个月里，这种情况可能会发生很多次。）

无论如何手动触发dag？也欢迎任何其他方向/建议。谢谢。

Answer 1

您在这里有多种选择：

• UI：单击主 DAG 或特定 DAG 上的“触发 DAG”按钮。
• CLI：运行airflow trigger_dag <dag_id>，参见https://airflow.apache.org/docs/stable/cli.html#trigger_dag 中的文档。请注意，更高版本的气流使用语法airflow dags trigger <dag_id>
• API：调用POST /api/experimental/dags/<dag_id>/dag_runs，参见https://airflow.apache.org/docs/stable/api.html#post--api-experimental-dags--DAG_ID--dag_runs 中的文档。
• 操作员：使用TriggerDagRunOperator，请参阅https://airflow.apache.org/docs/apache-airflow/stable/_api/airflow/operators/trigger_dagrun/index.html#airflow.operators.trigger_dagrun.TriggerDagRunOperator 中的文档和https 中的示例://github.com/apache/airflow/blob/master/airflow/example_dags/example_trigger_controller_dag.py。

如果这真的是 100% 手动，您可能会使用 UI 或 CLI。如果您希望让外部方自己间接触发它，则 API 或 Operator 将是选项。记得schedule_interval=None在 DAG上设置。