?
MySQL备份--mysql dump(二)
/bin/env python
# -*- coding: utf-8 -*-
#
#@arthur
#@date 2015-05-7
#@dsc 远程备份s数据
import os
import sys
import logging
import traceback
import time
logger = logging.getLogger()
logging.basicConfig(
format = '%(asctime)s %(levelname)s %(module)s.%(funcName)s Line:%(lineno)d\t%(message)s',
filename = os.path.join(os.path.dirname(__file__), r'backStrategyData.log'),
filemode = 'a+',
level = logging.NOTSET
)
class BackupDatabase():
'''
备份数据库
'''
def __init__(self, dbIp, dbName, bakFile, user, pwd):
self.dbIp = dbIp
self.dbName = dbName
self.bakFile = bakFile
self.user =user
self.pwd = pwd
def __generateCmd(self):
cmd = 'mysqldump --host %s --user=%s --password=%s %s > %s' \
% (self.dbIp, self.user, self.pwd, self.dbName, self.bakFile)
return cmd
def runBackup(self):
cmd = self.__generateCmd()
try:
os.system(cmd)
except:
logger.error(traceback.format_exc())
#
数据库ip
__mysqlIp = ''
__bakPath = r'/data/backup/strategydata'
__dbName = 'strategydata'
__user = ''
__pwd = ''
# 备份个数
__bakCount = 5
# 备份文件后缀
__bakSuffix = 'strategydata.sql'
def backStrategyData():
files = os.listdir(__bakPath)
bakFiles = []
for f in files:
if os.path.isfile(os.path.join(__bakPath, f)) and f.endswith(__bakSuffix):
bakFiles.append(f)
bakFiles.sort(reverse=True)
delFiles = bakFiles[__bakCount - 1:]
try:
for f in delFiles:
df = os.path.join(__bakPath, f)
logger.info('delete file %s.' % df)
os.remove(df)
except:
logger.error(traceback.format_exc())
newBakFile = os.path.join(__bakPath, time.strftime("%Y-%m-%d-%H-%M-%S") + __bakSuffix)
logger.info('backup %s:%s to %s!' % (__mysqlIp, __dbName, newBakFile))
oBack = BackupDatabase(__mysqlIp, __dbName, newBakFile, __user, __pwd)
oBack.runBackup()
def main():
try:
backStrategyData()
except:
logger.error(traceback.format_exc())
if __name__ == '__main__':
main()