mysql_backup_v3.py

import os
import time
import logging
import threading
import smtplib
from email.mime.text import MIMEText

# date : 2016-05-11
# description: mysql db many thread backup script and please use python3 run 
# author : 张玉坡(yupozhang@gmail.com)


class Dbbackup():


    @staticmethod
    def backup(dpath,db):
        dbtime = time.strftime('%Y%m%d%H%M%S')
        if os.path.exists(dpath) or os.mkdir(dpath):
            start = time.time()
            status = os.system("/usr/local/mysql/bin/mysqldump -R  --opt {0} > {1}/{2}_{3}.sql && /usr/bin/gzip {1}/{2}_{3}.sql " .format(db,dpath,db,dbtime))
            endtime = time.time() - start
            if status == 0:
                Dbbackup.save_db_logs(1,db,endtime,dbtime)
            else:
                Dbbackup.save_db_logs(2,db,endtime,dbtime)

    @staticmethod
    def save_db_logs(status,dbname,taketime,dbtime):
        dspath = '/data/backup'
        logname = "{0}/dbbackup.log".format(dspath)
        logformat = ('%(asctime)s - %(levelname)s - %(filename)s - %(message)s')
        logging.basicConfig(level=logging.DEBUG,format=logformat,filename=logname,filemode='a')
        if status == 1:
            logging.info('{0} at {1} backup succeed and totle take time {2} ' .format(dbname,dbtime,taketime))
        else:
             logging.info('{0} at {1} backup failed' .format(dbname,dbtime))
             s = Servermail()
             mailuser = ["zo@y.com"]				   #要通知的邮箱，可以支持多个。
             s.send_user_mail('数据库备份失败','数据库_{0}备份失败'.format(dbname),mailuser)

    @staticmethod
    def del_past_files(day,dpath='/data/backup'):
        if day:
            status = os.system('''/usr/bin/find {0}  -type f \( -name "*.gz" \) -mtime +{1} -delete''' .format(dpath,day))


#发送邮件类
class Servermail():
    def __init__(self):
        self.Server_user = "xx@qq.com"					#要使用发送邮件的邮箱
        self.Server_pwd = "Rxx8"						#邮箱密码
        self.Servers = "smtp.exmail.qq.com"				#要使用的邮件服务器地址

    def send_user_mail(self,title,connect,tomail):
        self.connect = connect
        self.title = title
        self.tomail = tomail

        msg = MIMEText(self.connect)
        msg["Subject"] = self.title						#邮件标题
        msg["From"]    = self.Server_user				#邮件来自的用户
        msg["To"]      = ";".join(self.tomail)			#要发送的邮箱地址
        try:
            with smtplib.SMTP(self.Servers, timeout=30) as s:
                s.login(self.Server_user, self.Server_pwd)	#登陆服务器
                s.sendmail(self.Server_user,self.tomail, msg.as_string())#发送邮件
                print("发送成功")
        except Exception as e:
             print("发送失败")




if __name__ == '__main__':
    dbname = (('company_inner','base'))		#要备份的数据库名称
    dspath = '/data/backup'
    threads = []
    for db in dbname:
        threads.append(threading.Thread(target=Dbbackup.backup,args=(dspath, db)))
    for t in threads:
        t.start()
    for t in threads:
        t.join()

    Dbbackup.del_past_files(day='50')