首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

如何将Storm、Zookeeper和Supervisor节点部署到GCP?

在GCP上部署Storm、Zookeeper和Supervisor节点需要以下步骤:

  1. 创建虚拟机实例:登录到GCP控制台,创建三个虚拟机实例,分别用于部署Storm、Zookeeper和Supervisor节点。选择适当的机型和配置,确保满足应用需求。
  2. 安装和配置操作系统:在每个虚拟机实例上安装适当的操作系统,例如Ubuntu、CentOS等,并进行基本的配置,如网络设置、防火墙规则等。
  3. 安装和配置Zookeeper:在Zookeeper节点上,安装Zookeeper软件包,并进行必要的配置。配置文件包括zoo.cfg,其中包含Zookeeper集群的配置信息,如节点IP地址、端口等。确保Zookeeper集群中的所有节点都能够相互通信。
  4. 安装和配置Storm:在Storm节点上,安装Storm软件包,并进行必要的配置。配置文件包括storm.yaml,其中包含Storm集群的配置信息,如Zookeeper的连接信息、Supervisor的数量等。确保Storm集群中的所有节点都能够相互通信。
  5. 安装和配置Supervisor:在Supervisor节点上,安装Supervisor软件包,并进行必要的配置。配置文件包括supervisor.conf,其中包含Supervisor的配置信息,如Storm的连接信息、启动的Worker数量等。确保Supervisor节点能够连接到Storm集群并接收任务。
  6. 启动集群:依次启动Zookeeper节点、Storm节点和Supervisor节点。确保节点之间的通信正常,并且集群状态正常。
  7. 测试和监控:使用适当的测试工具和监控工具,对部署的Storm集群进行测试和监控。确保集群能够正常处理任务,并及时发现和解决任何问题。

腾讯云相关产品和产品介绍链接地址:

  • 虚拟机实例:https://cloud.tencent.com/product/cvm
  • 云服务器操作系统:https://cloud.tencent.com/product/cvm/os
  • Zookeeper:https://cloud.tencent.com/product/ckafka
  • Storm:https://cloud.tencent.com/product/tke
  • 监控工具:https://cloud.tencent.com/product/monitoring
页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

【转】stormzookeeper中的节点的关系

1、箭头3表示SupervisorZookeeper中创建的路径是/storm/supervisor/。新节点加入时会在该路径下创建一个znode节点。...该目录下的znode节点列表代表了目前活跃的Supervisor,这保证了Nimbus能够及时得知当前集群中机器的状态,这是Nimbus可以进行任务分配的基础,也是Storm具有容错性以及扩展性的基础。...因为Worker与Supervisor属于不同的进程,因此Storm采用本地文件的方式来传递心跳。 四、Executor Executor只会利用Zookeeper来记录自己的运行错误信息。...五、心跳维持 由上可知,Nimbus、SupervisorWorker两两之间都要维持心跳信息,它们的心跳信息如下: 1、NimbusSupervisor之间通过/storm/supervisor/...2、WorkerNimbus之间通过/storm/workerbeats//node-port路径中的数据进行心跳维持。

97020

Apache Storm使用

Storm 集群组件 Storm 集群中包含两类节点:主控节点(Master Node)工作节点(Work Node)。...每一个工作进程执行一个Topology的子集;一个运行中的Topology由分布在不同工作节点上的多个工作进程组成 Nimbus Supervisor 节点之间所有的协调工作是通过 Zookeeper...此外,Nimbus Supervisor 进程都是快速失败(fail-fast)无状态(stateless)的;Storm 集群所有的状态要么在 Zookeeper 集群中,要么存储在本地磁盘上。...经测试,Storm UI必须Storm Nimbus 部署在同一台机器上,否则UI无法正常工作,因为UI进程会检查本机是否存在Nimbus链接。...为了方便使用,可以将bin/storm加入系统环境变量中。 至此,Storm集群已经部署、配置完毕,可以向集群提交拓扑运行了。

35110

Storm入门(二):架构模型集群部署

本篇文章我们来讲一讲 Storm 的集群: Storm 的特点 Storm 的架构组件 如何安装 Storm 集群 如何提交作业 Storm 集群 Storm 的特点 分布式:这个没什么好说的,对于大数据来说...supervisor,注意不是直接分配,而是将任务发布zookeeper上,由supervisorzookeeper上领取任务(在Zookeeper相应的znode节点上写入任务分配信息,由supervisor...节点挂掉,由Nimbus将该节点上正在运行着的任务重新分配给其他supervisor执行 Supervisor节点Zookeeper上获取Nimbus分配的任务,负责启动停止本机上worker...,一般是这样配置的) 从架构图我们可以知道,Storm 的 主节点 Nimbus 节点Supervisor 不会直接进行通讯,而是依赖于 zookeeper 这个组件,这也是Storm的一个设计巧妙之处...,很好的避免了 主从之间依赖而产生的系列问题 安装 Storm 集群 安装什么的比较简单,这里就不再造轮子了, 可以看下这篇 这里有张部署完之后,各个节点本地的目录树图 ?

61320

Storm集群安装详解

Storm集群组件 NimbusSupervisor节点之间所有的协调工作是通过Zookeeper集群来实现的。...此外,NimbusSupervisor进程都是快速失败(fail-fast)无状态(stateless)的;Storm集群所有的状态要么在Zookeeper集群中,要么存储在本地磁盘上。...大多数情况下,单个节点Zookeeper集群足够胜任,不过为了确保故障恢复或者部署大规模Storm集群,可能需要更大规模节点Zookeeper集群(对于Zookeeper集群的话,官方推荐的最小节点数为...: 在Storm各个工作节点上运行”bin/storm supervisor >/dev/null 2>&1 &”启动Supervisor后台程序,并放到后台执行; UI: 在Storm主控节点上运行”...为了方便使用,可以将bin/storm加入系统环境变量中。 至此,Storm集群已经部署、配置完毕,可以向集群提交拓扑运行了。 3.

1.8K10

实时流计算框架——Storm

/usr/local/Cellar/storm/1.2.2: 514 files, 181.7MB, built in 4 minutes 50 seconds Storm结构与部署 (1)Nimbus...集群的主节点,负责任务(task)的指派分发、资源的分配 (2)Supervisor是集群的从节点,负责执行任务的具体部分,启动停止自己管理的Worker进程, (3) Worker运行具体组件的逻辑...>/dev/null 2>&1 & #后台启动dev-zookeeper 方法1 nohup storm dev-zookeeper & #后台启动dev-zookeeper 方法2 启动主节点...nimbus 方法2 启动从节点Supervisor storm supervisor storm supervisor >/dev/null 2>&1 & #后台启动supervisor 方法1...storm storm jar 是命令关键字, topologyDemo.jar是我们的程序打成的jar包,com.baxiang.topologyTest是我们程序的入口主类,topologyDemo

1.7K30

Twitter Storm: 搭建Storm集群

下面是搭建storm集群的一些主要步骤: 搭建ZooKeeper集群。 在Nimbus所有工作机器上面安装所有的软件。 在Nimbus所有工作机器上下载并解压storm的发行版。...所以zookeeper上的负载是非常低的,单个节点zookeeper在大多数情况下都已经足够了, 但是如果你要部署大一点的storm集群, 那么你需要的zookeeper也要大一点。...关于如何部署zookeeper,可以看这里。...关于如何部署zookeeper有些需要注意的地方: 对zookeeper做好监控非常重要, zookeeper是fail-fast的系统,只要出现什么错误就会退出, 所以一定要监控,更多细节看这里。...storm被设计成在任何时候都可以安全退出, 在任何时候都能正确重启, 这就是storm为什么不在线程内存储状态 — 如果NimbusSupervisor重启的话,不会影响正在运行的topology。

50110

storm流式处理框架

Storm部署管理非常简单,而且,在同类的流式计算工具,Storm的性能也是非常出众的。 Storm主要分为两种组件NimbusSupervisor。这两种组件都是快速失败的,没有状态。...ZookeeperStorm重点依赖的外部资源。NimbusSupervisor甚至实际运行的Worker都是把心跳保存在Zookeeper上的。...下图是Storm的数据交互图。可以看出两个模块NimbusSupervisor之间没有直接交互。状态都是保存在Zookeeper上。Worker之间通过ZeroMQ传送数据。 ?...安装完成 storm系统由一个nimbus节点多个supervisor节点组成,上面因为是部署单机版本,所以只启动了一个supervisor。...他们之间是通过zookeeper协调运行的,所以必须依赖zookeeper。nimbus负责分配任务监控任务,本身不做计算,supervisor负责真正的计算任务。

93450

storm集群部署

nimbus supervisor nimbus 与 supervisor 可以部署在同一台机子,但是建议分开,避免相互影响。...supervisor 机子上运行 bin/storm ui >/dev/null 2>&1 & 测试 storm 集群 使用 storm 自带测试例子测试,从 github 下载工程本地: git clone...(zookeeper.java:260) ~[storm-core-1.1.0.jar:1.1.0] ... 4 more 部署storm 服务器版本为 1.1.0,而提交给 storm...例如本例中有两个 supervisor,172.24.132.143 172.24.132.142,但是通过接口请求,每次都只会显示其中的一个,但是现实的机子是交替出现的: curl -X GET...原因是由于部署时通过 linux scp 命令直接分发软件其他机子,残留了 local.dir 的东西,而 storm 是根据 local.dir 中的某一个或一些文件计算出一个 supervisor

1.7K30

大数据技术原理与应用之【流计算】习题

27.Storm集群中的Master节点Work节点各自运行什么后台进程?这些进程又分别负责什么工作?...分配任务监测故障 Worker节点运行名为“Supervisor”的后台程序,负责监听分配给它所在机器的工作,即根据Nimbus分配的任务来决定启动或停止Worker进程,一个Worker节点上同时运行若干个...Worker进程 28.试述ZookeeperStorm框架中的作用 Storm使用Zookeeper来作为分布式协调组件,负责Nimbus多个Supervisor之间的所有协调工作。...借助于Zookeeper,若Nimbus进程或Supervisor进程意外终止,重启时也能读取、恢复之前的状态并继续工作,使得Storm极其稳定。...,分配给相应的Supervisor,并将TaskSupervisor相关的信息提交到Zookeeper集群上 Supervisor会去Zookeeper集群上认领自己的Task,通知自己的Worker

93430

一脸懵逼学习Storm的搭建--(一个开源的分布式实时计算系统)

Storm的官方网址:http://storm.apache.org/index.html 1:集群部署的基本流程(基本套路): 集群部署的流程:下载安装包、解压安装包、修改配置文件、分发安装包...ID             echo 1 > /home/hadoop/zookeeper-3.4.5/tmp/myid         1.3将配置好的zookeeper拷贝其他节点:             ...最大可用内存大小 supervisor.childopts: "-Xmx1024m" #指定supervisor节点上,每个worker启动JVM最大可用内存大小 worker.childopts: "...ui.childopts: "-Xmx768m" #指定supervisor节点上,启动worker时对应的端口号,每个端口对应槽,每个槽位对应一个worker supervisor.slots.ports.../storm supervisor &  注意,解释:   1>/dev/null:代表标准输入这个目录;   2>&1:代表标准输出也这个目录下面;   &:代表这个是后台运行; 如下启动storm

1.3K60

大数据实时处理实战

系统架构 10台服务器组成hadoop集群,其中NameNode节点同时作为采集机安装FTPFlume,选取其他5台服务器安装Kafka,ZookeeperStorm实现大数据实时流处理架构,为了充分利用集群计算资源...Storm分布式实时计算系统,包含Nimbus主节点Supervisor节点(从storm1.0以后,增加了Nimbus备份节点),节点之间需要依靠Zookeeper做状态同步。...Supervisor:是Storm集群的slave节点,负责接受nimbus分配的任务,启动停止属于自己管理的worker进程,是真正意义上的分布式计算节点。 ?...启动主节点服务管理页面) nohup storm nimbus & nohup storm ui & 从节点: nohup storm supervisor & Storm管理页面: 浏览器输入...图六 从图六Cluster Summary中可以看出Storm集群共有4个Supervisor节点,因每台Supervisor提供6个slot(如果在storm.yaml配置文件中不配置supervisor.slots.ports

2.2K100

StormStorm之what

树中的每一个节点代表ZooKeeper中的一个节点(znode),每一个叶子节点Storm真正存储数据的地方。...、被分配到的Supervisor机器主机名的映射关系、每个Executor运行在哪个Worker上以及每个Executor的启动时间。...随后Storm可配多个Nimbus,就不存在单节点问题了。 2. Supervisor 同Nimbus类似,Supervisor也要通过ZooKeeper来创建和获取元数据。...箭头3表示SupervisorZooKeeper中创建的路径是/storm/supervisors/。新节点加人时,会在该路径下创建一个节点。...值得注意的是,该节点是一个临时节点(创建ZooKeeper节点的一种模式),即只要SupervisorZooKeeper的连接稳定存在,该节点就一直存在;一旦连接断开,该节点则会被自动删除。

69931

zookeeper思考与总结1:在其它组件的作用及hdfs对比

的所有的状态信息都是保存在Zookeeper里面,nimbus通过在zookeeper上面写状态信息来分配任务, supervisor,task通过从zookeeper中读状态来领取任务,同时supervisor..., task也会定义发送心跳信息zookeeper, 使得nimbus可以监控整个storm集群的状态,从而可以重启一些挂掉的task。...ls / 对于zookeeperhdfs都是一样的。 查看路径相关信息stat [Bash shell] 纯文本查看 复制代码 ?...很多初学者由于没有认识这个问题,所以会有“部署hbase,不安装zookeeper是否可以,部署storm,不安装zookeeper是否可以”。这样肯定是不可以的。.... backtype.storm.cluster定义了两个重要protocol:ClusterStateStormClusterState。

1.1K50

storm系统架构学习

1、主控节点(Master Node)     运行Storm nimbus后台服务的节点(Nimbus),它是storm系统的中心,负责接收用户提交的作业(如同spark submit一样 即为jar...包形式保存的topology代码),通过Zookeeper向每个工作节点分配处理任务(有进程级的也有线程级别的) 2、工作节点(Work Node)     运行Storm supervisor后台服务的节点...(如果需要实现作业的管理,Storm UI须Storm nimbus部署在同一台机器上,UI进程会检查本机是否存在nimbus的连接,若不存在可导致UI部分功能无法正常工作.) 4、协调节点(Coordinate...Node)     运行Zookeeper进程的节点,numbussupervisor之间所有的协调,包括分布式状态维护分布式配置管理,都是通过该协调节点实现的。...2、主控节点根据系统的全局配置作业中的局部配置,将接受的代码分发至调度的工作节点。 3、工作节点下载来自主控节点的代码包,并根据主控节点的调度生成相关的工作进程线程。

63030
领券