工具准备：

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

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)