性能展现
代码展现app.py#! /usr/bin/env python3# -*- coding:utf-8 -*-from flask import Flask, request, render_template, redirect, url_for, make_response ,escape, session, flash, g, current_app, abort, jsonify, send_fileimport requests#from werkzeug.utils import secure_filenameimport os,time, platformfrom flask_wtf import Form#from wtforms import TextField#from shell import os_scrpict, harbor#import sqlite3#from pathlib import Pathfrom flask_sqlalchemy import SQLAlchemyapp = Flask(__name__)# 本脚本只是harbor页面tags清理# cd /usr/local/src/harbor && docker-compose stop #敞开harbor# 物理清理：docker run -it --name gc --rm --volumes-from registry goharbor/registry-photon:v2.6.2-v1.6.3 garbage-collect /etc/registry/config.yml#docker-compose up -d #启动class RequestClient(object): def __init__(self, login_url, username, password): self.username = username self.password = password self.login_url = login_url self.session = requests.Session() self.login() def login(self): requests.packages.urllib3.disable_warnings() self.session.post(self.login_url, params={"principal": self.username, "password": self.password}, verify=False)class ClearHarbor(object): def __init__(self, harbor_domain, username, password, num, schema="http", ): self.num = num self.schema = schema self.harbor_domain = harbor_domain self.harbor_url = self.schema + "://" + self.harbor_domain self.login_url = self.harbor_url + "/login" self.api_url = self.harbor_url + "/api" self.pro_url = self.api_url + "/projects" self.repos_url = self.api_url + "/repositories" self.username = username self.password = password self.client = RequestClient(self.login_url, self.username, self.password) def __fetch_pros_obj(self): # 获取所有项目名称 self.pros_obj = self.client.session.get(self.pro_url).json() # for n in self.pros_obj: # print("分组：",n.get("name")) print(self.pros_obj) return self.pros_obj def get_pros_id(self): # 获取所有我的项目ID self.pros_id = [] pro_res = self.__fetch_pros_obj() for i in pro_res: self.pros_id.append(i['project_id']) # print("所有我的项目ID：",self.pros_id) return self.pros_id def get_del_repos_name(self, pro_id): # 镜像tag数量大于self.num的镜像仓库名称 self.del_repos_name = [] repos_res = self.client.session.get(self.repos_url, params={"project_id": pro_id}) # print("我的项目信息：",repos_res.json()) for repo in repos_res.json(): if repo["tags_count"] > self.num: # print("镜像仓库名称：",repo['name']) self.del_repos_name.append(repo['name']) return self.del_repos_name def fetch_del_repos(self, repo_name): # 删除镜像仓库tag self.del_res = [] tag_url = self.repos_url + "/" + repo_name + "/tags" # 我的项目镜像仓库的所有tags,按创立工夫排序 tags = self.client.session.get(tag_url).json() tags_sort = sorted(tags, key=lambda a: a["created"]) # print(len(tags_sort),tags_sort) # 除了最新的self.num个，其余的tag都增加到待删除列表del_tags del_tags = tags_sort[0:len(tags_sort) - self.num] # print(del_tags) for tag in del_tags: del_repo_tag_url = tag_url + "/" + tag['name'] # print(del_repo_tag_url) del_res = self.client.session.delete(del_repo_tag_url) self.del_res.append("镜像: %s 删除状态: %s" % (del_repo_tag_url,del_res)) return self.del_res def work(self): # 遍历project id for i in self.get_pros_id(): # 获取所有tag超过self.num的repos repos = self.get_del_repos_name(i) if repos: for repo in repos: del_repos = self.fetch_del_repos(repo) print(del_repos) print(repo) def list_repositories(self, pro_id): # 镜像tag数量大于self.num的镜像仓库名称 self.del_repos_name1 = [] repos_res = self.client.session.get(self.repos_url, params={"project_id": pro_id}) # print("我的项目信息：",repos_res.json()) for repo in repos_res.json(): #if repo["tags_count"] > self.num: #print(repo,"镜像仓库名称：",repo['name']) #self.del_repos_name1.append({"name": repo["name"], "tags_count": repo["tags_count"]}) self.del_repos_name1.append({"name": repo["name"], "tags_count": repo["tags_count"],"project_id": repo["project_id"]}) #print(self.del_repos_name1) return self.del_repos_name1 def list_pros(self): # 获取所有我的项目ID self.pros_idname = [] pro_res = self.__fetch_pros_obj() for i in pro_res: self.pros_idname.append({"project_id": i["project_id"], "name": i["name"], "repo_count": i["repo_count"] }) #print(self.pros_idname) #print(self.pros_idname[0]['name']) return self.pros_idname def work_list(self, pros_id_list): # 遍历project id for i in pros_id_list: # 获取所有tag超过self.num的repos repos = self.get_del_repos_name(i) if repos: for repo in repos: # del_repos = self.fetch_del_repos(repo) # print(del_repos) print(repo)@app.route('/harbor/', methods = ['GET', 'POST'])def harbor_list(): del_images_tag = ClearHarbor(harbor_domain="172.16.167.11", username="admin", password="Harbor12345", num=10) harbor_project = del_images_tag.list_pros() print("###########",harbor_project) return render_template('harbor.html', harbor_project1 = harbor_project)@app.route('/del_harbor_project_all/')def del_harbor_project_all1(): del_images_tag = ClearHarbor(harbor_domain="172.16.167.11", username="admin", password="Harbor12345", num=10) del_images_tag.work() return redirect('/harbor/')@app.route('/del_harbor_project/<int:project_id>')def del_harbor_project(project_id): del_images_tag = ClearHarbor(harbor_domain="172.16.167.11", username="admin", password="Harbor12345", num=10) del_reposname = del_images_tag.get_del_repos_name(project_id) print(del_reposname,"#####################",project_id) del_reposname_status = del_images_tag.fetch_del_repos(del_reposname) print(del_reposname_status) return redirect('/harbor/')@app.route('/del_harbor_project_list/', methods = ['GET', 'POST'])def del_harbor_project_list(): if request.method == 'POST': project_id_list = request.form.getlist('vals') #print(project_id_list) vals_list2 = [] for i in project_id_list: if i == '': print("i is none") else: vals_list2.append(i) del_images_tag = ClearHarbor(harbor_domain="172.16.167.11", username="admin", password="Harbor12345", num=10) del_images_tag.work_list(vals_list2) return redirect('/harbor/')@app.route('/harbor_repositories/<int:project_id>')def harbor_repositoriest(project_id): del_images_tag = ClearHarbor(harbor_domain="192.168.1.17", username="admin", password="xxxxxx", num=10) harbor_project = del_images_tag.list_repositories(project_id) print("###########",harbor_project) return render_template('harbor_repositories.html', harbor_project1 = harbor_project)@app.route('/del_repositories_url/<int:project_id>/<path:project_name>')def del_repositories_url(project_id,project_name): del_images_tag = ClearHarbor(harbor_domain="192.168.1.17", username="admin", password="xxxxxx", num=10) del_reposname_status = del_images_tag.fetch_del_repos(project_name) print(del_reposname_status) return redirect('/harbor_repositories/{tproject_id}'.format(tproject_id=project_id))if __name__ == '__main__': app.run() #app.run(host="172.16.117.33",port=5888)harbor.html<!DOCTYPE html><html lang="en"><head> <meta charset="UTF-8"> <title>Title</title></head><body> <script src="/static/jquery-1.9.1.min.js"></script> <script> $('#out').click(function () { $.ajax({ url: '/dns_list/', type: 'GET', data: {}, success: function (data) { //期待解决完结主动调用，data-返回值 console.log(data); window.location.href = "url" } }) }); $('#back').click(function () { $.ajax({ url: '/dns_list/', type: 'GET', data: {}, success: function (data) { window.location.href = "/" } }) });function getValues_del_project() { var valArr=[]; var ones=document.getElementsByName('item'); for (var i=0;i<ones.length;i++){ if (ones[i].checked==true){ valArr[i]=ones[i].value } } if (valArr.length!=0){ // var vals = valArr.join(','); // alert(valArr); // var url2 = '/app_intstall/' $.ajax({ url:"/del_harbor_project_list/", type:'POST', contenType:'application/json',// #不加这个，ajax会将后果后边加个[]，例如{'vals[]':[4,6,8]} traditional:true,// #不加这个，会报服务器终止了一个在运行的程序 async: false, data:{ 'vals':valArr }, success:function(){ alert("批量革除project 超过10个 tag 胜利"); // window.location.href =url2 }, error:function(){ alert("批量革除project 超过10个 tag 失败"); } }) } else { var error_m="请抉择数据"; alert(error_m); }} </script> <div class="container" style="position: absolute;left: -2%;width: 1590px;height: 850px;margin-left: 95px;"> <h2>harbor</h2> <div style="float: left; width:190px;height:70px"> <ul class='myul'> <li><a class="btn btn-success input-sm" href="/harbor/" onclick="getValues_del_project()"> 批量革除选中我的项目images </a> </li> </ul> </div> <div style="float: left; width:290px;height:40px;display:block;overflow-y:auto;"> <ul class='myul'> <li> <a class="btn btn-primary input-sm" href="/del_harbor_project_all/"> 革除all project >10 tag images </a> </li> </ul> </div> {# <div style="position: absolute;top: 12%;left: 65%;width: 590px;height: 650px;">#} {# <p>text： <textarea rows="41" cols="80" name="conftext"> {{ conflook.conflook }} </textarea></p>#} {# </div>#} <table class="table table-condensed" id="table1"> <thead> <tr> <th width="25"><input id="checkAll" onclick="checkAll()" type="checkbox"></th> <th>ID</th> <th>我的项目</th> <th>镜像仓库数</th> <th>操作</th> </tr> </thead> <tbody> {% for ele in harbor_project1 %} <tr> <td><input name="item" onclick="checkOne()" type="checkbox" value="{{ele.project_id}}"></td> <td>{{ ele.project_id }}</td> <td><a href="/harbor_repositories/{{ ele.project_id }}"> {{ ele.name }}</a></td> <td>{{ ele.repo_count }} </td> <td><a href="/del_harbor_project/{{ ele.project_id }}"> 革除 </a></td> </tr> {% endfor %} </tbody> </table> </div></body></html>harbor_repositories.html<!DOCTYPE html><html lang="en"><head> <meta charset="UTF-8"> <title>Title</title></head><body> <script src="/static/jquery-1.9.1.min.js"></script> <script> $('#out').click(function () { $.ajax({ url: '/dns_list/', type: 'GET', data: {}, success: function (data) { //期待解决完结主动调用，data-返回值 console.log(data); window.location.href = "url" } }) }); $('#back').click(function () { $.ajax({ url: '/dns_list/', type: 'GET', data: {}, success: function (data) { window.location.href = "/" } }) });function getValues_del_repositories() { var valArr=[]; var ones=document.getElementsByName('item'); for (var i=0;i<ones.length;i++){ if (ones[i].checked==true){ valArr[i]=ones[i].value } } if (valArr.length!=0){ // var vals = valArr.join(','); // alert(valArr); // var url2 = '/app_intstall/' $.ajax({ url:"/del_harbor_repositories_list/", type:'POST', contenType:'application/json',// #不加这个，ajax会将后果后边加个[]，例如{'vals[]':[4,6,8]} traditional:true,// #不加这个，会报服务器终止了一个在运行的程序 async: false, data:{ 'vals':valArr }, success:function(){ alert("批量革除image 超过10个 tag 胜利"); // window.location.href =url2 }, error:function(){ alert("批量革除image 超过10个 tag 失败"); } }) } else { var error_m="请抉择数据"; alert(error_m); }} </script> <div class="container" style="position: absolute;left: -2%;width: 1590px;height: 850px;margin-left: 95px;display:block;overflow-y:auto;"> <h2>harbor</h2> {# <div style="position: absolute;top: 12%;left: 65%;width: 590px;height: 650px;">#} {# <p>text： <textarea rows="41" cols="80" name="conftext"> {{ conflook.conflook }} </textarea></p>#} {# </div>#} <table class="table table-condensed" id="table1" > <thead> <tr> <th width="25"><input id="checkAll" onclick="checkAll()" type="checkbox"></th> <th>我的项目</th> <th>标签数</th> <th>操作</th> </tr> </thead> <tbody> {% for ele in harbor_project1 %} <tr> <td><input name="item" onclick="checkOne()" type="checkbox" value="{{ele.name}}"></td> <td> {{ ele.name }}</td> <td>{{ ele.tags_count }} </td> <td><a href="/del_repositories_url/{{ ele.project_id }}/{{ ele.name }}"> 革除 </a></td> </tr> {% endfor %} </tbody> </table> </div></body></html>