TOP

基于Python和Xtrbackup的自动化备份与还原实现(一)
2019-08-13 05:35:48 】 浏览:170
Tags:基于 Python Xtrbackup 自动化 备份 还原 实现

需要对xtrabackup有一定的了解,包括流式备份,压缩备份,Xtrabackup还原,mysqlbinlog还原等等。


 


1,基于xtrabackup的流式压缩备份。
2,周六/或者任意时间的第一次备份为完整备份,其他时间为基于上一次备份的增量备份。
3,将备份开始时间,结束时间,备份路径等信息写入一个日志文件,方便后续自动化还原的时候解析。


效果如下:不管是什么时候,第一次必须为完整备份,然后根据上述规则,继续执行备份的话为基于最新一次备份的增量备份,每备份完成后生成修改备份日志列表信息。



 实现:


# -*- coding: utf-8 -*-
import os
import time
import datetime
import sys
import socket
import shutil
import logging


logging.basicConfig(level=logging.INFO
                    #handlers={logging.FileHandler(filename='backup_log_info.log', mode='a', encoding='utf-8')}
                    )



host = "127.0.0.1"
port = "7000"
user = "root"
password = "root"
cnf_file = "/usr/local/mysql57_data/mysql7000/etc/my.cnf"
backup_dir = "/usr/local/backupdata"
backupfilelist = os.path.join(backup_dir,"backupfilelist.log")
backup_keep_days = 15


#获取备份类型,周六进行完备,平时增量备份,如果没有全备,执行完整备份
def get_backup_type():
    backup_type = None
    if os.path.exists(backupfilelist):
        with open(backupfilelist, 'r') as f:
            lines = f.readlines()
            if(lines):
                last_line = lines[-1] #get last backup name
                if(last_line):
                    if(time.localtime().tm_wday==6):
                        backup_type = "full"
                    else:
                        backup_type = "incr"
                else:
                    backup_type = "full"
            else:
                backup_type = "full"
    else:
        #full backup when first backup
        open(backupfilelist, "a").close()
        backup_type = "full"
    return backup_type


#获取最后一次备份信息
def get_last_backup():
    last_backup = None
    if os.path.exists(backupfilelist):
        with open(backupfilelist, 'r') as f:
            lines = f.readlines()
            last_line = lines[-1]  # get last backup name
            if (last_line):
                last_backup = os.path.join(backup_dir, last_line.split("|")[-1])
    return last_backup.replace("\n","")



#探测实例端口号
def get_mysqlservice_status():
    mysql_stat = 0
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    result = s.connect_ex((host, int(port)))
    #port os open
    if (result == 0):
        mysql_stat = 1
    return mysql_stat


#清理过期的历史备份信息
def clean_expire
基于Python和Xtrbackup的自动化备份与还原实现(一) https://www.cppentry.com/bencandy.php?fid=57&id=228415

首页 上一页 1 2 3 4 5 6 7 下一页 尾页 1/9/9
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇数据库包括哪些技术? 下一篇Redis分布式锁实现理解