如何使用python查询Prometheus监控数据

pip3 install prometheus-api-client

import json
from datetime import datetime, timedelta
from prometheus_api_client import PrometheusConnect
import requests
        
#query中填写Prometheus的查询语句       
QUERY = ''
PROMETHEUS_URL = "http://127.0.0.1:9090"
        
def get_prometheus_data(query):
    # 设置时间范围（最近 30 分钟）
    end_time = datetime.utcnow()
    start_time = end_time - timedelta(minutes=30)

    prom = PrometheusConnect(PROMETHEUS_URL, disable_ssl=True)
    # 获取时间序列数据
    result = prom.custom_query_range(
        query=query,
        start_time=start_time,
        end_time=end_time,
        step="1m"
    )
    
    #打印获取到的监控数据
    print(result)
    
    latest_by_mountpoint = {}
    
    #解析返回的监控数据
    for series in result:
        metric = series.get("metric", {})
        mountpoint = metric.get("mountpoint", "unknown")
        values = series.get("values", [])
        if not values:
            continue
        # 找出时间最新的一条数据
        # x = [timestamp, value]
        latest_point = max(values, key=lambda x: float(x[0]))  

        latest_by_mountpoint[mountpoint] = {
            "timestamp": datetime.utcfromtimestamp(float(latest_point[0])),
            "usage_percent": float(latest_point[1]),
            "instance": metric.get("instance", "unknown")
        }
        
        # todo 告警解析后结合自身业务逻辑进行后续处理......

#手动安装低于2.0版本的numpy
pip install "numpy<2.0"
#安装指定版本的numpy
pip install numpy==1.26.4
#安装完成后，可以验证已安装的版本
python3 -c "import numpy; print(numpy.__version__)"