我是 Prometheus 新手,目前正在将 Spark Streaming 指标集成到 Prometheus。我正在 Spark Streaming 中收集有关 Batch Completed 事件的不同指标,并希望将这些指标存储到 Prometheus。请注意,在每个批处理完成的事件中,我都有一个需要抓取到普罗米修斯的指标。我知道普罗米修斯遵循拉模型。我还看到它有推送导出器,它只推送最新的指标值,但在我的情况下,因为它基于已完成的事件,所以它可以是指标列表,所以我不能遵循这种方法。我应该如何设计这样的系统?
我正在考虑将我的指标存储在缓冲区中并公开一个普罗米修斯服务器将监听的休息调用(当普罗米修斯已经消耗它时我将重置我的指标)。这是正确的方法吗?或者我们可以做点别的什么?
最佳答案
普罗米修斯推送网关 [ https://github.com/prometheus/pushgateway]可以帮助您做到这一点,您可以创建客户端,这些客户端将在完成后插入作业的指标。您可以在下面的链接中找到不同的实现
关于java - 普罗米修斯抓取指标后如何重置指标状态?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59714352/