python + jenkins + 微信预警
功能说明：
通过jenkins定时任务执行对多个服务器的磁盘检查，当磁盘容量超出预设值时会自动发信息进行微信预警
工具准备：
jenkins PyCharm 企业微信
包和插件：
SSH Plugin 安装及配置：https://blog.csdn.net/taiyangdao/article/details/70163225
python3 urllib.request json
流程配置：
1、各服务器上安装获取磁盘容量的python脚本
1.1安装python脚本
在/root目录下放入test.py 并赋予可执行权限：
2、jenkins上配置定时任务获取脚本并触发微信预警
2.1 jenkins 配置python环境
配置本地的python路径以及相应的包路径
PATH E:\Users\Administrator\AppData\Local\Programs\Python\Python36
PYTHONPATH C:\Users\Administrator\AppData\Roaming\Python\Python36\site-packages
系统管理—节点管理—master—配置从节点—从节点属性
jenkins上python环境配置
2.2 配置 SSH Plugin
配置相应服务器的ssh hosts 以下为其中示例之一：
2.3配置本地python环境：
path 路径下添加python环境 E:\Users\Administrator\AppData\Local\Programs\Python\Python36
x
2.4配置jenkins 定时任务
CheckDS
设置定时
获取服务磁盘容量
判断预定值发微信预警
企业微信配置：
参考：
获取Secret （从企业应用系统预警获取）
获取企业ID （从企业信息里面获取）
涉及脚本解析：
test.py ( 注释：此脚本用于部署服务上获取当前磁盘容量)
#!/bin/env python
# -*- coding: utf-8 -*-
import os,commands,re
m = '\'' #分离出分号
#awk NR==3 取出第三行 $4读取第四列
n = 'NR==3 {print $4}'
#userNum 为 df -h |awk 'NR==3 {print $4}'
userNum = 'df' + ' ' + r'-h' + '|' + 'awk' + ' ' + m + n + m
#使用python commands.getstatusoutput获取返回值
(status,output) = commands.getstatusoutput(userNum)
#对返回值进行正则处理分离出容量值因为m为列表存储所以进行for循环提取里面容量值
m = re.findall(r'\d+',output)
for i in m:
print "xx.x.xxx.xx主机磁盘使用率为:" + i + "%"
#下面两个注释为output直接获取容量值的情况下执行
p#m = output
#print "xx.x.xxx.xx主机磁盘使用率为:" + m
checkDS.py （注释：此脚本部署于jenkins服务器上用于获取控制台输出上的主机号和磁盘容量并进行判断是否超出预警筏值）
#coding:utf-8
import os,re
#test101为触发微信预警脚本
from test101 import dy
#nextBuildNumber 文件是jenkins自动生成的job id
file =open(r'D:\Program Files (x86)\Jenkins\jobs\CheckDS\nextBuildNumber','r+')
#读取job id
test = file.readlines()
for i in test:
num = (int(i)-1)
#获取当前job id的控制台输出日志
test =r"D:/Program Files (x86)/Jenkins/jobs/CheckDS/builds" +r"/" +str(num) +r"/log"
file =open(test,'r+')
#读取文件里面的展示容量部分并存入getlist列表中
getlist = []
for f in file.readlines():
if re.match('\d+',f):
getlist.append(f)
print(f)
file.close()
getlist1 = []
# 获取容量值进行判断当大于98调用dy函数触发微信预警
#i.split('%')[0].split(':')[1] 正则分离容量值
#正则分离ip ((i.split('%')[0])[:11])
for i in getlist:
if int((i.split('%')[0].split(':')[1])) >98:
dy(((i.split('%')[0])[:11]))
test101.py （注释：又dy()函数触发，发出微信预警 获取企业微信token以及发送预警部分为参考网上模板，函数调用部分为作者新增）
import urllib.request
import json
#--------------------------------
# 获取企业微信token
#--------------------------------
def get_token(url, corpid, corpsecret):
token_url ='%s/cgi-bin/gettoken?corpid=%s&corpsecret=%s' % (url, corpid, corpsecret)
token = json.loads(urllib.request.urlopen(token_url).read().decode())['access_token']
return token
#--------------------------------
# 构建告警信息json
#--------------------------------
def messages(msg):
values = {
"touser":'@all',
"msgtype":'text',
"agentid":1000002,
"text": {'content': msg},
"safe":0
}
msges=(bytes(json.dumps(values), 'utf-8'))
return msges
#--------------------------------
# 发送告警信息
#--------------------------------
def send_message(url,token, data):
send_url ='%s/cgi-bin/message/send?access_token=%s' % (url,token)
respone=urllib.request.urlopen(urllib.request.Request(url=send_url, data=data)).read()
x = json.loads(respone.decode())['errcode']
# print(x)
if x ==0:
print ('Succesfully')
else:
print ('Failed')
url ='https://qyapi.weixin.qq.com'
msg='服务器磁盘空间已满请及时清理'
#函数调用
def dy(testm):
test_token=get_token(url, 'xxxxx', 'xxxxxx')
msg_data= messages(testm+msg)
send_message(url,test_token, msg_data)
预警效果：
jenkins任务执行控制台显示
企业微信预警
企业微信预警
