企业微信在2.8.7版本之后新增群机器人功能，类似于钉钉的机器人，因同事大多都用企业微信交流，于是写个一个简单的提示功能，将异常告知通过群机器人发到群里以便及时得到异常信息。
#!/usr/bin/python
# -*- coding: UTF-8 -*-
'''
批处理监控
'''
from Deploy.utils.dbconn import easydb
from openpyxl import Workbook
import time
from Deploy.utils.sendmail import send
import logging
import sys
import requests
logging.basicConfig(level=logging.DEBUG,#控制台打印的日志级别
filename='/app/data/timed_task.log',
filemode='a',##模式，有w和a，w就是写模式，每次都会重新写日志，覆盖之前的日志
#a是追加模式，默认如果不写的话，就是追加模式
format=
'%(asctime)s - %(pathname)s[line:%(lineno)d] - %(levelname)s: %(message)s'
#日志格式
)
exedate = time.strftime("%Y-%m-%d",time.localtime(time.time() - 24*60*60))
print(exedate)
def query_empdata():
query_sql = []
query_sql.append("select validflag from ldtaskserver where serverip = 'x.x.xx.x';")
exe_sql = ''.join(query_sql)
resultes = easydb.query('lissel_db',exe_sql) #easydb是一个封装的查询数据库的方法
if(resultes[0][0]!="1"):
sendMessage()
else:
print("批处理正常!")
def sendMessage():
headers = {"Content-Type": "text/plain"}
messagetxt="xxx批处理启动异常，请注意查看！"
data = {
"msgtype": "text",
"text": {
"content": messagetxt,
#"mentioned_list":["wangqing","@all"], #wangqing是ID号
"mentioned_mobile_list":["1668960xxxx","@all"] #可以根据根据手机号具体@某人或者@全员
}
}
r = requests.post(
url='https://qyapi./cgi-bin/webhook/send?key=d6520511-8xxxxxxxxxxxxxxx', #换成自己的key
headers=headers, json=data)
print(r.text)
if __name__ == '__main__':
try:
query_empdata()
except Exception as e:
logging.debug(sys.argv[0] + " python exec failed")
logging.debug(e)
