java - 普罗米修斯抓取指标后如何重置指标状态?

标签 java spark-streaming prometheus

我是 Prometheus 新手,目前正在将 Spark Streaming 指标集成到 Prometheus。我正在 Spark Streaming 中收集有关 Batch Completed 事件的不同指标,并希望将这些指标存储到 Prometheus。请注意,在每个批处理完成的事件中,我都有一个需要抓取到普罗米修斯的指标。我知道普罗米修斯遵循拉模型。我还看到它有推送导出器,它只推送最新的指标值,但在我的情况下,因为它基于已完成的事件,所以它可以是指标列表,所以我不能遵循这种方法。我应该如何设计这样的系统?

我正在考虑将我的指标存储在缓冲区中并公开一个普罗米修斯服务器将监听的休息调用(当普罗米修斯已经消耗它时我将重置我的指标)。这是正确的方法吗?或者我们可以做点别的什么?

最佳答案

普罗米修斯推送网关 [ https://github.com/prometheus/pushgateway]可以帮助您做到这一点,您可以创建客户端,这些客户端将在完成后插入作业的指标。您可以在下面的链接中找到不同的实现

https://prometheus.io/docs/instrumenting/pushing/

关于java - 普罗米修斯抓取指标后如何重置指标状态?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59714352/

相关文章:

java - 使用hikari连接池时如何解决 "Socket read timed out"

c# - 如何用伪代码写前置条件

java - Spark - 流数据帧/数据集不支持非基于时间的窗口;

apache-kafka - 使用spark-streaming时如何自己保存多个分区的Kafka偏移量

monitoring - 如何在 Prometheus 查询中 'join' 两个指标?

Java等价于iif函数

java - 如何得到需要的结果,结果是数组列表?

apache-spark - Spark 性能调优 - 执行器数量与核心数量

elasticsearch - 如何将存储在Elasticsearch中的多个微服务Jaeger指标导出到Prometheus

kubernetes - HPA无法从自定义指标API中获取指标