Storm命令詳解

在Linux終端直接輸入storm,不帶任何參數信息,或者輸入storm help,能夠查看storm命令行客戶端(Command line client)提供的幫助信息。Storm 0.9.0.1版本在Linux終端直接輸入storm後的輸出內容以下:java

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"

注:由此可知,新版Storm的命令行客戶端提供了19個命令。git


 

 

1.activategithub

激活指定的拓撲。語法以下:shell

1 storm activate topology-name

 

2.classpath編程

打印出Storm客戶端運行命令時使用的類路徑(classpath)。語法以下:工具

1 storm classpath

 

3.deactivate測試

禁用指定的拓撲Spout。語法以下:ui

1 storm deactivate topology-name

 

4.dev-zookeeperspa

以dev.zookeeper.path配置的值做爲本地目錄,以storm.zookeeper.port配置的值做爲端口,啓動一個新的Zookeeper服務,僅用來開發/測試。語法以下:.net

1 storm dev-zookeeper

 

5.drpc (經常使用!)

啓動一個DRPC守護進程。語法以下:

1 storm drpc

注:該命令應該使用daemontools或者monit工具監控運行。

 

6.help (經常使用!)

打印一條幫助消息或者可用命令的列表。語法以下:

1 storm help 2 storm help <command>

注:直接輸入不帶參數的storm,也能夠啓動storm help命令。

 

7.jar (很經常使用!)

運行類的指定參數的main方法。語法以下:

1 storm jar topology-jar-path class ...

注:把Storm的jar文件和"~/.storm"的配置放到類路徑(classpath)中,以便當拓撲提交時,StormSUbmitter會上傳topology-jar-path的jar文件。

 

8.kill (經常使用!)

殺死名爲topology-name的拓撲。語法以下:

1 storm kill topology-name [-w wait-time-secs]

注:storm首先會在拓撲的消息超時時間期間禁用spout,以容許全部正在處理的消息完成。而後,Storm將會關閉Worker並清理他們的狀態。能夠使用-w標記覆蓋Storm在禁用與關閉期間等待的時間長度。

 

9.list (經常使用!)

列出正在運行的拓撲及其狀態。語法以下:

1 storm list

 

10.localconfvalue

打印出本地Storm配置的conf-name的值。語法以下:

1 storm localconfvalue conf-name

注:本地Storm配置是~/.storm/storm.yaml與defaults.yaml合併的結果。

 

11.logviewer (經常使用!)

啓動Logviewer守護進程。語法以下:

1 storm logviewer

注:Logviewer提供一個Web接口查看Storm日誌文件。該命令應該使用daemontools或者monit工具監控運行。

 

12.nimbus (經常使用!)

啓動Nimbus守護進程。語法以下:

1 storm nimbus

注:該命令應該使用daemontools或者monit工具監控運行。

 

13.rebalance (經常使用!)

再平衡即動態設置拓撲的進程數量和線程數量等。詳細內容見:這裏

 

14.remoteconfvalue

打印出遠程集羣Storm配置的conf-name的值。語法以下:

1 storm remoteconfvalue conf-name

注:集羣Storm配置是$STORM-PATH/conf/storm.yaml與defaults.yaml合併的結果。該命令必須在集羣節點上運行。

 

15.repl

打開一個包含路徑(classpath)中的jar文件和配置的Clojure REPL,以便調試時使用。語法以下:

1 storm repl

注:Clojure能夠做爲一種腳本語言內嵌到java中,可是Clojure的首選編程方式是使用REPL,REPL是一個簡單的命令行接口。使用REPL,能夠輸入命令並執行,而後查看結果。

 

16.shell

執行Shell腳本。語法以下:

1 storm shell resourcesdir command args

 

17.supervisor (經常使用!)

啓動Supervisor守護進程。語法以下:

1 storm supervisor

注:該命令應該使用daemontools或者monit工具監控運行。

 

18.ui (經常使用!)

啓動UI守護進程。語法以下:

1 storm ui

注:UI爲Storm集羣提供了一個Web界面並顯示運行拓撲的詳細統計信息。該命令應該使用daemontools或者monit工具監控運行。

 

19.version

打印Storm發佈的版本號。語法以下:

1 storm version
相關文章
相關標籤/搜索