javascript - 如何使用 Apache Storm javascript 模块实现示例 bolt ？

Question

有一个 javascript module/library for Apache Storm ，但我不记得看到过任何使用它的例子。查看库，我不确定如何实现发出内容的示例 BasicBolt。我们有一个自定义的 Storm 拓扑构建器和管理器，所以我正在集成并运行一个 node.js bolt。我能够使用 storm-node 模块运行一个( https://www.npmjs.com/package/storm-node => https://github.com/STRML/storm-node , https://github.com/Lazyshot/storm-node )。但如果可能的话，我更愿意使用准系统主 Apache Storm 库。我得到的如下所示。能够将消息记录到 Storm 中，但无法将数据发送到拓扑中的下一个 bolt 以供使用。我在想我没有正确调用 emit() 函数。使用 storm-node，发出我想要的东西要容易得多。知道我做错了什么或遗漏了什么吗？

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();

不幸的是，我使用的 Storm 基础设施没有报告任何有用的关于 Node bolt 的运行时错误，以便我找出问题。

Answer 1

https://github.com/apache/storm/blob/master/examples/storm-starter/multilang/resources/splitsentence.js

是用作我们测试的一部分的测试拆分句子 bolt 。它应该为您提供一个良好的起点。