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变量作用域

《一文全面详解Python变量作用域》变量作用域是Python中非常重要的概念,它决定了在哪里可以访问变量,下面我将用通俗易懂的方式,结合代码示例和图表,带你全面了解Python变量作用域,需要的朋友... 目录一、什么是变量作用域?二、python的四种作用域作用域查找顺序图示三、各作用域详解1. 局部作

Python主动抛出异常的各种用法和场景分析

《Python主动抛出异常的各种用法和场景分析》在Python中,我们不仅可以捕获和处理异常,还可以主动抛出异常,也就是以类的方式自定义错误的类型和提示信息,这在编程中非常有用,下面我将详细解释主动抛... 目录一、为什么要主动抛出异常?二、基本语法:raise关键字基本示例三、raise的多种用法1. 抛

Python基于微信OCR引擎实现高效图片文字识别

《Python基于微信OCR引擎实现高效图片文字识别》这篇文章主要为大家详细介绍了一款基于微信OCR引擎的图片文字识别桌面应用开发全过程,可以实现从图片拖拽识别到文字提取,感兴趣的小伙伴可以跟随小编一... 目录一、项目概述1.1 开发背景1.2 技术选型1.3 核心优势二、功能详解2.1 核心功能模块2.

使用SpringBoot整合Sharding Sphere实现数据脱敏的示例

《使用SpringBoot整合ShardingSphere实现数据脱敏的示例》ApacheShardingSphere数据脱敏模块,通过SQL拦截与改写实现敏感信息加密存储,解决手动处理繁琐及系统改... 目录痛点一:痛点二:脱敏配置Quick Start——Spring 显示配置:1.引入依赖2.创建脱敏

基于Python实现一个简单的题库与在线考试系统

《基于Python实现一个简单的题库与在线考试系统》在当今信息化教育时代,在线学习与考试系统已成为教育技术领域的重要组成部分,本文就来介绍一下如何使用Python和PyQt5框架开发一个名为白泽题库系... 目录概述功能特点界面展示系统架构设计类结构图Excel题库填写格式模板题库题目填写格式表核心数据结构

Python使用smtplib库开发一个邮件自动发送工具

《Python使用smtplib库开发一个邮件自动发送工具》在现代软件开发中,自动化邮件发送是一个非常实用的功能,无论是系统通知、营销邮件、还是日常工作报告,Python的smtplib库都能帮助我们... 目录代码实现与知识点解析1. 导入必要的库2. 配置邮件服务器参数3. 创建邮件发送类4. 实现邮件

基于Python构建一个高效词汇表

《基于Python构建一个高效词汇表》在自然语言处理(NLP)领域,构建高效的词汇表是文本预处理的关键步骤,本文将解析一个使用Python实现的n-gram词频统计工具,感兴趣的可以了解下... 目录一、项目背景与目标1.1 技术需求1.2 核心技术栈二、核心代码解析2.1 数据处理函数2.2 数据处理流程

SpringBoot整合Apache Flink的详细指南

《SpringBoot整合ApacheFlink的详细指南》这篇文章主要为大家详细介绍了SpringBoot整合ApacheFlink的详细过程,涵盖环境准备,依赖配置,代码实现及运行步骤,感兴趣的... 目录1. 背景与目标2. 环境准备2.1 开发工具2.2 技术版本3. 创建 Spring Boot

Python远程控制MySQL的完整指南

《Python远程控制MySQL的完整指南》MySQL是最流行的关系型数据库之一,Python通过多种方式可以与MySQL进行交互,下面小编就为大家详细介绍一下Python操作MySQL的常用方法和最... 目录1. 准备工作2. 连接mysql数据库使用mysql-connector使用PyMySQL3.

使用Python实现base64字符串与图片互转的详细步骤

《使用Python实现base64字符串与图片互转的详细步骤》要将一个Base64编码的字符串转换为图片文件并保存下来,可以使用Python的base64模块来实现,这一过程包括解码Base64字符串... 目录1. 图片编码为 Base64 字符串2. Base64 字符串解码为图片文件3. 示例使用注意