storm命令行

原创
2017/03/27 11:36
阅读数 202

1.activate

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

storm activate topology-name

2.classpath

打印出Storm客户端运行命令时使用的类路径(classpath)。语法如下:

storm classpath

3.deactivate

暂停指定的拓扑Spout。语法如下:

storm deactivate topology-name

4.drpc (常用!)

启动一个DRPC守护进程。语法如下:

storm drpc

注:该命令应该使用daemontools或者monit工具监控运行。

5.help (常用!)

打印一条帮助消息或者可用命令的列表。语法如下:

storm help
storm help <command>

6.jar (很常用!)

运行类的指定参数的main方法。语法如下:

storm jar topology-jar-path class ...

注:把Storm的jar文件和"~/.storm"的配置放到类路径(classpath)中,以便当拓扑提交时,StormSUbmitter会上传topology-jar-path的jar文件。

7.kill (常用!)

杀死名为topology-name的拓扑。语法如下:

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

注:storm首先会在拓扑的消息超时时间期间禁用spout,以允许所有正在处理的消息完成。然后,Storm将会关闭Worker并清理他们的状态。可以使用-w标记覆盖Storm在禁用与关闭期间等待的时间长度。

8.list (常用!)

列出正在运行的拓扑及其状态。语法如下:

storm list

9.localconfvalue

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

storm localconfvalue conf-name

注:本地Storm配置是~/.storm/storm.yaml与defaults.yaml合并的结果。

10.logviewer (常用!)

启动Logviewer守护进程。语法如下:

storm logviewer

注:Logviewer提供一个Web接口查看Storm日志文件。该命令应该使用daemontools或者monit工具监控运行。

11.nimbus (常用!)

启动Nimbus守护进程。语法如下:

storm nimbus

注:该命令应该使用daemontools或者monit工具监控运行。

12.rebalance (常用!)

再平衡即动态设置拓扑的进程数量和线程数量等

# 重新配置拓扑
# "mytopology" 拓扑使用5个Worker进程
# "blue-spout" Spout使用3个Executor
# "yellow-bolt" Bolt使用10个Executor

storm rebalance mytopology -n 5 -e blue-spout=3 -e yellow-bolt=10

注:"mytopology"是拓扑的名称,"blue-spout"和"yellow-bolt"是组件的名称。

14.remoteconfvalue

打印出远程集群Storm配置的conf-name的值。语法如下:

storm remoteconfvalue conf-name

注:集群Storm配置是$STORM-PATH/conf/storm.yaml与defaults.yaml合并的结果。该命令必须在集群节点上运行。

15.supervisor (常用!)

启动Supervisor守护进程。语法如下:

storm supervisor

注:该命令应该使用daemontools或者monit工具监控运行。

16.ui (常用!)

启动UI守护进程。语法如下:

storm ui

注:UI为Storm集群提供了一个Web界面并显示运行拓扑的详细统计信息。该命令应该使用daemontools或者monit工具监控运行。

17.version

打印Storm发布的版本号。语法如下:

storm version

 

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部