2016-07-27 10 views
3

私たちはいくつかのアプリケーションを実行しており、気流の使用を開始したいと考えています。ドキュメントからは、DAGを起動する唯一の方法はコマンドライン上にあるようです。これは本当ですか?気流pythonクライアント

たとえば、フラスコサーバーが動作しており、気流によって制御されたワークフローを開始したいとします。どうすればこれを達成できますか?たとえば、トリガーするAPIはありますか:「DAGをパラメータx、y、hで実行する」

答えて

5

気流でこれを実現するには、いくつかの方法があります。それはあなたの状況に左右されます。

  1. トリガーされたDAGを使用してください。バックグラウンドで実行されているPythonジョブは、イベントが発生した場合に実行されるDAGをトリガすることがあります。リポジトリ内example_trigger_controller_dag.pyとexample_trigger_target_dag.pyを見て:GitHub Airflow

  2. 使用SensorTasks:あなたがデータソースf.e.内の特定のイベントをリッスンするために使用できる利用可能ないくつかの事前定義されたセンサーがあります。一度、既存のあなたの必要性を満たさない場合は、空気の流れがあなたのように私はあなたのユースケースを理解Airflow Sensor

0

あなたの質問を読んだ後、独自のセンサーを実装してみましょうするために十分に適応する必要があります:あなたが実行したいこと
/トリガ手動でも

あなたが実験にまだあるHEREを、行くことができますあなたはDAGを/トリガ実行することができ、そこから:(8080 /ローカルホスト) - HTTPサーバからのDAGは

>あなただけの提供エアフローのウェブサーバを使用することができますモードを使用し、提供されたAPIを使用する

質問をよく理解するためにさらに詳しく説明してください。

関連する問題