coop-cloud/backup-bot-two
coop-cloud/backup-bot-two
6
0
Fork 4
Code Issues 9 Pull Requests Packages Projects Releases Wiki Activity

get_backup_details/add_backup_paths: filter by volumes

Browse Source
This commit is contained in:
Moritz 2024-09-17 17:38:43 +02:00
parent 249772ec03
commit eb7c35d4cd
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
backupbot.py
View File

@ -193,7 +193,7 @@ def parse_backup_labels(hook_type='backup', selected_container=[]):
return app_settings
def get_backup_details(app_settings):
def get_backup_details(app_settings, volumes=[]):
backup_paths = set()
backup_apps = []
pre_hooks= {}
@ -205,7 +205,7 @@ def get_backup_details(app_settings):
# if SERVICE and SERVICE != app:
# continue
backup_apps.append(app)
add_backup_paths(backup_paths, settings, app)
add_backup_paths(backup_paths, settings, app, volumes)
if hooks:= settings.get('pre_hooks'):
pre_hooks.update(hooks)
if hooks:= settings.get('post_hooks'):
@ -213,7 +213,7 @@ def get_backup_details(app_settings):
return pre_hooks, post_hooks, list(backup_paths), backup_apps
def add_backup_paths(backup_paths, settings, app):
def add_backup_paths(backup_paths, settings, app, selected_volumes):
if (volumes := settings.get('volumes')):
if includes:= settings.get('included_volume_paths'):
included_volumes = list(zip(*includes))[0]
@ -221,6 +221,9 @@ def add_backup_paths(backup_paths, settings, app):
if not (volume_path:= volumes.get(volume)):
logger.error(f'Can not find volume with the name {volume}')
continue
if selected_volumes and volume not in selected_volumes:
logger.debug(f'Skipping {volume}:{rel_paths} because the volume is not selected')
continue
for p in rel_paths:
absolute_path = Path(f"{volume_path}/{p}")
backup_paths.add(absolute_path)
@ -228,8 +231,16 @@ def add_backup_paths(backup_paths, settings, app):
included_volumes = []
excluded_volumes = settings.get('excluded_volumes') or []
for name, path in volumes.items():
if name not in excluded_volumes and name not in included_volumes:
backup_paths.add(path)
if selected_volumes and name not in selected_volumes:
logger.debug(f'Skipping volume: {name} because the volume is not selected')
continue
if name in excluded_volumes:
logger.debug(f'Skipping volume: {name} because the volume is excluded')
continue
if name in included_volumes:
logger.debug(f'Skipping volume: {name} because a path is selected')
continue
backup_paths.add(path)
else:
logger.warning(f"{app} does not contain any volumes")
@ -242,7 +253,6 @@ def parse_volumes(stack_name, mounts):
relative_path = m['Source']
name = relative_path.removeprefix(stack_name + '_')
absolute_path = Path(f"{VOLUME_PATH}{relative_path}/_data/")
#TODO: if absolute_path.exists():
volumes[name] = absolute_path
return volumes