5. storm常用命令(客户端storm shell)

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>

1. activate

激活指定的拓扑
Spout。语法如下:

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)中,以便当拓扑提交时,
dbd0
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
语法如下:

storm rebalance topology-name [-w wait-time-secs]

有时你可能希望扩散一些正在运行的拓扑的
Worker。例如,假设你有一个
10
个节点的集 群,每个节点运行 4
个 Worker,然后假设需要添加另外
10
个节点到集群中。你可能希望有 Spout
扩散正在运行中的拓扑的 Worker,这样每个节点运行两个
Worker。解决的一种方法是 杀死拓扑并重新提交拓扑,但
Storm
提供了一个 rebalance
的命令,我们可以用一种更简单的 方法来做到这一点。

rebalance
首先会在消息超时时间内禁用拓扑,使用-w
可以覆盖超时时间,然后重新均衡 分配集群的
Worker,拓扑会返回到它原来的状态,即禁用的拓扑仍将禁用,激活的拓扑继续 激活。

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