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)中,以便当拓扑提交时,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