airflow - 气流python客户端

Question

我们有一些应用程序正在运行，我们想开始使用气流。从文档看来，启动 DAG 的唯一方法是通过命令行。这是真的？

例如，我们有一个烧瓶服务器正在运行，我们想要启动一些由气流控制的工作流。我们怎样才能做到这一点？是否有 API 可以触发，例如：“Run DAG now with parameters x,y,h”？

Answer 1

有几种方法可以通过气流实现这一目标。这取决于您的情况，哪一种或是否适合您。我想到了两个建议：

1. 使用触发的 DAG。在后台运行的 Python 作业可能会触发 DAG，以防事件发生。查看存储库中的 example_trigger_controller_dag.py 和 example_trigger_target_dag.py：GitHub Airflow

2. 使用 SensorTasks：有一些预定义的传感器可用，您可以使用它们来监听数据源 fe 中的特定事件

Answer 2

阅读您的问题后，我将您的用例理解为：
您希望从 HTTP 服务器运行/触发 DAG

--> 您可以使用提供的 Airflow 网络服务器（localhost:8080/），您可以从中手动触发/运行 dag

您也可以去这里，它仍处于实验模式并使用提供的 api

请详细说明以便更好地理解问题。