| |
| |
| |
| |
| |
| |
| |
| |
| import os |
| import time |
| import traceback |
|
|
| |
| |
| |
| import public |
| from btdockerModel import containerModel as dc |
| from btdockerModel import dk_public as dp |
| from btdockerModel.dockerBase import dockerBase |
|
|
|
|
| class main(dockerBase): |
|
|
| |
| def backup_volume(self, get): |
| ''' |
| @name 备份指定容器的mount volume |
| @author wzz <2023/12/22 上午 11:19> |
| @param "data":{"container_id":"容器ID"} |
| @return dict{"status":True/False,"msg":"提示信息"} |
| ''' |
| try: |
| client = dp.docker_client() |
| container = client.containers.get(get.container_id) |
| volume_list = container.attrs["Mounts"] |
| volume_list = [v["Source"] for v in volume_list] |
|
|
| if not volume_list: |
| return public.returnMsg(False, "没有可备份的volume") |
|
|
| backup_path = "/www/backup/btdocker/volumes/{}".format(container.name) |
| if not os.path.exists(backup_path): |
| os.makedirs(backup_path, 0o755) |
|
|
| import subprocess |
| public.ExecShell("echo -n > {}".format(self._backup_log)) |
|
|
| for v in volume_list: |
| backup_name = os.path.basename(v) |
| |
| tar_name = "{}_{}_{}.tar.gz".format( |
| container.name, |
| backup_name, |
| time.strftime("%Y%m%d_%H%M%S", time.localtime()) |
| ) |
| backup_file = os.path.join(backup_path, tar_name) |
| source_path = os.path.dirname(v) |
| cmd = "cd {} && tar zcvf {} {}".format(source_path, backup_file, backup_name) |
| cmd = ("nohup echo '开始备份容器{}的{},可能需要等待1-5分钟以上...' >> {};" |
| "{} >> {} 2>&1 &&" |
| "echo 'bt_successful' >> {} || echo 'bt_failed' >> {} &" |
| .format( |
| container.name, |
| tar_name, |
| self._backup_log, |
| cmd, |
| self._backup_log, |
| self._backup_log, |
| self._backup_log, |
| )) |
| subprocess.Popen(cmd, shell=True) |
|
|
| |
| dp.sql('dk_backup').add( |
| 'type,name,container_id,container_name,filename,size,addtime', |
| (3, tar_name, container.id, container.name, backup_file, 0, time.strftime( |
| "%Y-%m-%d %H:%M:%S", time.localtime() |
| )) |
| ) |
| public.WriteLog("Docker模块", "备份容器{}的{}成功！".format(container.name, tar_name)) |
|
|
| return public.returnMsg(True, "创建备份任务成功，请等待目录备份完成，可能需要1分钟以上！") |
| except Exception as e: |
| print(traceback.format_exc()) |
| return public.returnMsg(False, "创建备份任务失败{}".format(str(e))) |
|
|
| |
| def get_backup_list(self, get): |
| ''' |
| @name 获取指定容器的备份列表 |
| @param "data":{"container_id":"容器ID"} |
| @return list[dict{"":""}] |
| ''' |
| try: |
| |
| backup_list = dp.sql('dk_backup').where('container_id=?', (get.container_id,)).field( |
| 'name,container_id,container_name,filename,size,addtime' |
| ).select() |
|
|
| for l in backup_list: |
| if not os.path.exists(l['filename']): |
| l['size'] = 0 |
| l['ps'] = '文件不存在' |
| continue |
|
|
| l['size'] = os.path.getsize(l['filename']) |
| l['ps'] = '本地备份' |
|
|
| return backup_list |
|
|
| except Exception as e: |
| print(traceback.format_exc()) |
| return [] |
|
|
| |
| def remove_backup(self, get): |
| ''' |
| @name 删除指定容器的备份 |
| @param "data":{"container_id":"容器ID","container_name":"容器名","name":"文件名"} |
| @return dict{"status":True/False,"msg":"提示信息"} |
| ''' |
| try: |
| |
| dp.sql('dk_backup').where('container_id=? and name=?', (get.container_id, get.name)).delete() |
|
|
| |
| backup_path = "/www/backup/btdocker/volumes/{}".format(get.container_name) |
| file_path = os.path.join(backup_path, get.name) |
| if not os.path.exists(file_path): |
| return public.returnMsg(True, "删除成功") |
| os.remove(file_path) |
| return public.returnMsg(True, "删除成功") |
| except Exception as e: |
| print(traceback.format_exc()) |
| return public.returnMsg(False, "删除文件{}失败,原因：{}".format(get.name, str(e))) |
|
|
| def get_pull_log(self, get): |
| """ |
| 获取镜像拉取日志，websocket |
| @param get: |
| @return: |
| """ |
| get.wsLogTitle = "开始进行容器目录备份,请等待..." |
| get._log_path = self._backup_log |
| return self.get_ws_log(get) |
