Storm入門之附錄A

2021-09-23 16:15:07 字數 1447 閱讀 7578

storm客戶端能讓我們使用命令管理集群中的拓撲。按照以下步驟安裝storm客戶端:

把storm目錄加入path環境變數,這樣就不用每次都輸入全路徑執行storm了。如果我們使用了/usr/local/bin/storm,執行export path=$path:

/usr/local/bin/storm。

最後,建立storm本地配置檔案:~/.storm/storm.yaml,在配置檔案中按如下格式加入nimbus主機:

nimbus.host:"我們的nimbus主機"

現在,你可以管理你的storm集群中的拓撲了。

有許多簡單且有用的命令可以用來管理拓撲,它們可以提交、殺死、禁用、再平衡拓撲。

jar命令負責把拓撲提交到集群,並執行它,通過stormsubmitter執行主類。

1storm jar path-to-topology-jar class-with-the-main arg1 arg2 argn

path-to-topology-jar是拓撲jar檔案的全路徑,它包含拓撲**和依賴的庫。 class-with-the-main是包含main方法的類,這個類將由stormsubmitter執行,其餘的引數作為main方法的引數。

我們能夠掛起或停用執行中的拓撲。當停用拓撲時,所有已分發的元組都會得到處理,但是spouts的nexttuple方法不會被呼叫。

停用拓撲:

1storm deactivte topology-name

啟動乙個停用的拓撲:

1storm activate topology-name

銷毀乙個拓撲,可以使用kill命令。它會以一種安全的方式銷毀乙個拓撲,首先停用拓撲,在等待拓撲訊息的時間段內允許拓撲完成當前的資料流。

殺死乙個拓撲:

1stormkilltopology-name

note:執行kill命令時可以通過-w [等待秒數]指定拓撲停用以後的等待時間。

再平衡使你重分配集群任務。這是個很強大的命令。比如,你向乙個執行中的集群增加了節點。再平衡命令將會停用拓撲,然後在相應超時時間之後重分配工人,並重啟拓撲。

再平衡拓撲:

1storm rebalance topology-name

note:執行不帶引數的storm客戶端可以列出所有的storm命令。完整的命令描述請見:
文章** 

併發程式設計網-ifeve.com

Storm入門之第一章

譯者 譯者注 本文翻譯自 getting started with storm 本書中所有storm相關術語都用斜體英文表示。這些術語的字面意義翻譯如下,由於這個工具的名字叫storm,這些術語一律按照氣象名詞解釋 下面的術語跟氣象就沒有關係了 本文是該書的第一章。基礎知識 storm是乙個分布式的...

Storm入門之第一章

storm入門之第一章 spout龍捲,讀取原始資料為bolt提供資料 bolt雷電,從spout或者其他的bolt接收資料,並處理資料,處理結果可作為其他bolt的資料來源或最終結果 nimbus雨雲,主節點的守護程序,負責為工作節點分發任務 topology 拓撲結構,storm的乙個任務單元 ...

Storm入門之第一章

storm入門之第一章 譯者注 本文翻譯自 getting started with storm 本書中所有storm相關術語都用斜體英文表示。這些術語的字面意義翻譯如下,由於這個工具的名字叫storm,這些術語一律按照氣象名詞解釋 下面的術語跟氣象就沒有關係了 本文是該書的第一章。基礎知識 sto...