在部署好Storm集羣后,可以使用Storm提供的命令行客户端提供的幫助信息
[root@sc1 ~]# storm
Commands:
activate 激活指定的拓撲
classpath 獲取Storm客户端運行命令時使用的類路徑(classpath)
deactivate 禁用指定的拓撲
dev-zookeeper 以dev.zookeeper.path配置的值作為本地目錄,以storm.zookeeper.port配置的值作為端口,啓動一個新的zookeeper服務,僅用來開發測試。
drpc 啓動一個drpc服務
help 查看storm的命令行幫助,輸入storm時會默認啓動storm help
jar 在storm集羣中運行拓撲
kill 殺死集羣中正在運行的拓撲,storm會先在拓撲的消息超時時間旗艦禁用Spout,以允許所有正在處理的消息完成處理。然後關閉Worker並清理它們的狀態。
list 查看集羣中正在運行的所有拓撲及其狀態
localconfvalue 查看本地storm配置的conf-name的值
logviewer 啓動logviewer守護進程
monitor
nimbus 啓動storm集羣的主控節點的守護進程,該守護進程與Hadoop的JobTracker類似
rebalance 重新平衡集羣中正在運行的Worker。如果需要擴展Worker,當前集羣中有10個節點且每個節點運行4個Worker,然後需要添加另外10個節點到集羣中。這時候希望
Spout能擴散正在運行中的拓撲的Worker,讓每個節點運行2個Worker。解決方法有兩種,一種是殺死拓撲重新提交拓撲,一種是Storm提供的rebalance命令。
rebalance受限會在消息超時時間內禁用拓撲,使用-w可以覆蓋超時時間,然後重新均衡分配集羣的Worker,拓撲會返回到它原來的狀態,即禁用的拓撲仍將禁用
激活的拓撲則繼續運行。
remoteconfvalue 打印出遠程Storm集羣配置的conf-name的值,集羣配置使$STORM_PATH/conf/storm.yaml與defaults.yaml合併的結果且該命令必須在集羣節點上運行。
repl 打開一個包含類路徑(classpath)中的jar文件和配置的Clojure REPL,方便在調試時使用。
shell 執行shell腳本
supervisor 啓動Storm集羣的工作節點的守護進程,該守護進程與Hadoop的TaskTracker類似。
ui 啓動Storm集羣的Web界面並顯示集羣和正在運行拓撲的詳細信息。
version 查看Storm的發行版本號
Help:
help
help <command>
Documentation for the storm client can be found at http://storm.incubator.apache.org/documentation/Command-line-client.html
Configs can be overridden using one or more -c flags, e.g. "storm list -c nimbus.host=nimbus.mycompany.com"
本文章為轉載內容,我們尊重原作者對文章享有的著作權。如有內容錯誤或侵權問題,歡迎原作者聯繫我們進行內容更正或刪除文章。