如何定期运行自定义Kubernetes调度器以重新调度Pod？

核心逻辑 #

Kubernetes原生调度流程仅针对新创建的Pod，要让你的自定义调度器对已有Pod进行重调度，需要搭配重调度控制器完成：定期评估集群内Pod的节点适配性，对不符合最优规则的Pod发起驱逐，让自定义调度器重新为其分配节点。

具体实现步骤 #

1. 开发自定义重调度控制器 #

需编写一个控制器（推荐用Go基于client-go，或Python用kubernetes-client），核心逻辑如下：

• 遍历集群内所有运行中的Pod，排除DaemonSet、静态Pod、有PDB保护且无法驱逐的Pod
• 复用你的自定义调度器的决策逻辑，评估Pod当前所在节点是否仍满足调度规则（如资源阈值、自定义亲和性/反亲和性等）
• 对需要迁移的Pod，调用Kubernetes API执行驱逐操作

驱逐Pod的API调用示例（Go client-go片段）：

evict := &policyv1.Eviction{
    ObjectMeta: metav1.ObjectMeta{
        Name:      pod.Name,
        Namespace: pod.Namespace,
    },
}
err := kubeClient.PolicyV1().Evictions(pod.Namespace).Create(context.TODO(), evict, metav1.CreateOptions{})

2. 确保自定义调度器接管重调度Pod #

如果你的新Pod已经指定了自定义调度器（spec.schedulerName: your-custom-scheduler），那么被驱逐后重建的Pod会自动使用同一个调度器。若存在使用默认调度器的Pod，需修改其schedulerName字段指向你的自定义调度器。

3. 实现定期触发机制 #

有两种常见的定期触发方式：

• 控制器内置定时任务：在重调度控制器中加入定时逻辑（如Go的time.Ticker），按设定间隔执行检查
• Kubernetes CronJob：将重调度逻辑打包成镜像，用CronJob定期运行，适合轻量场景

示例CronJob配置（每天凌晨1点执行重调度）：

apiVersion: batch/v1
kind: CronJob
metadata:
  name: custom-rescheduler
spec:
  schedule: "0 1 * * *"
  jobTemplate:
    spec:
      template:
        spec:
          serviceAccountName: rescheduler-sa # 需配置权限：读取Pod/节点、执行evict操作
          containers:
          - name: rescheduler
            image: your-rescheduler-image # 包含重调度逻辑的镜像
            command: ["/app/run-rescheduler"]
          restartPolicy: OnFailure

4. 关键注意事项 #

• 控制调度频率：避免过于频繁的重调度导致集群不稳定，根据业务场景设置合理的检查间隔
• 尊重PDB限制：驱逐前必须检查Pod对应的PodDisruptionBudget，确保驱逐操作不会违反可用性约束
• 优先级分级：可给Pod添加自定义标签，实现分级重调度，优先处理资源紧张或不符合核心规则的Pod
• 监控与日志：为重调度控制器添加监控指标（如重调度次数、驱逐成功率）和详细日志，便于问题排查

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