• linkedu视频
  • 平面设计
  • 电脑入门
  • 操作系统
  • 办公应用
  • 电脑硬件
  • 动画设计
  • 3D设计
  • 网页设计
  • CAD设计
  • 影音处理
  • 数据库
  • 程序设计
  • 认证考试
  • 信息管理
  • 信息安全
菜单
linkedu.com
  • 网页制作
  • 数据库
  • 程序设计
  • 操作系统
  • CMS教程
  • 游戏攻略
  • 脚本语言
  • 平面设计
  • 软件教程
  • 网络安全
  • 电脑知识
  • 服务器
  • 视频教程
  • MsSql
  • Mysql
  • oracle
  • MariaDB
  • DB2
  • SQLite
  • PostgreSQL
  • MongoDB
  • Redis
  • Access
  • 数据库其它
  • sybase
  • HBase
您的位置:首页 > 数据库 >Mysql > python 监控日志并发送邮件报警

python 监控日志并发送邮件报警

作者:匿名 字体:[增加 减小] 来源:互联网 时间:2018-12-05

匿名通过本文主要向大家介绍了python 等相关知识,希望本文的分享对您有所帮助
#!/usr/bin/env python
#coding:utf8
import re
import os
import time
import smtplib
import socket
import fcntl
import struct
from email.mime.text import MIMEText
def get_ip_address(ifname):
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    return socket.inet_ntoa(fcntl.ioctl(
        s.fileno(),
        0x8915,  # SIOCGIFADDR
        struct.pack('256s', ifname[:15])
    )[20:24])
   
def sendemail(subject,msg,fromemail,emailpasswd,toemail):
    '''实现发送邮件功能函数'''
    _user = fromemail
    _pwd  = emailpasswd
    _to   = toemail
    nowtime = time.strftime('%Y-%m-%d %H:%M:%S')
     
    msg = MIMEText(msg)
    msg["Subject"] = subject
    msg["From"]    = _user
    msg["To"]      = _to
     
    try:
        s = smtplib.SMTP_SSL('smtp.qq.com', 465)
        s.login(_user, _pwd)
        s.sendmail(_user, _to, msg.as_string())
        s.quit()
        print "[%s]INFO:Email send Success!" % nowtime
    except smtplib.SMTPException,e:
        print "[%s]ERROR:Email send Falied,%s" % (nowtime,e) 
def matchkeyword(pattern,alertlogfile):
    '''实现匹配关键字函数'''
    re.compile(pattern)
    posfile = "/tmp/posfile"
    if not os.path.exists(posfile):
        os.mknod(posfile)
    if not os.path.getsize(posfile):
        with open(posfile,'w') as fobj:
            fobj.write('0')       
    #打开文件
    f = open(alertlogfile,'r')
    #移动到文件结尾
    f.seek(0,2)
    #读出文件所在的字节位置
    endpos = f.tell() 
    #移动到文件的开头
    with open(posfile,'r') as fobj:
        startpos = int(fobj.read())
        f.seek(startpos)
         
    if endpos-startpos > 0:    
        data = f.read(endpos-startpos)
        f.close()
        with open(posfile,'w') as fobj:
            fobj.write(str(endpos))
        m = re.findall(pattern, data,re.IGNORECASE)
        if m:
            content = '\n'.join(m)    
            return content
        else:
            return ''
             
if __name__ == '__main__':
    local_ip = get_ip_address('eth0')
    subject = '服务器[%s]日志报警了!' % local_ip
    fromemail = 'xxxxxxxx@qq.com'
    #emailpasswd为QQ邮箱的授权码
    emailpasswd = 'mdkuasfhnjbrbhdj'
    toemail = 'xxxxxx@qq.com'
    alertlogfile = "/data/mysql/mysql_3306/log/error.log"
    #pattern = ".*\[Warning\].*\s|.*\[Note\].*\s"
    pattern = ".*Warning.*\s|.*error.*\s"
    while True:
        content = matchkeyword(pattern, alertlogfile)
        if content:
            sendemail(subject, content, fromemail, emailpasswd, toemail)
分享到:QQ空间新浪微博腾讯微博微信百度贴吧QQ好友复制网址打印

您可能想查找下面的文章:

相关文章

  • 2018-12-05Mysql 日期时间 DATE_FORMAT(date,format)
  • 2018-12-05MySQL删除表的时候忽略外键约束的代码实例分享
  • 2017-05-11基于mysql查询语句的使用详解
  • 2017-05-11MySQL HandlerSocket插件安装配置教程
  • 2018-12-05Mac下brew方式安装mysql
  • 2018-12-05Excel导入Sqlserver数据库脚本
  • 2018-12-05MySQL利用procedure analyse()函数优化表结构
  • 2017-05-11MySQL中从库延迟状况排查的一则案例
  • 2017-05-11MySQL5.6基本优化配置
  • 2018-12-05Mysql数据库优化的方法总结(必看)

文章分类

  • MsSql
  • Mysql
  • oracle
  • MariaDB
  • DB2
  • SQLite
  • PostgreSQL
  • MongoDB
  • Redis
  • Access
  • 数据库其它
  • sybase
  • HBase

最近更新的内容

    • 如何使用Navicat连接MySQL数据库?
    • MySQL分布式集群之MyCAT(二)schema代码详解
    • MySQL之-日期时间Extract函数代码示例详细介绍
    • 几个扩展存储过程使用方法
    • 一道sql面试题附答案
    • 实例讲解sqlite迁移到mysql脚本的方法_
    • MySQL 4.0 升级到mysql 5.0的方法
    • 比较全面的MySQL优化参考
    • 批处理 动态sql
    • mysql创建函数出现1418错误的解决办法

关于我们 - 联系我们 - 免责声明 - 网站地图

©2020-2025 All Rights Reserved. linkedu.com 版权所有