如何实现Kubernetes中NodePool B上Pod的定时/随机自动终止？

以下是几种可行的实现方式，可根据自身场景选择：

方法一：修改Pod模板，内置自动终止逻辑 #

直接在Pod的启动流程中加入延迟终止逻辑，适合对Pod配置有控制权的场景：

固定时长终止 #

在Pod主容器的启动命令中，添加延迟退出逻辑（假设业务启动命令为/app/start.sh）：

containers:
- name: app
  image: your-app-image
  command: ["/bin/sh", "-c"]
  args:
  - "/app/start.sh & PID=$!; sleep 3600; kill $PID"

说明：启动业务进程后，休眠1小时（3600秒），随后终止业务进程，Pod会因主容器退出而终止。

随机时长终止（X-Y分钟） #

通过shuf生成随机休眠时长，示例为10-30分钟：

containers:
- name: app
  image: your-app-image
  command: ["/bin/sh", "-c"]
  args:
  - "/app/start.sh & PID=$!; sleep $(shuf -i 600-1800 -n 1); kill $PID"

注意：若基础镜像无shuf命令，需提前安装（Alpine用apk add coreutils，Debian/Ubuntu用apt-get install coreutils），可通过init容器预安装或更换包含该命令的基础镜像。

方法二：自定义控制器（推荐生产环境） #

编写Kubernetes自定义控制器，监控运行在NodePool B上的Pod，自动计算随机终止时间并执行删除操作：

1. 标记NodePool B节点：给NodePool B的所有节点打上统一标签，比如nodepool=B。
2. 核心逻辑：
   • 监听Pod资源，筛选出spec.nodeName对应节点带有nodepool=B标签的Pod。
   • 对符合条件的Pod，检查是否已通过注解termination-time记录终止时间。
   • 未标记的Pod，生成X-Y分钟内的随机时间，计算具体终止时间并写入注解。
   • 定时检查到达终止时间的Pod，通过K8s API执行删除操作。

简化逻辑示例（伪代码）：

// 筛选B节点池的Pod
func filterBNodePods(pods *v1.PodList) []*v1.Pod {
    var targetPods []*v1.Pod
    for _, pod := range pods.Items {
        node, err := kubeClient.CoreV1().Nodes().Get(context.TODO(), pod.Spec.NodeName, metav1.GetOptions{})
        if err != nil { continue }
        if node.Labels["nodepool"] == "B" {
            targetPods = append(targetPods, &pod)
        }
    }
    return targetPods
}

// 生成10-30分钟后的随机终止时间
func generateRandomTerminationTime() time.Time {
    min := 10 * time.Minute
    max := 30 * time.Minute
    randDuration := min + time.Duration(rand.Int63n(int64(max - min)))
    return time.Now().Add(randDuration)
}

方法三：CronJob定时清理 #

通过Kubernetes CronJob定期执行清理脚本，适合快速落地的场景：

1. 准备包含kubectl和shuf的镜像（可使用官方kubectl镜像）。
2. 编写清理脚本cleanup-b-pods.sh：

#!/bin/sh
# 获取所有运行在B节点池的Pod（节点标签为nodepool=B）
PODS=$(kubectl get pods --all-namespaces -o jsonpath='{range .items[?(@.spec.nodeName in $(kubectl get nodes -l nodepool=B -o jsonpath="{.items[*].metadata.name}"))]}{.metadata.namespace}/{.metadata.name}{"\n"}')

# 为每个Pod生成随机延迟后删除
for POD in $PODS; do
    # 生成10-30分钟的随机秒数
    DELAY=$(shuf -i 600-1800 -n 1)
    echo "计划在$DELAY秒后删除Pod: $POD"
    (sleep $DELAY; kubectl delete pod $POD) &
done

3. 创建CronJob资源：

apiVersion: batch/v1
kind: CronJob
metadata:
  name: cleanup-b-pods
spec:
  schedule: "*/5 * * * *" # 每5分钟执行一次
  jobTemplate:
    spec:
      template:
        spec:
          serviceAccountName: cleanup-sa # 需配置具有Pod删除权限的ServiceAccount
          containers:
          - name: cleanup
            image: bitnami/kubectl:latest
            command: ["/bin/sh", "-c"]
            args: ["/scripts/cleanup-b-pods.sh"]
            volumeMounts:
            - name: scripts
              mountPath: /scripts
          volumes:
          - name: scripts
            configMap:
              name: cleanup-scripts
          restartPolicy: OnFailure

注意：需提前创建具备Pod删除权限的ServiceAccount、Role和RoleBinding。

内容的提问来源于stack exchange，提问作者No1Lives4Ever