Browse Source

backup only local db , beacause xmlrpc call of dump cause memory leak

pull/636/head
archetipo 9 years ago
committed by Dave Lasley
parent
commit
7ba39bd385
  1. 45
      auto_backup/model/backup_scheduler.py

45
auto_backup/model/backup_scheduler.py

@ -23,11 +23,11 @@ import socket
import os import os
import time import time
import datetime import datetime
import base64
import re import re
from openerp import models, fields, api, _ from openerp import models, fields, api, _
from openerp.exceptions import except_orm, Warning as UserError from openerp.exceptions import except_orm, Warning as UserError
from openerp import tools from openerp import tools
from openerp.service import db
import logging import logging
_logger = logging.getLogger(__name__) _logger = logging.getLogger(__name__)
try: try:
@ -207,9 +207,7 @@ class DbBackup(models.Model):
messageTitle = "" messageTitle = ""
messageContent = "" messageContent = ""
for rec in confs: for rec in confs:
# db_list = self.get_db_list(cr, uid, [], rec.host, rec.port)
try: try:
# pathToWriteTo = rec.sftppath
conn_success = True conn_success = True
ipHost = rec.sftpip ipHost = rec.sftpip
portHost = rec.sftpport portHost = rec.sftpport
@ -243,11 +241,6 @@ class DbBackup(models.Model):
def schedule_backup(self): def schedule_backup(self):
for rec in self.search([]): for rec in self.search([]):
db_list = self.get_db_list(rec.host, rec.port, rec.securehost)
if rec.name in db_list:
file_path = ''
bkp_file = ''
try:
if not os.path.isdir(rec.bkp_dir): if not os.path.isdir(rec.bkp_dir):
os.makedirs(rec.bkp_dir) os.makedirs(rec.bkp_dir)
# Create name for dumpfile. # Create name for dumpfile.
@ -255,27 +248,9 @@ class DbBackup(models.Model):
time.strftime('%d_%m_%Y_%H_%M_%S'), time.strftime('%d_%m_%Y_%H_%M_%S'),
rec.name) rec.name)
file_path = os.path.join(rec.bkp_dir, bkp_file) file_path = os.path.join(rec.bkp_dir, bkp_file)
conn = self.get_connection(
rec.host, rec.port, rec.securehost)
bkp = ''
bkp = execute(
conn, 'dump', rec.adminpassword, rec.name)
except Exception, e:
_logger.info(
_(
"Autobackup Couldn't backup database %s. :" +
str(e))
)
return False
bkp = base64.decodestring(bkp)
fp = open(file_path, 'wb')
fp.write(bkp)
fp.close()
else:
_logger.info(
("database %s doesn't exist on http://%s:%s") %
(rec.name, rec.host, rec.port))
return False
fbk = open(file_path, 'wb')
db.dump_db(rec.name, fbk)
fbk.close()
# Check if user wants to write to SFTP or not. # Check if user wants to write to SFTP or not.
if rec.sftpwrite is True: if rec.sftpwrite is True:
try: try:
@ -318,6 +293,9 @@ class DbBackup(models.Model):
pass pass
srv.chdir(pathToWriteTo) srv.chdir(pathToWriteTo)
# Loop over all files in the directory. # Loop over all files in the directory.
_logger.debug(
'Start to copy files...'
)
for f in os.listdir(dir): for f in os.listdir(dir):
fullpath = os.path.join(dir, f) fullpath = os.path.join(dir, f)
if os.path.isfile(fullpath): if os.path.isfile(fullpath):
@ -325,7 +303,6 @@ class DbBackup(models.Model):
# Navigate in to the correct folder. # Navigate in to the correct folder.
srv.chdir(pathToWriteTo) srv.chdir(pathToWriteTo)
# Loop over all files in the directory from the back-ups. # Loop over all files in the directory from the back-ups.
# We will check the creation date of every back-up. # We will check the creation date of every back-up.
for file in srv.listdir(pathToWriteTo): for file in srv.listdir(pathToWriteTo):
@ -365,7 +342,12 @@ class DbBackup(models.Model):
# Remove all old files (on local server) # Remove all old files (on local server)
# in case this is configured.. # in case this is configured..
if rec.autoremove is True: if rec.autoremove is True:
try:
self.remove_folder(rec) self.remove_folder(rec)
except Exception as e:
_logger.debug(
'Exception when try to remove file'
)
return True return True
@ -420,4 +402,7 @@ class DbBackup(models.Model):
now = datetime.datetime.now() now = datetime.datetime.now()
delta = now - createtime delta = now - createtime
if delta.days >= rec.daystokeep: if delta.days >= rec.daystokeep:
_logger.debug(
'Remove local file...'
)
os.remove(fullpath) os.remove(fullpath)
Loading…
Cancel
Save