在Storm中用螺栓链固定的正确方法

Question

我只是想确定一下我知道Storm中的工作原理。我有一个喷口和两个螺栓链在一起。Spout向Bolt1发射元组，Bolt1又向Bolt2发射元组。我想要bolt2来处理从Spout发送的初始元组，但我不确定如何处理。

为了保证容错性（即：元组是重新生成的），我想在bolt2中ack由Spout发出的元组，以防它在进程中某个地方失败，这样它就可以重新生成。

 _collector.emit(new Values(queue.dequeue())

def execute(tuple: Tuple) {
 _collector.emit(tuple, new Values("stuff"))
}

def execute(tuple2: Tuple) {
 _collector.emit(tuple2, new Values("foo"))
}

此时，tuple2中的元组是从Bolt1发送的元组（其中包含字符串“stuff”的元组）。
因此，如果我在Bolt2中发送ack，这将ack来自Bolt1的元组，而不是从spout发送的元组。正确？

我怎样才能确认从喷口发送的元组？我是不是应该把最初的喷口放在所有其他喷口上，这样我就可以在最后一个插销里找回来，然后把它收起来？

我读了Nathan的教程，我得到的印象是，我可以在发出tuple2之后立即在Bolt1（从Spout）中接收到的元组。这将把新发出的tuple2链接到Spout发送的原始元组，因此当Bolt2对tuple2进行编译时，它实际上对来自Spout的原始元组进行编译。这是真的吗？

如果我在解释中遗漏了什么，请告诉我。

Answer 1

对于那些感兴趣的人，我已经找到了一个解决方案，通过询问暴风小组。我需要的是在Spout中以以下方式发出元组（具有唯一的ID）：

喷口：

 //ties in tuple to this UID
 _collector.emit(new Values(queue.dequeue(), *uniqueID*) 

那么Bolt1将只在它将元组发送到Bolt2之后对元组进行ack

 //emit first then ack
 _collector.emit(tuple, new Values("stuff")) //**anchoring** - read below to see what it means
 _collector.ack(tuple) 

 _collector.ack(tuple) 

希望这有帮助。