apache萨摩亚分析拓扑

y4ekin9u  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(332)

是否有任何示例、教程、博客、书籍、视频等可以向我展示如何使用apachesamoa创建拓扑的内容?
我对使用samoa进行storm非常感兴趣,我想构建一个拓扑,其中拓扑的一部分执行一些聚类(或关联规则),但我找不到任何一个示例来实现这一点。有人能解释一下怎么做吗?有可能吗?

hsvhsicv

hsvhsicv1#

为了在samoa上使用storm,您应该首先安装和配置storm。
storm拓扑有几个工作节点,分别是nimbus、zookeeper和supervisor。这些worker可能驻留在不同的机器上,因此,首先,我建议您使用wirbelsturm,它可以帮助您轻松地为拓扑设置虚拟机。
我的安装步骤是;

- Vagrant 1.7.2+
- Virtualbox 4.3.x
- Parallel
- Storm 0.9.3 (release and code-base)
- Wirbelsturm

!! Versions were very important for me because I could not succeed with latest ones.

在萨摩亚你应该编译和打包风暴,


# Build Storm

$ cd storm
$ mvn clean install -DskipTests=true

# Build the storm-starter example

$ cd examples/storm-starter
$ mvn compile exec:java -Dstorm.topology=storm.starter.WordCountTopology
$ mvn package

最后,不要忘记更改配置文件;

- Vagrantfile
- wirbelsturm.yaml
- hosts

在萨摩亚岛上跑步时;

$ bin/samoa storm target/SAMOA-Storm-0.4.0-incubating-SNAPSHOT.jar "PrequentialEvaluation -d /tmp/dump.csv -i 1000000 -f 100000 -l (org.apache.samoa.learners.classifiers.trees.VerticalHoeffdingTree -p 4) -s (org.apache.samoa.moa.streams.generators.RandomTreeGenerator -c 2 -o 10 -u 10)"

如果您的安装和配置正确,您应该在storm ui上看到您的拓扑:http://localhost:28080/
获取更多详细信息;
用Apache风暴处决萨摩亚
运行多节点storm群集
wirbelsturm#工作原理
wirbelsturm一键部署带有流浪 puppet 的风暴Kafka集群
我希望这有帮助。

相关问题