企业微信公众号告警Python脚本

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import time
import requests
import json
import os
import traceback
import logging
class WeChat:
def __init__(self):
self.CORPID = 'ww750dfdfde43613c3'
#企业ID，在管理后台获取
self.CORPSECRET = 'rCRzAXI-r7KUZ6uL5HZYYLaqQw2volmnhQrdStu6Qrk'#自建应用的Secret，每个自建应用里都有单独的secret
self.AGENTID = '1000011'
#应用ID，在后台应用中获取
self.TOUSER = "g1702543|g1702076|g1701677"
# 接收者用户名,多个用户用|分割
def _get_access_token(self):
url = 'https://qyapi.weixin.qq.com/cgi-bin/gettoken'
values = {'corpid': self.CORPID,
'corpsecret': self.CORPSECRET,
}
req = requests.post(url, params=values,proxies={'https':'https://10.191.131.20:3128'})
##这次外网访问是通过代理访问的,所以需要proxies指向代理地址
data = json.loads(req.text)
return data["access_token"]
def get_access_token(self):
try:
with open('access_token.conf', 'r') as f:
t, access_token = f.read().split()
except:
with open('access_token.conf', 'w') as f:
access_token = self._get_access_token()
cur_time = time.time()
f.write('t'.join([str(cur_time), access_token]))
return access_token
else:
cur_time = time.time()
if 0 < cur_time - float(t) < 7260:
return access_token
else:
with open('access_token.conf', 'w') as f:
access_token = self._get_access_token()
f.write('t'.join([str(cur_time), access_token]))
return access_token
def send_data(self, message):
send_url = 'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=' + self.get_access_token()
send_values = {
"touser": self.TOUSER,
"msgtype": "text",
"agentid": self.AGENTID,
"text": {
"content": message
},
"safe": "0"
}
logging.basicConfig(filename='log.txt', level=logging.DEBUG,format='%(asctime)s - %(levelname)s - %(message)s')
try:
send_msges=(bytes(json.dumps(send_values)))
#respone = requests.post(send_url, send_msges)
respone = requests.post(send_url, send_msges,proxies={'https':'https://10.191.131.20:3128'})
#respone = requests.post(send_url, send_msges,proxies={'https':'https://10.146.3.177:3128'})
respone = respone.json()
#当返回的数据是json串的时候直接用.json即可将respone转换成字典
return respone["errmsg"]
except:
logging.debug(traceback.format_exc())
if __name__ == '__main__':
wx = WeChat()
msg="""服务器10.134.167.126 EVMI JOBS计划任务异常告警提示如下：
TaskName名称
上次执行失败时间
"""
file= open('reulst_text.txt','r')
while True:
##循环读取文件内容
line= file.read()
msg += line.strip()+'n'
##读取每一行的内容之后，换行在换行读取
if not line:
break
##遇到读取空行的时候，结束读取文件
wx.send_data(msg)

 

异常现象:此处使用了一个代理访问外网,之前此脚本无法通过计划任务发送出去,手动执行可以发送,原因是本地访问外网是通过代理访问的,解决方法是程序需要指向代理访问外网,一直导致请求失败,出现如下异常日志输出:
requests.exceptions.ConnectionError: HTTPSConnectionPool(host='qyapi.weixin.qq.com', port=443): Max retries exceeded with url: /cgi-bin/message/send?access_token=9Uyg6rhaThMhcG0r256-KbrJqXr3j8M25kGXafcx7_GPJPMc8Q2fKd9hB4swwICuNTjt-z-fr4xMs0BJE4xTLsfK6JpGxjQegVHM11JgUNRrozVe6SwEcZVNywGHicYmjDzZpotA3Ksvn4Vx9S6F61RP1eQcBoA8vFyhIHxD5iThuJcPTzFzZd34HT37AGdcwtmQYGlg3q73WSQYgoHARg (Caused by NewConnectionError('<urllib3.connection.VerifiedHTTPSConnection object at 0x7fd808dcc850>: Failed to establish a new connection: [Errno 111] Connection refused',))