如何手动触发气流损失？

Question

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

[基本上，我已经准备好脚本并准备好执行任务，但是任务不会定期运行。相反，它需要在随机时间激活。 （外部各方会告诉我们现在是时候了，我们将运行它。在接下来的几个月中，这可能会发生很多次。）

反正有手动触发dag吗？也欢迎任何其他方向/建议。谢谢。

Answer 1

您在这里有很多选择：

• UI：在主DAG或特定DAG上单击“触发DAG”按钮。
• CLI：运行airflow trigger_dag <dag_id>，请参阅https://airflow.apache.org/docs/stable/cli.html#trigger_dag]中的文档>
• 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中的文档。
• Operator
：使用TriggerDagRunOperator，请参阅https://airflow.apache.org/docs/stable/_api/airflow/operators/dagrun_operator/index.html#airflow.operators.dagrun_operator.TriggerDagRunOperator中的文档和https://github.com/apache/airflow/blob/1.10.6/airflow/example_dags/example_trigger_controller_dag.py中的示例。

如果这确实是100％手动的，那么您可能会使用UI或CLI。如果您希望让外部用户自己间接触发它，则可以选择API或操作员。请记住在DAG上设置schedule_interval=None。

Answer 2

气流具有API。您需要的方法是POST /api/experimental/dags/<DAG_ID>/dag_runs。使用此方法，您还可以为dag运行传递配置参数。