用python实现实时监控web系统运行是否正常

对于web系统和服务器的监控，现在有太多的运维工具可以直接拿来用，这很方便运维人员开展工作，也能及时通知运维人员对异常的服务进行抢修。

其实还有很多运维小白对复杂的监控系统搞不明白，甚至于部署一套系统也比较吃力，这里我们出于学习的目的，用python实现一个小巧的web系统的实时监控。

话不多说，直接开干。

需求场景：对给出指定的一些web地址，每隔一段时间访问一次，以保证它可以正常访问，如果出现异常不能访问，则通知指定的人员

第一步，我们准备好需要监控的web地址，需要通知的人员名单，文件名取 projectURl.conf，说明一下，这些web地址最好是能有返回的接口。

我们把这些信息放在一个列表里，projectURl.conf的内容如下：

[

{

"projectName":"福建省xxx管理平台",

"projectURL":"http://xx.xx.xx.xx/open/Title",

"projectUser":"sterson|lilei|lbhuan|wjbing"

},

{

"projectName":"甘肃省xxx公共服务平台",

"projectURL":"http://xx.xx.xx.xx/open/tTitle",

"projectUser":"sterson|lilei|lbhuan|wjbing"

},

{

"projectName":"黔南州xxx网站",

"projectURL":"http://xxx.xx.xxx.xx:9098",

"projectUser":"sterson|lilei|lbhuan|wjbing"

}

]

第二步，我们写一个监控方法，这个方法实现也比较简单，就是从上面的文件中读取数据，

然后通过requests模块发请求，通过返回的状态码判断是否正常。

# 读取配置文件，并向URL发起请求

def read_project(conf_path):

f = open(conf_path, "r")

test_config = eval(f.read())

f.close()

is_ok = True

for i in test_config:

message = "项目名称：" + i["projectName"] + "\n监控时间：" + str(time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())) + "\n访问地址：" + i["projectURL"]

try:

result = requests.get(i["projectURL"],timeout=5)

message = message + "\n监控结果：" + str(result.status_code) + "\n"

if result.status_code != 200:

is_ok = False

except:

is_ok = False

if is_ok == False:

send_webchat(message, i["projectUser"]) #以企业微信

#send_mail(message) #发邮件

#control_log(message) #记录日志

如果状态码不是200，我们可以做些处理，比如发企业微信，发邮件，记录日志等等。

看具体情况需要去实现，这里以发企业微信为例。

# 向企业微信发消息

def send_webchat(message, test_person):

crop_id = 'xxxxxxxxxx'

crop_secret = 'xxxxxxxxxx'

tonken_url = 'https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=' + \

crop_id + '&corpsecret=' + crop_secret

token = requests.get(tonken_url)

access_token = json.loads(token.text)

send_url = 'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=' + \

access_token["access_token"]

send_values = {

"touser": test_person,

"msgtype": "text",

"agentid": 1000008,

"text": {"content": message}

}

send_value = json.dumps(send_values)

headers = {"content-type": "application/json"}

r = requests.post(send_url, send_value, headers=headers)

然后再写一个启动方法，该方法有个睡眠时间，用来控制每隔一段时间启动一次。

def start(project_url, s):

while True:

read_project(project_url)

time.sleep(s)

start("/th_control/projectURL.conf",600)

crop_id和crop_secret需要改成自己的企业微信，把以上保存到xxx.py里，就可以执行了。

以上只是一种粗糙简单的思路，当然现在好多企业已实现了自动化监控运维平台。