patrick/zfs_autobackup
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

now hold important snapshots to prevent accidental deletion by administrator or other scripts

Browse Source
This commit is contained in:
Edwin Eefting
2019-02-16 02:06:06 +01:00
parent 511311eee7
commit 11d051122b
1 changed files with 31 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
zfs_autobackup
View File

@ -100,7 +100,7 @@ def zfs_get_selected_filesystems(ssh_to, backup_name):
else: else:
if source=="local" and ( value=="true" or value=="child"): if source=="local" and ( value=="true" or value=="child"):
direct_filesystems.append(name) direct_filesystems.append(name)
if source=="local" and value=="true": if source=="local" and value=="true":
selected_filesystems.append(name) selected_filesystems.append(name)
verbose("Selected: {0} (direct selection)".format(name)) verbose("Selected: {0} (direct selection)".format(name))
@ -224,6 +224,27 @@ def zfs_get_snapshots(ssh_to, filesystems, backup_name):
return(ret) return(ret)
def default_tag():
return("zfs_autobackup:"+args.backup_name)
"""hold a snapshot so it cant be destroyed accidently by admin or other processes"""
def zfs_hold_snapshot(ssh_to, snapshot, tag=None):
cmd=[
"zfs", "hold", tag or default_tag(), snapshot
]
run(ssh_to=ssh_to, test=args.test, tab_split=False, cmd=cmd, valid_exitcodes=[ 0, 1 ])
"""release a snapshot"""
def zfs_release_snapshot(ssh_to, snapshot, tag=None):
cmd=[
"zfs", "release", tag or default_tag(), snapshot
]
run(ssh_to=ssh_to, test=args.test, tab_split=False, cmd=cmd, valid_exitcodes=[ 0, 1 ])
"""transfer a zfs snapshot from source to target. both can be either local or via ssh. """transfer a zfs snapshot from source to target. both can be either local or via ssh.
@ -536,6 +557,9 @@ def zfs_autobackup():
else: else:
resume_token=None resume_token=None
#hold the snapshot we're sending on the source
zfs_hold_snapshot(ssh_to=args.ssh_source, snapshot=source_filesystem+"@"+send_snapshot)
zfs_transfer( zfs_transfer(
ssh_source=args.ssh_source, source_filesystem=source_filesystem, ssh_source=args.ssh_source, source_filesystem=source_filesystem,
first_snapshot=latest_target_snapshot, second_snapshot=send_snapshot, first_snapshot=latest_target_snapshot, second_snapshot=send_snapshot,
@ -543,11 +567,17 @@ def zfs_autobackup():
resume_token=resume_token resume_token=resume_token
) )
#hold the snapshot we just send to the target
zfs_hold_snapshot(ssh_to=args.ssh_target, snapshot=target_filesystem+"@"+send_snapshot)
#now that we succesfully transferred this snapshot, the previous snapshot is obsolete: #now that we succesfully transferred this snapshot, the previous snapshot is obsolete:
if latest_target_snapshot: if latest_target_snapshot:
zfs_release_snapshot(ssh_to=args.ssh_target, snapshot=target_filesystem+"@"+latest_target_snapshot)
target_obsolete_snapshots[target_filesystem].append(latest_target_snapshot) target_obsolete_snapshots[target_filesystem].append(latest_target_snapshot)
zfs_release_snapshot(ssh_to=args.ssh_source, snapshot=source_filesystem+"@"+latest_target_snapshot)
source_obsolete_snapshots[source_filesystem].append(latest_target_snapshot) source_obsolete_snapshots[source_filesystem].append(latest_target_snapshot)
#we just received a new filesytem? #we just received a new filesytem?
else: else:
@ -653,4 +683,3 @@ except Exception as e:
else: else:
print("* ABORTED *") print("* ABORTED *")
print(str(e)) print(str(e))