【python】Python中采集Prometheus数据，进行数据分析和可视化展示

✨✨ 欢迎大家来到景天科技苑✨✨

🎈🎈 养成好习惯，先赞后看哦~🎈🎈

🏆 作者简介：景天科技苑
🏆《头衔》：大厂架构师，华为云开发者社区专家博主，阿里云开发者社区专家博主，CSDN全栈领域优质创作者，掘金优秀博主，51CTO博客专家等。
🏆《博客》：Python全栈，PyQt5和Tkinter桌面开发，小程序开发，人工智能，js逆向，App逆向，网络系统安全，数据分析，Django，fastapi，flask等框架，云原生K8S，linux，shell脚本等实操经验，网站搭建，数据库等分享。

所属的专栏：python综合应用，基础语法到高阶实战教学
景天的主页：景天科技苑

文章目录

Python中采集Prometheus数据的详细用法教程

引言

Prometheus是一个开源的监控和警报工具，专门用于记录和查询时间序列数据。它提供了一个强大的查询语言PromQL（Prometheus Query Language），允许用户根据不同的标签和指标选择特定的时间序列数据。在Python中，我们可以通过Prometheus的HTTP API来采集这些数据，并进行进一步的处理和分析。本文将详细介绍如何在Python中采集Prometheus数据，并通过实际案例展示其用法。

安装必要的库

首先，我们需要安装Python中与Prometheus交互的库。常见的库有

prometheus_client

和

prometheus-api-client

。这里我们选择使用

prometheus-api-client

，因为它提供了一个更简洁的接口来与Prometheus服务器进行交互。

pip install prometheus-api-client

连接到Prometheus服务器

在Python中，我们首先需要创建一个与Prometheus服务器的连接。这通常涉及到设置Prometheus服务器的URL和端口。以下是一个示例代码，展示了如何创建这样的连接：

from prometheus_api_client import PrometheusConnect

# 连接到Prometheus服务器
prom = PrometheusConnect(url="http://localhost:9090", disable_ssl=True)

注意，如果Prometheus服务器启用了SSL，则不需要设置

disable_ssl=True

。

使用PromQL查询数据

通过Prometheus的HTTP API，我们可以使用PromQL来查询数据。PromQL是一种功能强大的查询语言，允许我们根据特定的条件选择时间序列数据。

示例1：查询CPU使用率

假设我们想要查询系统的CPU使用率，可以使用以下PromQL查询语句：

100 - (avg by (instance) (irate(node_cpu_seconds_total{mode="idle"}[5m])) * 100)

这个查询语句计算了CPU在过去5分钟内的平均非空闲时间百分比，即CPU使用率。

在Python中，我们可以使用

custom_query

方法来执行这个查询：

# 查询CPU使用率
query ='100 - (avg by (instance) (irate(node_cpu_seconds_total{mode="idle"}[5m])) * 100)'
result = prom.custom_query(query)# 输出查询结果print(result)

查询结果将是一个JSON对象，包含查询到的数据。

示例2：查询特定时间范围内的数据

如果我们需要查询特定时间范围内的数据，可以使用

/api/v1/query_range

端点。以下是一个示例，展示了如何查询从

2023-01-01T00:00:00Z

到

2023-01-02T00:00:00Z

之间，每小时一次的系统CPU使用率：

import requests
import pandas as pd

# 定义查询参数
url ='http://localhost:9090/api/v1/query_range'
query ='100 - (avg by (instance) (irate(node_cpu_seconds_total{mode="idle"}[5m])) * 100)'
start ='2023-01-01T00:00:00Z'
end ='2023-01-02T00:00:00Z'
step ='1h'
params ={'query': query,'start': start,'end': end,'step': step}# 发起请求并获取数据
response = requests.get(url, params=params)
data = response.json()# 处理数据
results = data['data']['result']for result in results:
    df = pd.DataFrame(result['values'], columns=['timestamp','value'])
    df['timestamp']= pd.to_datetime(df['timestamp'], unit='s')
    df.set_index('timestamp', inplace=True)print(df)

在这个示例中，我们使用

pandas

库来处理时间序列数据，并将其转换为更易于分析的格式。

数据处理与分析

获取到Prometheus数据后，我们可以使用Python进行进一步的数据处理和分析。这包括但不限于数据清洗、聚合、可视化等。

数据清洗

在数据清洗阶段，我们可能需要剔除异常值、填充缺失值或转换数据类型等。例如，对于CPU使用率数据，我们可能会去除一些明显偏离正常范围的异常值。

数据聚合

对于时间序列数据，数据聚合是常见的需求，它可以帮助我们更好地理解数据的整体趋势或不同维度下的表现。在Python中，我们可以使用

pandas

库来轻松地进行数据聚合。

假设我们已经从Prometheus获取了多个实例（instance）的CPU使用率数据，并存储在

pandas

的

DataFrame

中。我们可以按照实例（instance）进行分组，并计算每个实例的平均CPU使用率。

import pandas as pd

# 假设df是包含CPU使用率数据的DataFrame，其中'instance'是实例标签，'value'是CPU使用率# 这里我们使用一个模拟的DataFrame作为示例
data ={'timestamp':['2023-01-01T00:00:00Z','2023-01-01T00:00:00Z','2023-01-01T01:00:00Z','2023-01-01T01:00:00Z'],'instance':['instance1','instance2','instance1','instance2'],'value':[75,80,76,82]}
df = pd.DataFrame(data)
df['timestamp']= pd.to_datetime(df['timestamp'], unit='s')
df.set_index('timestamp', inplace=True)# 按照'instance'分组，并计算每个组的平均值
avg_cpu_usage = df.groupby('instance')['value'].mean()print(avg_cpu_usage)

数据可视化

数据可视化是理解数据的有效方式。在Python中，

matplotlib

和

seaborn

是两个流行的可视化库。我们可以使用这些库来绘制CPU使用率的折线图、柱状图等。

折线图

import matplotlib.pyplot as plt

# 假设avg_cpu_usage是上面计算得到的平均CPU使用率
avg_cpu_usage.plot(kind='line', title='Average CPU Usage by Instance')
plt.xlabel('Instance')
plt.ylabel('CPU Usage (%)')
plt.grid(True)
plt.show()

柱状图

avg_cpu_usage.plot(kind='bar', title='Average CPU Usage by Instance')
plt.xlabel('Instance')
plt.ylabel('CPU Usage (%)')
plt.grid(True)
plt.show()

警报与通知

在实际应用中，当监控数据达到预设的阈值时，我们可能需要触发警报并发送通知。虽然Prometheus本身提供了强大的警报功能，但你也可以在Python脚本中根据查询结果实现自定义的警报逻辑。

例如，如果某个实例的CPU使用率持续高于90%，我们可能需要发送一封电子邮件或短信通知管理员。

# 假设max_cpu_usage是从Prometheus查询得到的当前最高CPU使用率
max_cpu_usage =92# 示例值if max_cpu_usage >90:# 发送警报通知（这里只是一个示例，实际中可能需要使用SMTP库发送电子邮件或使用其他通知服务）print("Warning: CPU usage is above 90%!")# 这里可以添加发送电子邮件或短信的代码

深入Prometheus集成与自动化

在前面的部分中，我们讨论了如何在Python中直接查询Prometheus以获取数据，并进行基本的处理和分析。然而，在实际的生产环境中，你可能需要将Prometheus的数据集成到更复杂的监控和自动化流程中。以下是一些进一步集成和自动化的方法。

1. 使用Prometheus Alertmanager

Prometheus的Alertmanager是一个独立的报警处理组件，它负责接收来自Prometheus服务器的警报，执行去重、分组，并路由到正确的接收器（如电子邮件、Slack、PagerDuty等）。虽然Python脚本可以触发自定义警报，但使用Alertmanager可以更方便地管理和配置警报规则。

你可以在Prometheus配置文件中定义警报规则，当这些规则被触发时，它们会发送警报到Alertmanager。Alertmanager根据配置处理这些警报，并发送通知。

2. 集成Grafana

Grafana是一个开源的、功能丰富的数据可视化工具，它支持多种数据源，包括Prometheus。通过将Prometheus作为Grafana的数据源，你可以创建漂亮的仪表板来展示监控数据，并进行深入的分析。

Grafana提供了强大的图表和面板选项，允许你以直观的方式展示数据。此外，Grafana还支持变量、模板和注解等功能，进一步增强了其灵活性和可定制性。

3. 使用Prometheus Webhook Receiver

虽然Alertmanager提供了丰富的通知方式，但如果你需要更复杂的处理逻辑或集成到特定的系统中，你可以使用Prometheus Webhook Receiver。Webhook Receiver是一个监听HTTP POST请求的轻量级服务，当Alertmanager发送警报时，它会触发一个Webhook。

你可以编写Python脚本来监听这些Webhook请求，并根据警报内容执行自定义的逻辑，如更新数据库、发送自定义通知或触发其他自动化任务。

4. 自动化部署与配置

在生产环境中，你可能需要频繁地部署和更新Prometheus及其相关组件（如Alertmanager、Grafana等）。自动化这些过程可以大大提高效率和可靠性。

你可以使用Ansible、Chef、Puppet等配置管理工具来自动化Prometheus及其组件的部署和配置。这些工具允许你定义服务器和服务的状态，并自动将它们应用到目标环境中。

5. 监控Prometheus本身

最后，别忘了监控Prometheus本身。Prometheus是一个关键组件，负责收集和分析其他服务的性能数据。如果Prometheus出现问题，你将失去对这些服务的监控能力。

你可以通过Prometheus自带的指标来监控其自身的健康状况，如查询延迟、内存使用情况、存储效率等。此外，你还可以设置警报来通知你Prometheus的任何潜在问题。

结论

通过本教程，我们详细介绍了如何在Python中采集Prometheus数据，包括连接到Prometheus服务器、使用PromQL查询数据、数据处理与分析以及数据可视化。我们还简单讨论了如何根据查询结果实现自定义的警报逻辑。这些技能对于构建基于Prometheus的监控和警报系统至关重要，可以帮助你更好地理解和响应系统性能的变化。

记住，这只是一个起点。随着你对Prometheus和Python的进一步学习，你将能够开发更复杂、更强大的监控和数据分析解决方案。