59 lines
1.4 KiB
Python
59 lines
1.4 KiB
Python
|
from .spec import Spec
|
||
|
|
from typing import Union
|
||
|
|
from pathlib import Path
|
||
|
|
from datetime import datetime
|
||
|
|
import subprocess
|
||
|
|
|
||
|
|
|
||
|
|
class VolumeSpec(Spec):
|
||
|
|
"""
|
||
|
|
A spec for backup up a Docker volume.
|
||
|
|
"""
|
||
|
|
|
||
|
|
_SKEL = {
|
||
|
|
"volume": None,
|
||
|
|
"image": "alpine:latest",
|
||
|
|
"command": "tar -czf '/to/{filename}' .",
|
||
|
|
}
|
||
|
|
|
||
|
|
def __init__(
|
||
|
|
self,
|
||
|
|
name: str,
|
||
|
|
volume: str,
|
||
|
|
image: str,
|
||
|
|
destination: Union[str, Path],
|
||
|
|
limit: int,
|
||
|
|
command: str,
|
||
|
|
extension: str,
|
||
|
|
notify=None,
|
||
|
|
):
|
||
|
|
super().__init__(name, destination, limit, extension, notify)
|
||
|
|
|
||
|
|
self.volume = volume
|
||
|
|
self.image = image
|
||
|
|
self.command = command
|
||
|
|
|
||
|
|
def backup(self):
|
||
|
|
# Remove excess backups
|
||
|
|
self.remove_backups()
|
||
|
|
|
||
|
|
# Run actual backup command
|
||
|
|
filename = "{}.{}".format(
|
||
|
|
datetime.now().strftime("%Y-%m-%d_%H-%M-%S"), self.extension
|
||
|
|
)
|
||
|
|
|
||
|
|
process = subprocess.run(
|
||
|
|
"docker run --rm -v '{}:/from' -v '{}:/to' -w /from '{}' {}".format(
|
||
|
|
self.volume,
|
||
|
|
self.destination,
|
||
|
|
self.image,
|
||
|
|
self.command.format(
|
||
|
|
filename=filename,
|
||
|
|
),
|
||
|
|
),
|
||
|
|
shell=True,
|
||
|
|
)
|
||
|
|
|
||
|
|
if self.notifier:
|
||
|
|
self.notifier.notify("backup", self.name, process.returncode)
|