2017-12-28 6 views
0

ストームトポロジを継続的に実行したくないユースケースがあります。代わりに、指定された時間に処理されるべき入力(10K +)のセットがあり、Spoutはこれらの入力を継続的に放出し、トポロジ内の残りのボルトによって処理されます。すべての入力が処理されると、私の吐き気の中でnextTupleから放出するものはありません。スパウトからのストームトポロジの殺し

この時点で、トポロジがスリープ状態になり、毎日午前12:00にプロセスを再開したかったのです。

1日に1回トポロジを実行し、処理が完了して指定された時刻にスリープするように設定するプロパティはありますか?

答えて

0

私はあなたが求めているような機能を認識していません。 Stormはバッチ処理システムではなく、継続的に稼働することを意図しています。 Stormがこのユースケースに適しているかどうかを検討してください。

しかし、あなたが望むものを実装できるはずです。あなたは吐き気の入力の最後に "私は完了しました"というメッセージを入力することができます。スパウトがそのメッセージにヒットし、その他の保留中のメッセージがすべて拒否されると、Nimbusクライアントを使用してトポロジを停止または非アクティブにできます(キルまたは非アクティブにするかどうかによって異なります)。https://stackoverflow.com/a/37134473/8845188を参照してください。最後のステップでは、お気に入りのスケジューリングソフトウェアを使用して、毎日深夜0時にトポロジを再サブミット/再アクティブ化します。

関連する問題