時間制限とトリガーを伴うApacheエアフロースケジューリング

Question

セロリーエグゼキュータで気流を使用しています。今、DAG内のBranchOperatorを使用してブランチを選択することを決定するタスクのユーザー対話を開発する予定です。連続ループを実行してデータベース内の値をチェックすることによって動作します。しかし、私はそれが良いアプローチ方法ではないと感じています。これを行うための選択肢はありますか？

そして、私はこの交流を最大限に待っています。そうでなければ私は止めたいと思います。気流でこれを行うことは可能ですか？可能な場合は、この時間範囲を動的に変更する可能性はありますか？

ありがとうございます。

Answer 1

このためにBranchOperatorを使用しないでください。 dbの値に基づいてdagを進めたい場合は、Sensorを使用する必要があります。棚のセンサーは気流の中にあるものがあります。また、それらのセンサーのいくつかを見て自分のものを作ることもできます。センサーは基本的に一定の条件と設定可能な時間の後のタイムアウトをポーリングします。あなたの質問から、これはまさにあなたが必要とするものであるようです。