我现在使用 streamparse 有一段时间了，但我被困在一个主题上。我们使用storm-0.10.0和streamparse==2.1.4。我们让所有的默认值（no auto_anchor = False或类似的东西）。
我们没有在 spout 中实现 ack 或 fail 方法，也没有在 bolts 中调用任何 ack 或 fail 方法。
在螺栓方面，进程延迟和执行延迟看起来是正确的。进程延迟是>>执行延迟。
我担心的是spout Complete Latency我们可以在storm UI 中找到的。它总是在 0.00 。我读到完整的延迟是消息在拓扑中花费的总时间。因此，这是一个非常好的 KPI，因为它可以帮助检测大量工作人员、任务甚至节点。
在一个螺栓中，我做了一个 self.log(tup) 并且我确实有一个带有这种输出的 tuple.id ：
name:engine-bolt Tuple(id=u'2213630928741732943',
component=u'request-spout-1',
stream=u'default',
task=24,
values= etc
...
那么我怎样才能获得一些关于 spouts 的“完全延迟”的值呢？
如果您还需要什么，请询问:)