文章出处:https://blog.csdn.net/sdksdk0/article/details/80933444
作者:朱培 ID:sdksdk0
--------------------------------------------------------------------------------------------
对于最近的开发环境,偶尔会有挂掉的现象发生,然而并没有及时发现,下载需要添加一个监控功能,当服务挂掉的时候需要有邮件提醒,同时我们的系统每天晚上会跑定时任务,想知道有没有异常发生,所以添加了两个python监本监控,因为本身系统不大,所以没必要去配置kafka+storm这种日志监控了,只用了很简单的方式来处理了。
1、监控tomcat是否挂掉
from smtplib import SMTP_SSL from email.mime.text import MIMEText from email.header import Header from os.path import getsize from sys import exit from re import compile, IGNORECASE import sys, time import os #定义主机 帐号 密码 收件人 邮件主题 #定义主机 帐号 密码 收件人 邮件主题 mail_info = { "from": "info@sogoucloud.cn", "to": "zhupei@sogoucloud.cn", "hostname": "smtp.exmail.qq.com", "username": "info@sogoucloud.cn", "password": "123456", "mail_subject": "qybd服务器异常", "mail_text": "hello, tomcat服务器出现异常了!,请及时处理", "mail_encoding": "utf-8" } #发送邮件函数 def send_mail(error): #定义邮件的头部信息 #连接SMTP服务器,然后发送信息 smtp = SMTP_SSL(mail_info["hostname"]) smtp.set_debuglevel(1) smtp.ehlo(mail_info["hostname"]) smtp.login(mail_info["username"], mail_info["password"]) msg = MIMEText(error, "plain", mail_info["mail_encoding"]) msg["Subject"] = Header(mail_info["mail_subject"], mail_info["mail_encoding"]) msg["from"] = mail_info["from"] msg["to"] = mail_info["to"] smtp.sendmail(mail_info["from"], mail_info["to"], msg.as_string()) smtp.quit() def isRunning(process_name): try: process = len(os.popen('ps aux | grep "' + process_name + '" | grep -v grep').readlines()) if process >= 1: return True else: return False except: print("Check process ERROR!!!") return False #调用发送邮件函数发送邮件 if __name__ == '__main__': process_name = "qybd" isrunning = isRunning(process_name) print(isrunning) if isrunning == False: send_mail("老铁!qybd服务器挂了!")
2、添加crontab定时任务:
*/3 * * * * python /usr/tools/qybd/cmd/sendEmail.py >> /usr/tools/qybd/cmd/tomcatlife.py.log 2>&1
3、使用crontab -u root -l 命令查看当前运行的定时任务
4、监控日志的脚本
from smtplib import SMTP_SSL from email.mime.text import MIMEText from email.header import Header from os.path import getsize from sys import exit from re import compile, IGNORECASE #定义主机 帐号 密码 收件人 邮件主题 #定义主机 帐号 密码 收件人 邮件主题 mail_info = { "from": "info@sogoucloud.cn", "to": "zhupei@sogoucloud.cn", "hostname": "smtp.exmail.qq.com", "username": "info@sogoucloud.cn", "password": "123456", "mail_subject": "qybd服务器异常", "mail_text": "hello, tomcat服务器出现异常了!,请及时处理", "mail_encoding": "utf-8" } #定义tomcat日志文件位置 tomcat_log = '/usr/tools/qybd/tomcat/logs/catalina.out' #该文件是用于记录上次读取日志文件的位置,执行脚本的用户要有创建该文件的权限 last_position_logfile = '/usr/tools/qybd/tomcat/logs/last_position.txt' #匹配的错误信息关键字的正则表达式 pattern = compile(r'Exception|^\t+\bat\b',IGNORECASE) #发送邮件函数 def send_mail(error): #定义邮件的头部信息 #连接SMTP服务器,然后发送信息 smtp = SMTP_SSL(mail_info["hostname"]) smtp.set_debuglevel(1) smtp.ehlo(mail_info["hostname"]) smtp.login(mail_info["username"], mail_info["password"]) msg = MIMEText(error, "plain", mail_info["mail_encoding"]) msg["Subject"] = Header(mail_info["mail_subject"], mail_info["mail_encoding"]) msg["from"] = mail_info["from"] msg["to"] = mail_info["to"] smtp.sendmail(mail_info["from"], mail_info["to"], msg.as_string()) smtp.quit() #读取上一次日志文件的读取位置 def get_last_position(file): try: data = open(file,'r') last_position = data.readline() if last_position: last_position = int(last_position) else: last_position = 0 except: last_position = 0 return last_position #写入本次日志文件的本次位置 def write_this_position(file,last_positon): try: data = open(file,'w') data.write(str(last_positon)) data.write('\n' + "Don't Delete This File,It is Very important for Looking Tomcat Error Log !! \n") data.close() except: print "Can't Create File !" + file exit() #分析文件找出异常的行 def analysis_log(file): error_list = [] #定义一个列表,用于存放错误信息. try: data = open(file,'r') except: exit() last_position = get_last_position(last_position_logfile) #得到上一次文件指针在日志文件中的位置 this_postion = getsize(tomcat_log) #得到现在文件的大小,相当于得到了文件指针在末尾的位置 if this_postion < last_position: #如果这次的位置 小于 上次的位置说明 日志文件轮换过了,那么就从头开始 data.seek(0) elif this_postion == last_position: #如果这次的位置 等于 上次的位置 说明 还没有新的日志产生 exit() elif this_postion > last_position: #如果是大于上一次的位置,就移动文件指针到上次的位置 data.seek(last_position) for line in data: if pattern.search(line): error_list.append(line) write_this_position(last_position_logfile,data.tell()) #写入本次读取的位置 data.close() return ''.join(error_list) #形成一个字符串 #调用发送邮件函数发送邮件 error_info = analysis_log(tomcat_log) if error_info: send_mail(error_info)
5、添加crontab定时任务:
*/10 * * * * python /usr/tools/qybd/cmd/tomcat_log_error_analysis.py >> /usr/tools/qybd/cmd/crontest.py.log 2>&1
效果如下:
总结
以上所述是小编给大家介绍的python脚本监控Tomcat服务器的方法,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对小牛知识库网站的支持!
本文向大家介绍python脚本监控docker容器,包括了python脚本监控docker容器的使用技巧和注意事项,需要的朋友参考一下 本文实例为大家分享了python脚本监控docker容器的方法,供大家参考,具体内容如下 脚本功能: 1、监控CPU使用率 2、监控内存使用状况 3、监控网络流量 具体代码: 以上就是python脚本监控docker容器的全部代码,希望对大家的学习有所帮助。
本文向大家介绍使用python进行服务器的监控,包括了使用python进行服务器的监控的使用技巧和注意事项,需要的朋友参考一下 在linux服务器中,一切皆为文件,就是说,服务器运行的个中信息,其实是可以从某些文件中查询得到的;百度后,你会知道,在Linux系统中,有一个/proc的虚拟文件系统: Linux 系统为管理员提供了非常好的方法,使其可以在系统运行时更改内核,而不需要重新引导内核系统,
微服务治理的一个核心需求便是服务可观察性。作为微服务的牧羊人,要做到时刻掌握各项服务的健康状态,并非易事。云原生时代这一领域内涌现出了诸多解决方案。本组件对可观察性当中的重要支柱遥测与监控进行了抽象,方便使用者与既有基础设施快速结合,同时避免供应商锁定。 安装 通过 Composer 安装组件 composer require hyperf/metric hyperf/metric 组件默认安装
1.1、什么是监控服务 监控服务(Monitor Service),是指对直播视频流的实时监控。目睹云提供的监控服务能够支持对rtmp、flv、hls等大多数直播流进行即时监控,并且渲染成图表。监控服务主要监控的是直播视频的帧率和码率信息,这样能够及时的反映出来视频流的卡顿流畅情况。 1.2、监控服务功能介绍 支持多种流监控:支持rtmp、flv、hls等多种直播视频协议流监控 历史监控数据:支持
本文向大家介绍如何监控 Linux 服务器状态的方法,包括了如何监控 Linux 服务器状态的方法的使用技巧和注意事项,需要的朋友参考一下 Linux 服务器我们天天打交道,特别是 Linux 工程师更是如此。为了保证服务器的安全与性能,我们经常需要监控服务器的一些状态,以保证工作能顺利开展。 本文介绍的几个命令,不仅仅适用于服务器监控,也适用于我们日常情况下的开发。 1. watch watch
My roommate lost his pet elephant. It’s in the apartment somewhere. — Steven Wright 我们无法持续关注所有的一切。问题是:你怎么知道一台服务器何时会出现故障呢? 错误的答案是,“我的客户打电话给我,告诉我服务器宕机了。” 但是,你会惊奇地发现,许多组织的系统没有任何的自动监控。自动监控的设置非常简单。 目前有许多优秀