Storm命令詳解
在Linux終端直接輸入storm,不帶任何引數資訊,或者輸入storm help,可以檢視storm命令列客戶端(Command line client)提供的幫助資訊。Storm 0.9.0.1版本在Linux終端直接輸入storm後的輸出內容如下:
注:由此可知,新版Storm的命令列客戶端提供了19個命令。Commands: activate classpath deactivate dev-zookeeper drpc help jar kill list localconfvalue logviewer nimbus rebalance remoteconfvalue repl shell supervisor ui version Help: help help <command> Documentation for the storm client can be found at https://github.com/nathanmarz/storm/wiki/Command-line-client Configs can be overridden using one or more -c flags, e.g. "storm list -c nimbus.host=nimbus.mycompany.com"
1.activate
啟用指定的拓撲。語法如下:
storm activate topology-name
2.classpath
打印出Storm客戶端執行命令時使用的類路徑(classpath)。語法如下:
storm classpath
3.deactivate
禁用指定的拓撲Spout。語法如下:
storm deactivate topology-name
4.dev-zookeeper
以dev.zookeeper.path配置的值作為本地目錄,以storm.zookeeper.port配置的值作為埠,啟動一個新的Zookeeper服務,僅用來開發/測試。語法如下:
storm dev-zookeeper
5.drpc (常用!)
啟動一個DRPC守護程序。語法如下:
storm drpc
注:該命令應該使用daemontools或者monit工具監控執行。
6.help (常用!)
列印一條幫助訊息或者可用命令的列表。語法如下:
storm help
storm help <command>
注:直接輸入不帶引數的storm,也可以啟動storm help命令。
7.jar (很常用!)
執行類的指定引數的main方法。語法如下:
storm jar topology-jar-path class ...
注:把Storm的jar檔案和"~/.storm"的配置放到類路徑(classpath)中,以便當拓撲提交時,StormSUbmitter會上傳topology-jar-path的jar檔案。8.kill (常用!)
殺死名為topology-name的拓撲。語法如下:
storm kill topology-name [-w wait-time-secs]
注:storm首先會在拓撲的訊息超時時間期間禁用spout,以允許所有正在處理的訊息完成。然後,Storm將會關閉Worker並清理他們的狀態。可以使用-w標記覆蓋Storm在禁用與關閉期間等待的時間長度。
9.list (常用!)
列出正在執行的拓撲及其狀態。語法如下:
storm list
10.localconfvalue
打印出本地Storm配置的conf-name的值。語法如下:
storm localconfvalue conf-name
注:本地Storm配置是~/.storm/storm.yaml與defaults.yaml合併的結果。
11.logviewer (常用!)
啟動Logviewer守護程序。語法如下:
storm logviewer
注:Logviewer提供一個Web介面檢視Storm日誌檔案。該命令應該使用daemontools或者monit工具監控執行。
12.nimbus (常用!)
啟動Nimbus守護程序。語法如下:
storm nimbus
注:該命令應該使用daemontools或者monit工具監控執行。
13.rebalance (常用!)
再平衡即動態設定拓撲的程序數量和執行緒數量等。詳細內容見:這裡
14.remoteconfvalue
打印出遠端叢集Storm配置的conf-name的值。語法如下:
storm remoteconfvalue conf-name
注:叢集Storm配置是$STORM-PATH/conf/storm.yaml與defaults.yaml合併的結果。該命令必須在叢集節點上執行。
15.repl
開啟一個包含路徑(classpath)中的jar檔案和配置的Clojure REPL,以便除錯時使用。語法如下:
storm repl
注:Clojure可以作為一種指令碼語言內嵌到java中,但是Clojure的首選程式設計方式是使用REPL,REPL是一個簡單的命令列介面。使用REPL,可以輸入命令並執行,然後檢視結果。
16.shell
執行Shell指令碼。語法如下:
storm shell resourcesdir command args
17.supervisor (常用!)
啟動Supervisor守護程序。語法如下:
storm supervisor
注:該命令應該使用daemontools或者monit工具監控執行。
18.ui (常用!)
啟動UI守護程序。語法如下:
storm ui
注:UI為Storm叢集提供了一個Web介面並顯示執行拓撲的詳細統計資訊。該命令應該使用daemontools或者monit工具監控執行。
19.version
列印Storm釋出的版本號。語法如下:
storm version
附:文章引用自《從零開始學Storm》