File size: 4,224 Bytes
020c337 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 | #coding: utf-8
#-------------------------------------------------------------------
# 宝塔Linux面板
#-------------------------------------------------------------------
# Copyright (c) 2015-2099 宝塔软件(http://bt.cn) All rights reserved.
#-------------------------------------------------------------------
# Author: zouhw <zhw@bt.cn>
#-------------------------------------------------------------------
#------------------------------
# Docker模型
#------------------------------
import public
import projectModel.bt_docker.dk_public as dp
import docker.errors
class main:
__docker_url = None
def docker_client(self,url):
import projectModel.bt_docker.dk_public as dp
return dp.docker_client(url)
def get_container_list(self):
'''
获取容器详情生成列表
@return: list
'''
containers = self.docker_client(self.__docker_url).containers
c_list = containers.list(all=True)
# 获取容器详情生成列表
return [container_info.attrs for container_info in c_list]
def get_volume_container_name(self, volume_detail, container_list):
'''
拼接对应的容器名与卷名
@param volume_detail: 卷字典
@param container_list: 容器详情列表
@return:
'''
for container in container_list:
if not container['Mounts']:
continue
for mount in container['Mounts']:
if "Name" not in mount:
continue
if volume_detail['Name'] == mount['Name']:
volume_detail['container'] = container['Name'].replace("/","")
if 'container' not in volume_detail:
volume_detail['container'] = ''
return volume_detail
def get_volume_list(self,args):
"""
:param args.url: 链接docker的URL
:return:
"""
import projectModel.bt_docker.dk_setup as ds
self.__docker_url = args.url
client = self.docker_client(args.url)
docker_setup = ds.main()
installed = docker_setup.check_docker_program()
service_status = docker_setup.get_service_status()
if not client:
data = {
"volume": [],
"installed": installed,
"service_status": service_status
}
return public.returnMsg(True,data)
volumes = client.volumes
data = {
"volume": self.get_volume_attr(volumes),
"installed": installed,
"service_status": service_status
}
return public.returnMsg(True,data)
def get_volume_attr(self,volumes):
volume_list = volumes.list()
data = list()
container_list = self.get_container_list()
for v in volume_list:
v = self.get_volume_container_name(v.attrs, container_list)
data.append(v)
return data
def add(self,args):
"""
添加一个卷
:param name
:param driver local
:param driver_opts (dict) – Driver options as a key-value dictionary
:param labels str
:return:
"""
self.docker_client(args.url).volumes.create(
name=args.name,
driver=args.driver,
driver_opts=args.driver_opts if args.driver_opts else None,
labels=dp.set_kv(args.labels)
)
dp.write_log("添加存储卷 [{}] 成功！".format(args.name))
return public.returnMsg(True,"添加成功!")
def remove(self,args):
"""
删除一个卷
:param name volume name
:param args:
:return:
"""
try:
obj = self.docker_client(args.url).volumes.get(args.name)
obj.remove()
dp.write_log("删除存储卷 [{}] 成功！".format(args.name))
return public.returnMsg(True,"删除成功")
except docker.errors.APIError as e:
if "volume is in use" in str(e):
return public.returnMsg(False,"存储卷正在使用中，无法删除！")
return public.returnMsg(False,"删除失败！ {}".format(e))
|