千分尺/普罗米修斯：如何测量处理持续时间？

Question

我想测量处理某些数据需要多长时间：我的应用程序以固定速率从给定源读取该数据。在每个圆圈之前，我存储即时。now（）。我读取数据，将单个时间戳添加到每个条目中。数据被存储，转换，就在我通过WebSockets发送它之前，我想测量现在（）和初始时间戳之间的持续时间。

我试过了

long millis = Duration.between(dataEntry.getReceivedTimestamp(), Instant.now()).toMillis();
LOG.info(millis + "ms");
registry.timer("processingDuration").record(millis, TimeUnit.MILLISECONDS);

但是可视化这一点只允许我使用＜code＞processingDuration_seconds_count、＜code>_max和＜code>_ sumcount和sum随时间增加（当然，max在大多数时间是恒定的。那么，我如何看待负载的较高和较低平台？我尝试了＜code＞irate（processingDuration_seconds_sum[10m]）仅使用两个数据点，我仍然无法轻松识别长时间的高负载。另外：图中的值约为0.6，而记录的ms约为5-10，因此我在这里丢失了实际值。

所以我试着用< code >量表来代替——它应该允许增加和减少值:

registry.gauge("processingDurationGauge", millis);

我原以为它会在记录的ms范围内上下波动，但它一直是92。

如何测量数据的整个时间？

Answer 1

问题是，长时间不是线程安全的，看到这个答案。按照记录的操作按预期工作：

private final AtomicLong processingDuration;

// ...

// in constructor:
processingDuration = meterRegistry.gauge("processingDuration", new AtomicLong(0L));

// ...

// before finishing the data entries' handling:
long millis = Duration.between(dataEntry.getReceivedTimestamp(), Instant.now()).toMillis();
LOG.info(millis + "ms");
processingDuration.set(millis);

Answer 2

使用计时器和< code >记录是正确的解决方案。

long millis = Duration.between(dataEntry.getReceivedTimestamp(), Instant.now()).toMillis();
LOG.info(millis + "ms");
registry.timer("processingDuration").record(millis, TimeUnit.MILLISECONDS);

假设您每30秒进行一次刮片，您可以使用＜code＞_sum

increase(processingDuration_seconds_sum[1m])/increase(processingDuration_seconds_count[1m])

如果你想比较当前的持续时间与过去一天的平均时间的表现：

((increase(processingDuration_seconds_sum[1m])/
increase(processingDuration_seconds_count[1m]))*1.50) >
increase(processingDuration_seconds_sum[24h])/
increase(processingDuration_seconds_count[24h])

这只会返回1m平均值超过每日平均值1.5倍的值。（我还没有测试那个查询，但它应该明白了）。