Kubernetes Node删除镜像的实现步骤

$ ssh user@node-ip

$ docker image ls

$ docker image rm <image-name>:<tag>

$ docker image ls

$ pip install kubernetes

from kubernetes import client, config
def delete_node_image(node_name, image_name):
    # 加载Kubernetes配置
    config.load_kube_config()
    # 创建Kubernetes API客户端
    kube_client = client.CoreV1Api()
    # 获取节点信息
    node = kube_client.read_node(node_name)
    # 获取节点上正在运行的Pod列表
    field_selector = f"spec.nodeName={node_name}"
    pods = kube_client.list_pod_for_all_namespaces(field_selector=field_selector)
    # 根据给定的镜像名称过滤出需要删除的Pod
    delete_pods = []
    for pod in pods.items:
        for container in pod.spec.containers:
            if container.image == image_name:
                delete_pods.append(pod)
                break
    
    # 删除需要删除的Pod
    for pod in delete_pods:
        kube_client.delete_namespaced_pod(name=pod.metadata.name, namespace=pod.metadata.namespace)
    # 删除节点上的镜像
    for image in node.status.images:
        if image_names_match(image.name, image_name):
            image_names = image_names_except(image.name, image_name)
            kube_client.patch_node(node_name, {"status": {"images": [{"names": image_names}]}})
            break
def image_names_match(image_name, target_image_name):
    # 判断两个镜像名称是否匹配
    # 可根据实际需求进行匹配规则定制
    if image_name == target_image_name or image_name.startswith(target_image_name + ":"):
        return True
    return False
def image_names_except(image_name, target_image_name):
    # 移除列表中的目标镜像名称
    image_names = image_name.split(",")
    image_names = [name.strip() for name in image_names if not image_names_match(name, target_image_name)]
    return image_names
# 示例用法
node_name = "your-node-name"
image_name = "your-image-name:your-tag"
delete_node_image(node_name, image_name)

import sqlite3
def create_table():
    # 连接到数据库，如果不存在则会创建新的数据库
    conn = sqlite3.connect('example.db')
    # 创建一个游标对象
    cursor = conn.cursor()
    # 执行SQL语句创建表
    cursor.execute('''CREATE TABLE IF NOT EXISTS users 
                      (id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT, age INTEGER)''')
    # 提交事务（保存更改）
    conn.commit()
    # 关闭连接
    conn.close()
def insert_user(name, age):
    conn = sqlite3.connect('example.db')
    cursor = conn.cursor()
    # 执行SQL语句插入数据
    cursor.execute('INSERT INTO users (name, age) VALUES (?, ?)', (name, age))
    # 提交事务
    conn.commit()
    conn.close()
def select_users():
    conn = sqlite3.connect('example.db')
    cursor = conn.cursor()
    # 执行SQL语句查询所有数据
    cursor.execute('SELECT * FROM users')
    # 获取所有查询结果
    results = cursor.fetchall()
    # 打印查询结果
    for row in results:
        print("ID:", row[0])
        print("Name:", row[1])
        print("Age:", row[2])
        print("-----------------")
    conn.close()
    
# 示例用法
create_table()
insert_user("Alice", 25)
insert_user("Bob", 30)
select_users()