查看“Python实现实时文件监控”的源代码

Python实现实时文件监控
在我们业务运维中，监控无处不在，我们对业务运行状态做监控，一旦业务故障，我们提前同志运维人员，把风险降到最低。

当然要查看业务的运行状态是否正常,我们一般从以下几个方面来判断:
(1)业务接口的状态码是否正常
(2)业务接口的返回内容是否正常
(3)业务端口是否正常
(4)对业务程序的生成的日志内容进行判断

Python实现实时文件监控几种方案:

准备好S_mail.py代码

#coding:utf-8
import smtplib
from email.mime.text import MIMEText

class SendEMail(object):
    # 定义第三方 SMTP 服务
    def __init__(self):
        self.mail_host = "smtp.163.com"  # SMTP服务器
        self.mail_user = "15610347662@163.com"  # 用户名
        self.mail_pass = "APLT"  # 密码
        self.sender = '15610347662@163.com'  # 发件人邮箱
        self.smtpObj = smtplib.SMTP_SSL(self.mail_host, 465)
        self.smtpObj.login(self.mail_user,self.mail_pass)  # 登录验证

    def sendmail(self,receivers,title,content):
        message = MIMEText(content,'plain','utf-8')  # 内容, 格式, 编码
        message['From'] = "{}".format(self.sender)
        message['To'] = ",".join(receivers)
        message['Subject'] = title
        try:
            self.smtpObj.sendmail(self.sender, message['To'].split(','), message.as_string())  # 发送
            print("mail has been send successfully.")
        except smtplib.SMTPException as e:
            print(e)

if __name__ == '__main__':
    sm = SendEMail()
sm.sendmail(['15610347662@163.com'], '主题', '正文')
我们将代码和测试日志放在同一个文件夹下测试

方案一调用Linux的tailf实现


#coding:utf-8
import subprocess
from S_mail import SendEMail

logfile = "pay-api_error.log"
cmd = 'tailf -1{0}'.format(logfile)
key_word="heart"

pp = subprocess.Popen(cmd,stdout=subprocess.PIPE,stderr=subprocess.PIPE,shell=True)
while True:
    line = pp.stdout.readline().strip()
    line = line.decode()
    if key_word in line:
        print("有{0},发送紧急警告".format(key_word))
        sm = SendEMail()
        sm.sendmail(['15610347662@163.com'],"主题","正文")

1-3行：导入subprocess用于调用shell，from S_mail import SendEMail导入邮件类

5-7行：定义变量，执行的shell命令，文件路径和关键字

最后调用shell去执行，strip()方法用于移除字符串头尾指定的字符，