Tag: apache storm

可视化stream速非常高的数据

我正在使用Twitter Storm进行stream式高速/大数据的实时分析。 现在我不知道如何有效地在浏览器上可视化数据。 我的意思是Storm正在处理的速度真的非常快，风暴正在集群上工作。 我刚刚遇到了Node.js和D3.js的组合来解决这个显示问题。 由于我不是从UI或JavaScript世界，所以只是想知道我是否正确的方向？ 有人能简单地解释一下这个组合能给我带来什么吗？

如何使用Apache Storm JavaScript模块实现一个示例螺栓？

Apache Storm有一个JavaScript模块/库 ，但我不记得看到使用它的任何示例。 看着图书馆，我不知道如何实现一个示例BasicBolt发出的东西。 我们有一个自定义的风暴拓扑结构和pipe理器，所以我正在集成并运行一个node.js的螺栓。 我可以使用storm-node模块运行一个（ https://www.npmjs.com/package/storm-node => https://github.com/STRML/storm-node，https：// github .com / Lazyshot / storm-node ）。 但是如果可能的话，我宁愿使用准系统主Apache Storm库。 我得到了如下所示。 能够将消息logging到风暴中，但不能将数据发送到拓扑中的下一个螺栓以消耗。 我想我没有正确调用emit（）函数。 随着风暴节点，发射我想要的东西就容易多了。 任何想法我做错了或失踪？ var ExampleBolt = require("./storm.js").BasicBolt; ExampleBolt.prototype.process = function(tuple, done) { this.log("loggedamessage"); var data = JSON.stringify(tuple.values); //originally tried something like this… //this.emit([data]); this.emit({'tuple':data,'anchorTupleId':tuple.values},function taskIdHandler(taskId){ return; }); done(); }; var bolt = new ExampleBolt(); bolt.run(); […]