Storm 实践记录

Posted fubinhnust

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Storm 实践记录相关的知识,希望对你有一定的参考价值。

概念

Storm 各个组成部分结构

技术图片

 

各个组件的作用:

主节点:nimbus 分配任务和系统资源

从节点:Supervisor 执行任务的节点

worker:多线程的进程,worker中每个线程叫做一个Executor

Executor:物理上的线程

Task:任务,类型:Spout(采集数据),Bolt(处理数据)

 

各个组件个数对应关系:

  • 搭建Nimbus高可用(HA),需要两个Nimbus主节点。
  • 一个从节点Supervisor上可以有多个Worker进程
  • 一个Worker进程可以有多个Executor线程
  • 一个Executor线程中可运行多个Task任务
  • Task任务可以是Spout或者Bolt

注意:

nimbus是通过zookeeper这个中间节点来分配任务给supervisor的。supervisor会去zk上取任务。

 

以上是关于Storm 实践记录的主要内容,如果未能解决你的问题,请参考以下文章

使用 Storm IEventLogger 将事件记录到 DB

zookeeper安装以及遇到的一些坑

Storm Trident:如何使用 IPartitionedTridentSpout?

storm问题记录 python 不断向kafka中写消息,spout做为消费者从kafka中读消息并emit给bolt,但是部分消息没有得到bolt的处理

Apache Storm 简单实践

Apache Storm 简单实践