Python编写告警信息,整合Alertmanager告警

2023-10-25 14:20

本文主要是介绍Python编写告警信息,整合Alertmanager告警,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

 Alertmanager告警 系统整合

流程

(1)监控端,可以使用Python 或者 shell 进行监控,把 相关的json数据推送到Alertmanager

(2)Alertmanager端 进行 汇总,发送,后续可以静默,抑制等功能

(3)把告警的数据发送到prometheusalert,进行钉钉的发送

环境

软件

prometheusalert 告警系统 :主要是数据的各个渠道发送

Alertmanager 告警处理:主要汇总数据,抑制,静默

思路

编写告警测试数据时,我们可以不用生成时间,仅生成相关的告警指标,时间程序会帮忙生成(待测试)

步骤

获取Alertmanager数据格式

方法,通过flask 编写接口,Alertmanager配置,告警时回把数据发送到此接口 ,进行展示查看

from flask import Flask, request
import jsonapp = Flask(__name__)@app.route("/send/", methods=["POST"])
def send():try:data = json.loads(request.data)print(data)alerts = data['alerts']for i in alerts:print('SEND SMS: ' + str(i))except Exception as e:print(e)return 'ok'if __name__ == '__main__':app.run(host='0.0.0.0', port=8082)

在Alertmanager配置

[root@prometheus-server alertmanager-0.24.0.linux-amd64]# cat alertmanager.yml
global:resolve_timeout: 5m
route:group_by: ['instance']group_wait: 30sgroup_interval: 10srepeat_interval: 10mreceiver: 'web.hook.prometheusalert'
receivers:
- name: 'web.hook.prometheusalert'webhook_configs:- url: http://192.168.96.19:8082/send/

产生prometheus的测试数据

关闭客户端,产生告警 

告警数据

{'receiver': 'web\\.hook\\.prometheusalert','status': 'firing','alerts': [{'status': 'firing','labels': {'alertname': '主机存活状态警告!','cloud': '乘风-Dev环境','instance': '192.168.82.105:9100','job': 'node_exporter','severity': '非常严重','team': 'ops'},'annotations': {'description': '192.168.82.105:9100:服务器延时超过5分钟','summary': '192.168.82.105:9100:服务器宕机'},'startsAt': '2022-07-05T05:54:37.452Z','endsAt': '0001-01-01T00:00:00Z','generatorURL': 'http://prometheus-server.0101101300.fjf:9090/graph?g0.expr=up+%3D%3D+0&g0.tab=1','fingerprint': '4a890f7c225c3bef'}],'groupLabels': {'instance': '192.168.82.105:9100'},'commonLabels': {'alertname': '主机存活状态警告!','cloud': '乘风-Dev环境','instance': '192.168.82.105:9100','job': 'node_exporter','severity': '非常严重','team': 'ops'},'commonAnnotations': {'description': '192.168.82.105:9100:服务器延时超过5分钟','summary': '192.168.82.105:9100:服务器宕机'},'externalURL': 'http://prometheus-server.0101101300.fjf:9093','version': '4','groupKey': '{}:{instance="192.168.82.105:9100"}','truncatedAlerts': 0
}

有用的告警数据

{'status': 'firing','labels': {'alertname': '主机存活状态警告!','cloud': '乘风-Dev环境','instance': '192.168.82.105:9100','job': 'node_exporter','severity': '非常严重','team': 'ops'},'annotations': {'description': '192.168.82.105:9100:服务器延时超过5分钟','summary': '192.168.82.105:9100:服务器宕机'},'startsAt': '2022-07-05T05:54:37.452Z','endsAt': '0001-01-01T00:00:00Z','generatorURL': 'http://prometheus-server.0101101300.fjf:9090/graph?g0.expr=up+%3D%3D+0&g0.tab=1','fingerprint': '4a890f7c225c3bef'}

恢复数据

{'receiver': 'web\\.hook\\.prometheusalert','status': 'resolved','alerts': [{'status': 'resolved','labels': {'alertname': '主机存活状态警告!','cloud': '乘风-Dev环境','instance': '192.168.82.105:9100','job': 'node_exporter','severity': '非常严重','team': 'ops'},'annotations': {'description': '192.168.82.105:9100:服务器延时超过5分钟','summary': '192.168.82.105:9100:服务器宕机'},'startsAt': '2022-07-05T05:54:37.452Z','endsAt': '2022-07-05T05:56:52.452Z','generatorURL': 'http://prometheus-server.0101101300.fjf:9090/graph?g0.expr=up+%3D%3D+0&g0.tab=1','fingerprint': '4a890f7c225c3bef'}],'groupLabels': {'instance': '192.168.82.105:9100'},'commonLabels': {'alertname': '主机存活状态警告!','cloud': '乘风-Dev环境','instance': '192.168.82.105:9100','job': 'node_exporter','severity': '非常严重','team': 'ops'},'commonAnnotations': {'description': '192.168.82.105:9100:服务器延时超过5分钟','summary': '192.168.82.105:9100:服务器宕机'},'externalURL': 'http://prometheus-server.0101101300.fjf:9093','version': '4','groupKey': '{}:{instance="192.168.82.105:9100"}','truncatedAlerts': 0
}

有用的恢复数据

{'status': 'resolved','labels': {'alertname': '主机存活状态警告!','cloud': '乘风-Dev环境','instance': '192.168.82.105:9100','job': 'node_exporter','severity': '非常严重','team': 'ops'},'annotations': {'description': '192.168.82.105:9100:服务器延时超过5分钟','summary': '192.168.82.105:9100:服务器宕机'},'startsAt': '2022-07-05T05:54:37.452Z','endsAt': '2022-07-05T05:56:52.452Z','generatorURL': 'http://prometheus-server.0101101300.fjf:9090/graph?g0.expr=up+%3D%3D+0&g0.tab=1','fingerprint': '4a890f7c225c3bef'}

Python发送告警数据

发送告警信息

import json
import requestsnew_packinf = [{'status': 'firing','labels': {'alertname': '主机存活状态警告!','cloud': '乘风小贷-Dev环境','instance': '192.168.82.105:9100','job': 'node_exporter','severity': '非常严重','team': 'ops'},'annotations': {'description': '192.168.82.105:9100:服务器延时超过5分钟','summary': '192.168.82.105:9100:服务器宕机'},'startsAt': '2022-07-05T05:54:37.452Z','endsAt': '0001-01-01T00:00:00Z','generatorURL': 'http://prometheus-server.0101101300.fjf:9090/graph?g0.expr=up+%3D%3D+0&g0.tab=1','fingerprint': '4a890f7c225c3bef'}]
jsons = json.dumps(new_packinf)
url = "http://192.168.82.105:9093/api/v2/alerts"
headers = {'Content-Type': 'application/json'}
responses = requests.post(url=url, headers=headers, data=jsons)
print(responses.status_code, responses.url)
# print(responses.json())

 

 发送恢复告警信息

import json
import requestsnew_packinf = [{'status': 'resolved','labels': {'alertname': '主机存活状态警告!','cloud': '乘风-Dev环境','instance': '192.168.82.105:9100','job': 'node_exporter','severity': '非常严重','team': 'ops'},'annotations': {'description': '192.168.82.105:9100:服务器延时超过5分钟','summary': '192.168.82.105:9100:服务器宕机'},'startsAt': '2022-07-05T05:54:37.452Z','endsAt': '2022-07-05T05:56:52.452Z','generatorURL': 'http://prometheus-server.0101101300.fjf:9090/graph?g0.expr=up+%3D%3D+0&g0.tab=1','fingerprint': '4a890f7c225c3bef'}]
jsons = json.dumps(new_packinf)
url = "http://192.168.82.105:9093/api/v2/alerts"
headers = {'Content-Type': 'application/json'}
responses = requests.post(url=url, headers=headers, data=jsons)
print(responses.status_code, responses.url)
# print(responses.json())

 

import json
import requests
import timeyear_time = time.strftime('%Y-%m-%d', time.localtime())
now_time = time.strftime('%H:%M:%S', time.localtime())
start_time = year_time + "T" + now_time + ".000+08:00"
is_end_time = False
if is_end_time:print("告警未解决")end_time = '0001-01-01T00:00:00Z'
else:print("告警已经解决")end_time = start_time
new_packinf = [{'labels': {'alertname': '主机存活状态警告!','cloud': '小贷-Dev环境','instance': '192.168.82.105:9100','job': 'node_exporter','severity': '非常严重','team': 'ops'},'annotations': {'description': '192.168.82.105:9100:服务器延时超过5分钟','summary': '192.168.82.105:9100:服务器宕机'},'endsAt': end_time,
}]
jsons = json.dumps(new_packinf)
url = "http://192.168.82.105:9093/api/v2/alerts"
headers = {'Content-Type': 'application/json'}
responses = requests.post(url=url, headers=headers, data=jsons)
print(responses.status_code, responses.url)
# print(responses.json())

钉钉告警模板

{{ $var := .externalURL}}{{ range $k,$v:=.alerts }}
{{if eq $v.status "resolved"}}
#### [Prometheus恢复信息]({{$v.generatorURL}})##### <font color="#02b340">告警名称</font>:[{{$v.labels.alertname}}]({{$var}})
##### <font color="#02b340">告警级别</font>:{{$v.labels.severity}}
##### <font color="#02b340">开始时间</font>:{{TimeFormat $v.startsAt "2006-01-02 15:04:05"}}
##### <font color="#02b340">结束时间</font>:{{TimeFormat $v.endsAt "2006-01-02 15:04:05"}} 
##### <font color="#02b340">实例地址</font>:{{$v.labels.instance}}
##### <font color="#02b340">主机名称</font>:{{$v.labels.hostname}}**{{$v.annotations.description}}**
{{else}}
#### [Prometheus告警信息]({{$v.generatorURL}})##### <font color="#FF0000">告警名称</font>:[{{$v.labels.alertname}}]({{$var}})
##### <font color="#FF0000">告警级别</font>:{{$v.labels.severity}}
##### <font color="#FF0000">开始时间</font>:{{ TimeFormat $v.startsAt "2006-01-02 15:04:05"}}
##### <font color="#FF0000">结束时间</font>:{{TimeFormat $v.endsAt "2006-01-02 15:04:05"}} 
##### <font color="#FF0000">实例地址</font>:{{$v.labels.instance}}
##### <font color="#FF0000">主机名称</font>:{{$v.labels.hostname}}**{{$v.annotations.description}}**
{{end}}
{{ end }}
{{ $urimsg:=""}}{{ range $key,$value:=.commonLabels }}{{$urimsg =  print $urimsg $key "%3D%22" $value "%22%2C" }}{{end}}[*** 点我屏蔽该告警]({{$var}}/#/silences/new?filter=%7B{{SplitString $urimsg 0 -3}}%7D)

这篇关于Python编写告警信息,整合Alertmanager告警的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/283154

相关文章

Python将博客内容html导出为Markdown格式

《Python将博客内容html导出为Markdown格式》Python将博客内容html导出为Markdown格式,通过博客url地址抓取文章,分析并提取出文章标题和内容,将内容构建成html,再转... 目录一、为什么要搞?二、准备如何搞?三、说搞咱就搞!抓取文章提取内容构建html转存markdown

Python获取中国节假日数据记录入JSON文件

《Python获取中国节假日数据记录入JSON文件》项目系统内置的日历应用为了提升用户体验,特别设置了在调休日期显示“休”的UI图标功能,那么问题是这些调休数据从哪里来呢?我尝试一种更为智能的方法:P... 目录节假日数据获取存入jsON文件节假日数据读取封装完整代码项目系统内置的日历应用为了提升用户体验,

Python FastAPI+Celery+RabbitMQ实现分布式图片水印处理系统

《PythonFastAPI+Celery+RabbitMQ实现分布式图片水印处理系统》这篇文章主要为大家详细介绍了PythonFastAPI如何结合Celery以及RabbitMQ实现简单的分布式... 实现思路FastAPI 服务器Celery 任务队列RabbitMQ 作为消息代理定时任务处理完整

Python Websockets库的使用指南

《PythonWebsockets库的使用指南》pythonwebsockets库是一个用于创建WebSocket服务器和客户端的Python库,它提供了一种简单的方式来实现实时通信,支持异步和同步... 目录一、WebSocket 简介二、python 的 websockets 库安装三、完整代码示例1.

揭秘Python Socket网络编程的7种硬核用法

《揭秘PythonSocket网络编程的7种硬核用法》Socket不仅能做聊天室,还能干一大堆硬核操作,这篇文章就带大家看看Python网络编程的7种超实用玩法,感兴趣的小伙伴可以跟随小编一起... 目录1.端口扫描器:探测开放端口2.简易 HTTP 服务器:10 秒搭个网页3.局域网游戏:多人联机对战4.

使用Python实现快速搭建本地HTTP服务器

《使用Python实现快速搭建本地HTTP服务器》:本文主要介绍如何使用Python快速搭建本地HTTP服务器,轻松实现一键HTTP文件共享,同时结合二维码技术,让访问更简单,感兴趣的小伙伴可以了... 目录1. 概述2. 快速搭建 HTTP 文件共享服务2.1 核心思路2.2 代码实现2.3 代码解读3.

Python使用自带的base64库进行base64编码和解码

《Python使用自带的base64库进行base64编码和解码》在Python中,处理数据的编码和解码是数据传输和存储中非常普遍的需求,其中,Base64是一种常用的编码方案,本文我将详细介绍如何使... 目录引言使用python的base64库进行编码和解码编码函数解码函数Base64编码的应用场景注意

Python基于wxPython和FFmpeg开发一个视频标签工具

《Python基于wxPython和FFmpeg开发一个视频标签工具》在当今数字媒体时代,视频内容的管理和标记变得越来越重要,无论是研究人员需要对实验视频进行时间点标记,还是个人用户希望对家庭视频进行... 目录引言1. 应用概述2. 技术栈分析2.1 核心库和模块2.2 wxpython作为GUI选择的优

Python如何使用__slots__实现节省内存和性能优化

《Python如何使用__slots__实现节省内存和性能优化》你有想过,一个小小的__slots__能让你的Python类内存消耗直接减半吗,没错,今天咱们要聊的就是这个让人眼前一亮的技巧,感兴趣的... 目录背景:内存吃得满满的类__slots__:你的内存管理小助手举个大概的例子:看看效果如何?1.

Python+PyQt5实现多屏幕协同播放功能

《Python+PyQt5实现多屏幕协同播放功能》在现代会议展示、数字广告、展览展示等场景中,多屏幕协同播放已成为刚需,下面我们就来看看如何利用Python和PyQt5开发一套功能强大的跨屏播控系统吧... 目录一、项目概述:突破传统播放限制二、核心技术解析2.1 多屏管理机制2.2 播放引擎设计2.3 专