runtime - 嵐のクラスターのボルトからの結果をブラウザーに表示する

Question

ストーム プロセスのボルト内のプロセスから派生した結果を、実行時に Web ブラウザーまたは UI に表示することはできますか? それはどのように行われますか？

Answer 1

何を探しているのかわかりませんが、ボルト出力をファイルに書き込むことは非常に可能です。ファイルで渡されたものをすべて白くする作業ボルトが必要なだけです。ストリームをファイルに書き込むロジックは、ボルトのexecute(Tuple tuple)メソッド内にある必要があります。それはあなたが求めているものですか？

アップデート

ボルトと Websocket の間にキュー (Kafka/Krestel) を配置するのはどうですか。私はこの記事を見つけ ました

Storm とフロントエンドを (WebSockets を介して) 簡単に統合するために、私は Apache Camel を選択して面倒な作業を行いました。Storm トポロジーのボルトが出力を ActiveMQ キューに書き込むようにすることで、次のように、このキューをサブスクライブし、メッセージを WebSocket にプッシュする Camel ルートを作成できます。

    public class StreamingRoute extends RouteBuilder {
        @Override
        public void configure() throws Exception {
              from("activemq:storm.queue")
                .to("websocket://storm?sendToAll=true");
       }
   }

間の統合について話しているこの記事も見つかりましたJMS and Websockets