Python3 备份 MySQL/Mar

发布时间：2019-09-26 07:34:04编辑：auto阅读（1978）

    【准备工作】

    • 搭建 FTP 服务器：Windows Server 2008 R2 搭建FTP服务

    • 如果本机访问报 530 错误：1、检查用户名、密码；2、检查 ftp 目录的用户权限。

    • 如果远程主机无法访问，检查防火墙。

    • 关于 ftp 的端口：控制端口为21；数据端口在主动模式（PORT）下为20，被动模式（PASV）下不定。

    • 开启被动模式：在“FTP 防火墙支持”里面配置端口，然后重启“Microsoft FTP Service”服务。注意具体 ftp 站点的数据框是灰色的，需要在 IIS 总站点配置。


    【code】

    以下代码对 Windows 下 MariaDB 10.1.18，Ubuntu 下  MySQL 5.7.23 测试可行。

    # encoding: utf-8
# author: walker
# date: 2018-08-02 
# summary: Python3 备份 MySQL/MariaDB（本地+FTP），一个库一个文件

import os
import time
import pymysql
import pprint
import psutil
from ftplib import FTP

DBHost = r'127.0.0.1'
DBPort = 3306
DBUser = r'root'     
DBPwd = r'password'

# LocalBakRoot = r'/home/walker/sql_bak'    # 本地备份目录
LocalBakRoot = r'D:\sql_bak'    # 本地备份目录
LocalIP = ''

FtpHost = r'192.168.xx.xx'  # FTP 主机
FtpBakRoot = r'sql_bak'     # FTP 目录
FtpUser = r'ftpadmin'        
FtpPwd = r'password' 

# 忽略掉系统库
IgnoreDB = {'information_schema', 'mysql', 'performance_schema', 'sys'}    

# 根据前缀获取IP
def GetLocalIPByPrefix(prefix):
    localIP = ''
    dic = psutil.net_if_addrs()
    for adapter in dic:
        snicList = dic[adapter]
        for snic in snicList:
            if not snic.family.name.startswith('AF_INET'):
                continue
            ip = snic.address
            if ip.startswith(prefix):
                localIP = ip
      
    return localIP
  
# 处理一个数据库
def ProcOneDB(dbName):
    print('ProcOneDB %s ...' % dbName)

    filename = '%s_%s_%s.sql' % (time.strftime('%Y%m%d', time.localtime()), LocalIP, dbName)
    localFile = os.path.join(LocalBakRoot, filename)
    #备份数据库，如果没有 -B 参数不会导出数据库创建语句
    cmd = 'mysqldump -u%s -p%s -B %s > %s' % (DBUser, DBPwd, dbName, localFile)
    # print('cmd: %s' % cmd)
    print('mysqldump ...')
    rtn = os.system(cmd)
    if 0 != rtn:
        print('Error: 0 != rtn')
        return False

    ftp = FTP()
    ftp.encoding = 'gb18030'
    ftp.set_pasv(False)
    ftp.connect(FtpHost, port=21, timeout=10)
    ftp.login(user=FtpUser, passwd=FtpPwd)

    print(ftp.getwelcome())
    ftp.cwd(FtpBakRoot)
    # 以 sql 服务器 ip 作为子目录名
    if LocalIP not in ftp.nlst():
        ftp.mkd(LocalIP)       # 创建子目录
    ftp.cwd(LocalIP)
    with open(localFile, mode='rb') as f:
        ftp.storbinary('STOR ' + filename, f)

    return True    
  
# 处理所有数据库
def ProcAllDB():
    connDB = pymysql.connect(host=DBHost,
                                port=DBPort,
                                user=DBUser,
                                passwd=DBPwd,
                                charset='utf8mb4')
                                  
    cur = connDB.cursor()
          
    sql = "show databases;" 
    print('input sql:' + sql)
    cur.execute(sql)
    rowList = cur.fetchall()
    cur.close()
    connDB.close()
      
    dbList = list()
    for row in rowList:
        dbList.append(row[0])
    print('dbList(%d):\n%s\n' % (len(dbList), pprint.pformat(dbList, indent=4)))
      
    for dbName in dbList:
        if dbName in IgnoreDB:
            continue
        print('current time: %s' % time.strftime('%Y-%m-%d %H:%M:%S',time.localtime()))    
        ProcOneDB(dbName)                                          
        print('current time: %s\n' % time.strftime('%Y-%m-%d %H:%M:%S',time.localtime()))    
                                          
if __name__ == '__main__':
    LocalIP = GetLocalIPByPrefix('192.168.xx.')
    ProcAllDB()


    【相关阅读】


    *** walker ***


关键字：

上一篇： python3二维码生成工具

下一篇： Python3 面向对象概述