2013-10-22 183 views

回答

2

不知道你在找什麼,但是很有可能把任何螺栓輸出寫入文件。您只需要一個工作螺栓,它可以清除文件中傳遞給它的任何內容。你的寫入流文件的邏輯應該在螺栓的方法execute(Tuple tuple)中。 這就是你正在尋找的?

UPDATE

如何把一個隊列(卡夫卡/ Krestel)在您的螺栓和WebSockets的之間。我發現這篇文章here它說

爲了便於風暴和前端(通過 的WebSockets)之間的集成我選擇了Apache的駱駝做繁重的我。通過在風暴拓撲螺栓 寫自己的輸出到 ActiveMQ的隊列,我可以創建支持這一 隊列中的駱駝航線,推動消息的WebSockets,像這樣:

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

而且發現this文章談論集成JMS and Websockets

+0

我實際上試圖運行一個風暴過程,掃描一個文件並在運行時將這些過程的結果發送到Web瀏覽器。任何想法?我正在使用Web套接字來實現在瀏覽器上獲取數據,而無需發送任何請求。我猜想關於該文件的部分是誤導性的。將刪除它。儘管感謝您的回答。 – rudd0211

+0

你是否設法做到這一點?如果你可以更新帖子! – change

相關問題