5 from sql.util import new_cursor, get_dbs, db_backup_pre, db_backup_mkdir
6 from Queue import Queue, Empty
10 MYSQLDUMP_ARGS = ['--compact', '--add-drop-table', '--add-locks',
11 '--create-options', '--disable-keys', '--dump-date',
12 '--extended-insert', '--quick',
13 '--no-autocommit', '--quote-names', '--routines',
14 '--single-transaction', '--triggers', '--force']
22 next = queue.get(timeout=3)
24 log = db.Backup.get_by(db=next[0])
26 log = db.Backup(db=next[0])
27 log.dump_path = next[1]
28 log.dump_date = db.func.now()
29 db_backup_mkdir(next[1])
30 args = ['mysqldump', next[0]]
31 args.extend(MYSQLDUMP_ARGS)
32 p0 = subprocess.Popen(args, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
33 p1 = subprocess.Popen(['gzip'], stdin=p0.stdout, stdout=file(next[1], 'w+'))
35 err = p0.stderr.read()
37 log.dump_errnum = p0.returncode
40 log.dump_errnum = None
41 log.dump_errstr = None
45 except (KeyboardInterrupt, SystemExit):
51 t_consumer = threading.Thread(target=consumer)
55 c = new_cursor('mysqldump')
57 log = db.Backup.get_by(db=db)
59 log = db.Backup(db=db)
60 elif log.skip_date and log.skip_date.timetuple:
61 if time.mktime(log.skip_date.timetuple()) + 3600 > time.time():
62 # never recheck a db skipped in the past hour
64 d = db_backup_pre(c, db)
67 log.skip_reason = None
70 log.skip_reason = d[1]
71 log.skip_date = db.func.now()
77 except KeyboardInterrupt: