| |
| |
| |
| |
| |
| |
| |
| |
|
|
| |
| |
| |
| import sys |
| import threading |
| import time |
|
|
| sys.path.insert(0, "/www/server/panel/class/") |
| sys.path.insert(1, "/www/server/panel/") |
| import public |
| from btdockerModel import dk_public as dp |
| from btdockerModel import containerModel as dc |
| from btdockerModel import statusModel as ds |
| from btdockerModel import imageModel as di |
|
|
|
|
| class main: |
| __save_date = None |
| __day_sec = 86400 |
|
|
| def __init__(self, save_date): |
| if not save_date: |
| self.__save_date = 30 |
| else: |
| self.__save_date = save_date |
|
|
| def docker_client(self, url): |
| return dp.docker_client(url) |
|
|
| def get_all_host_stats(self, fun): |
| """ |
| 获取所有主机信息并获取该主机下的容器状态 |
| :param fun: 需要调用的方法，用于获取并记录容器状态 |
| :return: |
| """ |
| hosts = dp.sql('hosts').select() |
| for i in hosts: |
| t = threading.Thread(target=fun, args=(i,)) |
| t.setDaemon(True) |
| t.start() |
|
|
| |
| def container_status_for_all_hosts(self): |
| """ |
| 获取所有服务器的容器数量 |
| :return: |
| """ |
| |
| args = public.to_dict_obj({}) |
| container_list = dc.main().get_list(args) |
| for c in container_list['container_list']: |
| args.id = c['id'] |
| args.write = 1 |
| args.save_date = self.__save_date |
| ds.main().stats(args) |
| |
|
|
| |
| def container_count(self): |
| |
| hosts = dp.sql('hosts').select() |
| n = 0 |
| for i in hosts: |
| args = public.to_dict_obj({}) |
| args.url = i['url'] |
| container_list = dc.main().get_list(args) |
| n += len(container_list) |
| pdata = { |
| "time": int(time.time()), |
| "container_count": n |
| } |
| expired = time.time() - (self.__save_date * self.__day_sec) |
| dp.sql("container_count").where("time<?", (expired,)).delete() |
| dp.sql("container_count").insert(pdata) |
| |
|
|
| def image_for_all_host(self): |
| |
| hosts = dp.sql('hosts').select() |
| num = 0 |
| size = 0 |
| for i in hosts: |
| args = public.to_dict_obj({}) |
| args.url = i['url'] |
| res = di.main().image_for_host(args) |
| num += res['num'] |
| size += res['size'] |
| pdata = { |
| "time": int(time.time()), |
| "num": num, |
| "size": int(size) |
| } |
| expired = time.time() - (self.__save_date * self.__day_sec) |
| dp.sql("image_infos").where("time<?", (expired,)).delete() |
| dp.sql("image_infos").insert(pdata) |
| |
|
|
|
|
| def monitor(): |
| |
| while True: |
| save_date = dp.docker_conf()['SAVE'] |
| m = main(save_date) |
| m.get_all_host_stats(m.container_status_for_all_hosts) |
| |
| t = threading.Thread(target=m.container_count) |
| t.setDaemon(True) |
| t.start() |
| |
| t = threading.Thread(target=m.image_for_all_host) |
| t.setDaemon(True) |
| t.start() |
| time.sleep(60) |
| |
| |
| |
|
|
|
|
| if __name__ == "__main__": |
| monitor() |
|
|
