Airflow python 客户端

Question

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

例如，我们有一个正在运行的 Flask 服务器，我们想要启动一些由 Airflow 控制的工作流程。我们怎样才能做到这一点？是否有 API 可以触发，例如:“立即使用参数 x、y、h 运行 DAG”？

Answer 1

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

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

2. 使用 SensorTasks:有一些预定义的传感器可用，您可以使用它们来监听数据源中的特定事件。如果现有的传感器不能满足您的需求， Airflow 应该具有足够的适应性，以便您实现自己的传感器Airflow Sensor