删除K8s中已准备就绪但具有较高pod.deletion.cost的pod优先。

要实现删除Kubernetes中已准备就绪但具有较高pod.deletion.cost的Pod优先的功能，可以使用一个自定义的控制器来监视Pod的状态并进行删除操作。下面是一个示例代码，展示了如何使用Python和Kubernetes客户端库进行实现：

from kubernetes import client, config, watch

# 加载Kubernetes配置
config.load_kube_config()

# 创建API客户端
api_client = client.ApiClient()

# 创建CoreV1Api对象
api_instance = client.CoreV1Api(api_client)

# 设置pod.deletion.cost的阈值
deletion_cost_threshold = 100

# 监听Pod事件
w = watch.Watch()
for event in w.stream(api_instance.list_pod_for_all_namespaces):
    pod = event['object']
    if event['type'] == 'MODIFIED':
        # 检查Pod是否已准备就绪
        if pod.status.phase == 'Running' and pod.status.conditions is not None:
            for condition in pod.status.conditions:
                if condition.type == 'Ready' and condition.status == 'True':
                    # 获取pod.deletion.cost注解的值
                    deletion_cost = pod.metadata.annotations.get('pod.deletion.cost', 0)
                    if int(deletion_cost) > deletion_cost_threshold:
                        # 删除Pod
                        api_instance.delete_namespaced_pod(pod.metadata.name, pod.metadata.namespace)
                        print(f"Deleted Pod: {pod.metadata.name} in Namespace: {pod.metadata.namespace}")
                    break
w.stop()

上述代码中，我们使用了Kubernetes官方提供的Python客户端库来与Kubernetes API进行交互。首先，我们加载了Kubernetes的配置，然后创建了一个CoreV1Api对象用于操作Pod。然后，我们设置了一个pod.deletion.cost的阈值，用于确定是否删除Pod。接下来，我们使用watch包来监听Pod事件，并在每个事件中检查Pod的状态。如果Pod已准备就绪并且pod.deletion.cost的值大于阈值，我们就删除该Pod。

请注意，需要安装kubernetes和kubernetes-watch客户端库：

pip install kubernetes
pip install kubernetes-watch

此外，还需要具有适当的Kubernetes集群访问权限以及Pod的控制权限。

请根据实际需求进行自定义调整，并根据项目的规模和复杂性添加错误处理和日志记录等功能。