UNLOZE/projects-jenz
9
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

updated backups system

Browse Source
This commit is contained in:
jenz
2023-05-10 22:38:52 +02:00
parent f79327a11f
commit 2385004da4
4 changed files with 173 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files
file_mover/file_mover.py
+14
View File
@@ -53,9 +53,11 @@ def main():
for index, job in enumerate(jobs):
src = create_remote(remotes[job["src"]], settings)
dest = create_remote(remotes[job["dest"]], settings)
dest2 = create_remote(remotes[job["dest2"]], settings)
if index == 0:
#delete old files (not very adaptable, cant handle dirs in dirs)
dest.delete_remote_zips("/home/nonroot/backups")
dest2.delete_remote_zips("/home/autismbot5/compressed_backups")
if 'demo_' in job["job_name"]:
source_files = src.list_dir()
distribute_files(source_files, dest)
@@ -68,6 +70,10 @@ def main():
log_msg = ''.join(["failed putting file: ", str(pathfile)])
logging.warning(log_msg)
sys.exit(1)
if not dest2.put(zip_file_path, dest2.path):
log_msg = ''.join(["failed putting file: ", str(pathfile)])
logging.warning(log_msg)
sys.exit(1)
src.delete_local_zip(zip_file_path)
elif "mysqldump" in job["job_name"]:
src.remote_channel_command(job, "mysqldump")
@@ -85,6 +91,10 @@ def main():
logging.warning(f'failed putting local zip {local_zip_path_name} at job {job}')
src.delete_local_zip(local_zip_path_name)
sys.exit(1)
if not dest2.put(local_zip_path_name, dest2.path):
logging.warning(f'failed putting local zip {local_zip_path_name} at job {job}')
src.delete_local_zip(local_zip_path_name)
sys.exit(1)
src.delete_local_zip(local_zip_path_name)
elif "backup_remote" in job["job_name"]:
zipname = src.remote_channel_command(job, "tar_recursive")
@@ -101,6 +111,10 @@ def main():
logging.warning(f'failed putting local zip {local_zip_path_name} at job {job}')
src.delete_local_zip(local_zip_path_name)
sys.exit(1)
if not dest2.put(local_zip_path_name, dest2.path):
logging.warning(f'failed putting local zip {local_zip_path_name} at job {job}')
src.delete_local_zip(local_zip_path_name)
sys.exit(1)
src.delete_local_zip(local_zip_path_name)
logging.info(('finished job: ', job))