Featured image of post Python编写告警信息，整合Alertmanager告警
Python学习

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

告警系统整合流程监控端，可以使用或者进行监控，把相关的数据推送到端进行汇总，发送，后续可以静默，抑制等功能把告警的数据发送到，进行钉钉的发送环境软件告警系统告警系统：主要是数据的各个渠道发送告警处理告。。。。。。。

 Alertmanager告警 系统整合

流程

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

（2）Alertmanager端 进行 汇总，发送，后续可以静默，抑制等功能

（3）把告警的数据发送到prometheusalert，进行钉钉的发送

环境

软件

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

Alertmanager 告警处理：主要汇总数据，抑制，静默

思路

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

步骤

获取Alertmanager数据格式

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

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21

from flask import Flask, request
import json

app = 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配置

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

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

产生prometheus的测试数据

关闭客户端，产生告警 

告警数据

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

{
	'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
}

有用的告警数据

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

{
		'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'
	}

恢复数据

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

{
	'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
}

有用的恢复数据

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

{
		'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发送告警数据

发送告警信息

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

import json
import requests

new_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())

 

 发送恢复告警信息

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

import json
import requests

new_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())

 

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

import json
import requests
import time

year_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())

钉钉告警模板

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

{{ $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)