作者:Devon_Mars | 来源:互联网 | 2023-09-03 09:04
Storm命令行参数研究????[root@node1~]#stormCommands:???????activate???????classpath???????de
Storm命令行参数研究
??
?
?
[root@node1 ~]# storm
Commands:
??????? activate
??????? classpath
??????? deactivate
??????? dev-zookeeper
??????? drpc
??????? help
??????? jar
??????? kill
??????? list
??????? localconfvalue
??????? logviewer
??????? monitor
??????? nimbus
??????? rebalance
??????? remoteconfvalue
??????? repl
??????? shell
??????? supervisor
??????? ui
??????? version
Help:
??????? help
??????? help
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"
[root@node1 ~]# storm help activate
Syntax: [storm activate topology-name]
??? Activates the specified topology‘s spouts.
-----------------------------------------------------------------------------------------------
?activate??? storm activate topology-name
???????? 激活指定的任务
???? classpath??? storm classpath
???????? 打印storm的classpath
???? deactivate??? storm deactivate topology-name
???????? 暂停storm的任务
???? dev-zookeeper??? storm dev-zookeeper
???????? 启动一个新的Zookeeper,这种情况只用于dev/test
???? drpc??? storm drpc
????????? 启动一个DRPC进程
???? help
???? jar??? storm jar topology-jar-path class
???????? 运行你的storm job,topology是类中的主函数
???? kill??? storm kill topology-name [-w wait-time-secs]
???????? 通过任务名称kill一个任务,storm会先使任务接口无效,使已经存在的消息被处理完成,然后会关闭任务并清除状态,你可以使用-w延迟几秒后关闭任务
???? list??? storm list
???????? 列出正在运行的topolofies和状态
???? localconfvalue??? storm localconfvalue conf-name
???????? 打印出conf-name在本地storm配置文件中的值
???? nimbus??? storm nimbus
???????? 启动一个nimubs进程。
???? rebalance??? storm rebalance topology-name [-w wait-time-secs]
???????? 有时候你想扩展你的任务运行在某些机器上,比如你有10个节点,每个节点运行4个任务,然后又增加了10个节点,你希望每个节点运行2个任务,一种方法是kill掉任务,重新提交,但是storm提供rebalance命令来做这件事。
???? remoteconfvalue??? storm remoteconfvalue conf-name
???????? 打印出conf-name在storm cluster中的值
???? repl??? storm repl
????????? 打开一个clojure repl,对debugging有用
???? shell
???? supervisor??? storm supervisor
???????? 启动一个supervisor进程
???? ui??? storm ui
???????? 启动一个ui进程
???? version
??? logviewer
??? 启动Logviewer守护进程。语法如下:
??? storm logviewer
???Logviewer提供一个Web接口查看Storm日志文件。该命令应该使用daemontools或者monit工具监控运行。