如何获取Jstorm获取元组生命周期时间

Question

我的问题是:我想监控风暴中每个数据的持续时间。我应该怎么做?有没有demo?我只能统计每个螺栓处理的持续时间。

Answer 1

在apache-storm和jstorm中，您都可以获取监视器的数据，并将其导出到您想要的任何位置。

在storm中，使用Metrics Consumer (参见http://storm.apache.org/releases/1.0.6/Metrics.html)。

在jstorm中，使用指标上传器(请参阅http://jstorm.io/Maintenance/JStormMetrics.html)

这里有一个jstorm metricsUploader示例：https://github.com/lcy362/StormTrooper/blob/master/src/main/java/com/trooper/storm/monitor/MetricUploaderTest.java