Quakus指标-拦截指标endpoint

Question

是否有办法在使用时监听 /metricsendpointhttps://quarkus.io/guides/micrometer?

我想收集一些需要调用不同API的指标。。。而不是制定时间表(https://quarkus.io/guides/scheduler-reference)...

例：

• 我在库伯内特斯API中查询一些自定义资源
• 然后我想用不同的标签更新一些仪表

首先，/metrics为我们提供了：

# HELP test_metric_a  
# TYPE test_metric_a gauge
test_metric_a{namespace="test123",user="admin",} 1.0
test_metric_a{namespace="testabc",user="admin",} 1.0

# HELP test_metric_b  
# TYPE test_metric_b gauge
test_metric_b 0.0

其次，/metrics可能给出：

# HELP test_metric_a  
# TYPE test_metric_a gauge
test_metric_a 0.0

# HELP test_metric_b  
# TYPE test_metric_b gauge
test_metric_b{namespace="testabc",user="admin",} 2.0

如何使用https://quarkus.io/guides/micrometer调用Kubernetes API，因为应用程序中可能没有任何更改导致仪表/注册表更新，但外部事件或时间流逝将导致状态（所需的度量输出）更改。。。

请注意，自定义度量（请参见下面的注释）只被调用一次（我猜它是单例的？）。理想情况下，我希望在每次回答/metrics时调用它。。。

进一步编辑以显示仪表的创建/更新方式：

@ApplicationScoped
public class MyMetrics {

    private final MeterRegistry registry;

    MyMetrics(MeterRegistry registry) {
        this.registry = registry;
    }

    //...

    // somehow call this whenever /metrics is hit?
    protected void updateGauges() {
        // use KubernetesClient to query K8s API to gather some customer resources, then process that list... etc...
        // there is a loop over the below for user/namespace pairs in the tags
        //final Tags tags = getTags();
        //int count = getCount();
        //registry.gauge("test_metric_a", tags, count);

        // so this could roll out to something like:
        registry.gauge("test_metric_a", Tags.of("user", "user1", "namespace", "ns1"), 1);
        registry.gauge("test_metric_a", Tags.of("user", "user2", "namespace", "ns1"), 2);
        registry.gauge("test_metric_a", Tags.of("user", "user1", "namespace", "ns2"), 1);

        registry.gauge("test_metric_b", Tags.of("user", "user1", "namespace", "ns1"), 1);
        registry.gauge("test_metric_b", Tags.of("user", "user2", "namespace", "ns1"), 1);
    }
}

...也许这些仪表可能是计数器。。。但问题仍然是。。。

Answer 1

好啊正如我在评论中所说，当收集指标时（例如普罗米修斯的情况下，当endpoint被刮伤时），会观察到量具的值。

如果您正在谈论添加包含类似名称空间的标记，那么common tags示例可能会为您提供一些信息，您可以预先计算标签：

registry.config().commonTags("stack", "prod", "region", "us-east-1");

这将向所有指标添加这些标签，但您可以使用MeterFilter来更具选择性（例如，仅向匹配某些条件的指标添加标签）。

new MeterFilter() {
    @Override
    public Meter.Id map(Meter.Id id) {
       if(id.getName().startsWith("test")) {
          return id.withName("extra." + id.getName()).withTag("extra.tag", "value");
       }
       return id;
    }
}

https://micrometer.io/docs/concepts#_common_tags

如果试图根据从Kubernetes API检索到的数据更新标记/标签值，则需要运行定期任务（例如计划任务），使用新标记重新注册仪表。

请注意，对于已被垃圾收集的仪表，测微计将忽略或返回NaN（取决于您使用的注册表），因此，如果您希望使用以前的标记值注册的仪表保持不变，则需要使其成为强引用。