我使用streamparse已经有一段时间了，但我只停留在一个主题上。我们使用 storm-0.10.0 以及 streamparse==2.1.4 . 我们让所有的默认值( no auto_anchor = False 或者类似的）。
我们没有在spout中实现ack或fail方法，也没有在bolts中调用任何ack或fail方法。
在bolt方面，进程延迟和执行延迟看起来是正确的。进程延迟是>>执行延迟。
我关心的是 spout Complete Latency 我们可以在storm ui中找到。总是在0点。我了解到，complete latency是消息在拓扑中花费的总时间。因此，它是一个非常好的kpi，因为它可以帮助检测大量的工作人员、任务甚至节点。
在一个bolt中，我做了一个self.log（tup），我有一个tuple.id，它有这样的输出：
name:engine-bolt tuple（id=u'2213630928741732943'，
组件=u'请求喷口-1'，
流=u'默认'，
任务=24，
值=等
...
那么，我如何才能得到一些关于喷口的“完全延迟”的值呢？
如果您还需要什么，请问：）