python监控服务器应用日志，推送钉钉机器人，实时关注日志异常.pdfVIP

python监监控控服服务务器器应应⽤⽤⽇⽇志志，，推推送送钉钉钉钉机机器器⼈⼈，，实实时时关关注注⽇⽇志志 异异常常 ⽣产环境多台服务器上部署了多 应⽤，⽇志出现报错时，⽆法及时反馈到开发⼈员。部署⼀ ⼤型的运维监控应⽤，不但耗资源，⽽且配 置也不简单。 简简单单写 python脚本来监控服务器⽇志就简单多了，废话不多说，直接上脚本。 主要逻辑： 1. 使⽤python的subprocess模块，执⾏shell命令，“tail -f” 来监听⽇志⽂件 2. 对输出的⽇志⽂件，逐⾏⽐对字符串，如果匹配到预设的字符串则开始记录，keywords中配置需要预设的异常字符串 3. 开始记录⽇志⾄数组中，可通过rows来预设记录多少条，达到规定数量后 4. 将⽇志内容通过http发送给钉钉服务器，钉钉机器⼈就会在群⾥通知我们啦 简单，⾼效，实时 # !/ usr/ bin/ python # encodin =utf-8 # Filename: monitorLo .py import os import si nal import subprocess import time import smtplib from email.mime.text import MIMEText from email.header import Header import requests import json import threadin serverName="prod:0" # ⽇志⽂件路径地址 lo Files =[ "/opt/app/ mall/ mall-admin/ lo s/ mall-admin-0.0.1-SNA PSHOT.lo ", "/opt/app/ mall/ mall-portal/ lo s/ mall-portal-0.0.1-SNA PSHOT.lo " ] ; #机器⼈回调地址 , 钉钉群⾥添加⼀ 机器⼈就可以了 webhook = 'https ://oapi.din / robot/send?access_tokenb92cd3a8ce94732fd785dc753134fc 1c4d69141f56e942a5d453e5b' # ⽇志缓存数据 lo s = [] #记录⽇志⾏数，从匹配⾏开始记录，到达数量就⽤推给钉钉机器⼈ rows = 2 # 是否开始记录⽇志标记位 recordFla s = [] # 检测的关键字数组，⼤⼩写敏感 keywords = [] keywords .append("threw exception") keywords .append("java.lan .NullPointerException") keywords .append("com.macro.mall.exception.ApiRRException") keywords .append("SocketTimeout Exception") #消息内容,url地址 def din talk(ms ,webhook): headers = {'Content-Type': 'application/json; charset=utf-8'} data = {'ms type': 'text', 'text': {'content': ms }, 'at': {'at Mobiles': [] , 'isAtAll': False}} post_data = json.dumps(data) response = requests .post(webhook, headers=headers , data=post_data) return response.text # 检查⾏ def checkLine(line, index): curLo = lo s[index] if recordFla s[index]==1: curLo .append(line) if len(curLo )>rows : content = "\ n".join('%s' %id for id in curLo )