氣流python客戶端

Question

我們有一些應用程序正在運行，我們想要開始使用氣流。從文檔看來，啓動DAG的唯一方法是通過命令行。這是真的？

例如，我們有一個燒瓶服務器正在運行，我們想要啓動一些由氣流控制的工作流程。我們怎樣才能做到這一點？是否有API觸發例如：「現在使用參數x，y，h運行DAG」？

Answer 1

有幾種方法可以通過氣流實現這一點。這取決於你的情況哪一個或者哪個適合你。我想到的兩個建議：

1. 使用觸發的DAG。在後臺運行的Python作業可能觸發DAG在事件發生時執行。看一看在example_trigger_controller_dag.py和example_trigger_target_dag.py在倉庫中：GitHub Airflow

2. 使用SensorTasks：有可用的一些預定義的傳感器，它們可以用來監聽的數據源F.E.特定事件如果現有一旦不能滿足您的需要，氣流應該是足夠的靈活性，讓你實現自己的傳感器Airflow Sensor

Answer 2

閱讀您的問題後，我明白你的用例爲：
那你想運行/觸發DAG從HTTP服務器

- >你可以使用所提供的氣流Web服務器（本地主機：8080 /），從中可以觸發/運行DAG手動

，你也可以去HERE，仍處於實驗模式並使用所提供的api

請詳細說明以便更好地理解問題。