时间戳未过期的普罗米修斯客户端自定义指标

Question

我在下面编写了自定义收集器，它从其余的 api 中提取数据并添加页面视图指标。每个有效载荷有 5 个指标，所以我向它添加了时间戳。它成功地将它发布到 http 侦听器，但指标永不过期。如何为这些指标添加到期时间？

#!/usr/bin/env python3

import argparse
import re
import sys
import time
import datetime
import urllib3
import requests
import aniso8601
import pytz
import json

from prometheus_client import start_http_server
from prometheus_client.core import GaugeMetricFamily, REGISTRY

class HttpCollector(object):
    def __init__(self):
        self.url = "my_endpoint"
        self.username = 'my_userid'
        self.password = 'my_pass'
        self.labels = ['app_name', 'url_host' ]
        self.page_views_metrics = GaugeMetricFamily('pageviews', 'Page Views', labels=self.labels)

    def collect(self):
        headers = {'Accept': '*/*', }
        auth = (self.username, self.password)
        urllib3.disable_warnings()
        result = requests.get(self.url, headers=headers, auth=auth, timeout=60, verify=False)
        if not result.ok:
            # Log error
            print("No results")
            return
        json_result = result.json()
        for record in json_result['records']:
            timestamp_epoch = covert_date_to_epoch(record["timestamp'])
            label_values = ["testapp", "testhost"]
            self.page_views_metrics.add_metric(label_values, record["page_views"], timestamp=timestamp_epoch)
        yield self.page_views_metrics

Answer 1

将 self.page_views_metrics 作为局部变量收集方法解决了这个问题。

import re
import sys
import time
import datetime
import urllib3
import requests
import aniso8601
import pytz
import json

from prometheus_client import start_http_server
from prometheus_client.core import GaugeMetricFamily, REGISTRY

class HttpCollector(object):
    def __init__(self):
        self.url = "my_endpoint"
        self.username = 'my_userid'
        self.password = 'my_pass'
        self.labels = ['app_name', 'url_host' ]

    def collect(self):
        headers = {'Accept': '*/*', }
        auth = (self.username, self.password)
        urllib3.disable_warnings()
        result = requests.get(self.url, headers=headers, auth=auth, timeout=60, verify=False)
        if not result.ok:
            # Log error
            print("No results")
            return
        json_result = result.json()
        page_views_metrics = GaugeMetricFamily('pageviews', 'Page Views', labels=self.labels)
        for record in json_result['records']:
            timestamp_epoch = covert_date_to_epoch(record["timestamp'])
            label_values = ["testapp", "testhost"]
            page_views_metrics.add_metric(label_values, record["page_views"], timestamp=timestamp_epoch)
        yield page_views_metrics

时间戳未过期的普罗米修斯客户端自定义指标

prometheus client custom metrics with timestamp not expiring

python

client

prometheus