Python分析MySQL慢日志并定期发送邮件

时间：2015-03-17 编辑：简简单单来源：一聚教程网

因为开发针对某系统做稳定性建设，需要对数据库系统的慢日志进行审计，检查优化。和开发沟通选择定期发送慢查询到开发的邮箱的方式，每日汇总，然后一起评估优化slow query 。

工具实现

mail.py 脚本

代码如下

复制代码

#!/usr/bin/env python

# -*- coding: utf-8 -*-

# mail.py

import os.path

import time

import sys

import os

import json

import string

import random

import smtplib

import time

from datetime import date

from email.mime.multipart import MIMEMultipart

from email.mime.text import MIMEText

from email.mime.image import MIMEImage

from email.Header import Header

from email.MIMEText import MIMEText

from email.MIMEMultipart import MIMEMultipart

mail_user="xxx@xxxx.com";

mail_pass="xxxxx";

mail_smtp_server="smtp.xxxxx.com";

mail_smtp_port= 25

def sendMail(contents,subject,attach,mail_to):

    lTime=str(time.strftime('%Y%m%d_%H',time.localtime(time.time())))

    msg = MIMEMultipart('related');

    if subject=="":

        subject='test';

    msg['Subject'] = subject+" Time:"+ lTime;

    msg['From'] = mail_user;

    msg['To'] = ";".join(mail_to) ;

    html="";

    for cont in contents:

        html = html+cont[0];

    msgHtml = MIMEMultipart('alternative');

    msgHtml.set_charset('UTF-8');

    msgAtt = MIMEText(open(attach,'rb').read(),'base','gbk');

    msgAtt["Content-Type"] = 'application/octet-stream'

    msgAtt["Content-Disposition"] = 'attachment; filename="'+subject+'"'

    msg.attach(msgAtt);

    try:

        smtp = smtplib.SMTP();

        smtp.connect(mail_smtp_server,mail_smtp_port)

        smtp.login(mail_user,mail_pass);

        smtp.sendmail(mail_user,mail_to,msg.as_string());

        smtp.close();

    except Exception,e:

        print str(e)
sendSlowlog.py

#!/usr/bin/env python

# -*- coding: utf-8 -*-

import mail ##使用了上述脚本

import sys

import time

import os

import datetime

from datetime import date

from os.path import join, getsize

def sendSlowlog(subject_info,attach,mail_to):

    size = os.path.getsize(attach)

    if(size > 1):

      mail.sendMail("",subject_info,attach,mail_to)

if __name__ == '__main__':

mail_to=["qilong.yangql@xxxx.com"]

lDate=str(time.strftime('%Y%m%d',time.localtime(time.time())))

lTime=str(time.strftime('%Y%m%d_%H',time.localtime(time.time())))

subject_info="Slowlog of DBname" + lTime

attach="/u01/my3306/log/slow_"+ lDate +"/slow.log."+lTime

sendSlowlog(subject_info,attach,mail_to)

注：本系统已经每小时将slow log 进行分割，关于如何切割，各位可以思考一下。

上一个：简单的php数字正则表达式
下一个：快速查找apache响应慢的请求位置的mod_log_slow

推荐专题

最新下载

热门教程

Python分析MySQL慢日志并定期发送邮件

相关文章

热门栏目

php教程

asp.net教程

手机开发

css教程

网页制作

办公数码

jsp教程