使用测微计查询数据

Question

我们有一个奇特的监控系统，我们的Spring启动服务将指标发布到带有千分尺的流入数据库中。有一个很好的grafana前端，但问题是我们现在正处于这样一个阶段，我们必须在其他服务中获得一些可用的指标来进行推理。整个系统是由我的前任建立的，我目前对它的理解几乎为零。我可以添加和发布新的指标，但我一生都不能从中得到任何东西。

下面是一个简短示例：我们的网关会为摄像机发布到它的每张图像递增计数器。计数器的定义如下所示：

private val imageCounters = mutableMapOf<String, Counter>()
private val imageCounter = { camera: String ->
    imageCounters.getOrPut(camera) {
        registry.counter("gateway.image.counter", "camera", camera)
    }

计数器在代码中递增，如下所示：

imageCounter("placeholder-id").increment()

现在我们正在改进我们的计费，计费服务需要知道某个相机有多少图像通过了网关。所以很自然地，我尝试的第一件事是这样的:

class MonitoringService(val metrics: MeterRegistry) {

    private val log = logger()
    private val imageCounters = mutableMapOf<String, Counter>()
    private val imageCounter = { camera: String ->
        imageCounters.getOrPut(camera) {
            metrics.counter("gateway.image.counter", "camera", camera)
        }
    }

    fun test() {
        val test = imageCounter("16004").count()
        val bugme = true
        log.info("influx test: $test")
    }
}

这有两个问题：首先，它总是返回零，所以显然我做错了。我只是不知道它是什么。其次，即使它会返回一个合理的值，我也看不到按时间限制它的方法（我通常需要当月上传的图像数量）。

我担心的是，虽然我可以找到很多关于如何用千分尺发布数据的文档，但我似乎找不到任何关于如何查询的文档。千分尺是否只设计用于发布监控数据，而不查询它？.getOrPut（） 方法表明它可以同时执行这两项操作，但是由于据我所知，查询数据似乎没有文档，因此这可能是我的误解。

Java有一个invox-db客户端，我接下来将尝试它，但归根结底，我不希望我的应用程序中的多个组件做同样的事情，仅仅因为我不熟悉我继承的工具。

Answer 1

< code>InfluxMeterRegistry是一个< code>StepMeterRegistry，因此从中创建的< code >计数器是一个< code>StepCounter。< code > step counter . increment()递增当前步骤中的计数，但< code>StepCounter.count()将返回上一步骤中的计数。这就是为什么尽管您已经多次调用了< code>increment(),但< code>count()仍为0。您可以在下一步看到它，默认步骤是1分钟，所以您必须等待1分钟才能看到它。

请参阅以下测试以了解其工作原理：https://github.com/izeye/sample-micrometer-spring-boot/blob/influx/src/test/java/com/izeye/sample/InfluxMeterRegistryTests.java