使用Kubernetes Python客户端无法扩容指定Pod副本数问题排查

我用AWS EKS管理K8s集群中的应用，mytenantspace命名空间下的my-core-pod里运行着Python Flask应用，我写了create_infra接口接收POST请求，用来扩容myenvspace命名空间下my-daemon-service-pod的副本数。

当前环境：

• 已安装kubectl，.kube/config配置正确
• 使用Python 3.8和28.1.0版本的Kubernetes客户端，能正常连接集群并列出所有Pod和命名空间

以下是我实现扩容的代码：

#code running in the `my-core-pod` in the namespace `mytenantspace`
from  kubernetes import client, config
config.load_kube_config()
v1 = client.CoreV1Api()

@app.route("/create_infra", methods=["POST"])
def create_pod():
    number_pods = 3
    pod_name = "my-daemon-service-pod"
    namespace = "myenvspace"

    # Get the existing pod's template.
    existing_pod = v1.read_namespaced_pod(pod_name, namespace)

    #Clear the resourceVersion to avoid the error.
    existing_pod.metadata.resource_version = None

    # Create new pods based on the existing pod's template.
    for i in range(number_pods):
        new_pod_name = f"{pod_name}-replica-{i}"
        new_pod = existing_pod
        new_pod.metadata.name = new_pod_name
        new_pod.metadata.uid = None  # Clear the UID to ensure a unique pod is created.

        # Create the new pod replica.
        v1.create_namespaced_pod(namespace, new_pod)

执行代码后无报错，控制台返回大量JSON响应，但Pod并未实现扩容，需要排查代码问题并确认是否用对了API。

核心问题分析 #

1. 对象引用复用冲突：代码中new_pod = existing_pod是直接引用同一个对象，循环中修改new_pod.metadata.name时，实际是在修改原始existing_pod对象的属性，导致后续循环创建的Pod都使用最后一次修改后的对象，甚至可能因元数据重复创建失败。
2. API使用不符合K8s设计理念：直接创建Pod不是扩容应用的正确方式。K8s中应通过Deployment、StatefulSet或DaemonSet这类控制器管理Pod副本，手动创建的Pod无控制器兜底，故障后无法自动重建，也不符合“扩容”的本质需求。如果my-daemon-service-pod是DaemonSet的一部分，手动创建Pod会脱离控制器管理，完全违背DaemonSet的调度逻辑。
3. 元数据清理不完整：除resourceVersion和uid外，creationTimestamp、selfLink等自动生成的元数据未清理，可能导致K8s API拒绝请求。

修正方案 #

方案1：通过控制器扩容（推荐） #

如果my-daemon-service-pod由Deployment管理，正确做法是修改Deployment的副本数：

from kubernetes import client, config
config.load_kube_config()
apps_v1 = client.AppsV1Api()

@app.route("/create_infra", methods=["POST"])
def scale_deployment():
    target_replicas = 3  # 可改为从请求参数动态获取
    deployment_name = "my-daemon-service-deployment"  # 替换为实际Deployment名称
    namespace = "myenvspace"

    # 获取当前Deployment配置
    deployment = apps_v1.read_namespaced_deployment(deployment_name, namespace)
    # 修改副本数
    deployment.spec.replicas = target_replicas
    # 更新Deployment
    apps_v1.patch_namespaced_deployment(deployment_name, namespace, deployment)
    
    return f"Deployment {deployment_name} 已扩容至 {target_replicas} 个副本"

方案2：修复手动创建Pod的代码（仅调试用，不推荐） #

若必须手动创建Pod副本，需深拷贝原始对象并清理所有自动生成元数据：

from kubernetes import client, config
import copy  # 引入深拷贝模块

config.load_kube_config()
v1 = client.CoreV1Api()

@app.route("/create_infra", methods=["POST"])
def create_pod():
    number_pods = 3
    pod_name = "my-daemon-service-pod"
    namespace = "myenvspace"

    # 获取现有Pod
    existing_pod = v1.read_namespaced_pod(pod_name, namespace)

    for i in range(number_pods):
        # 深拷贝原始Pod对象，避免引用复用
        new_pod = copy.deepcopy(existing_pod)
        
        # 清理所有自动生成的元数据
        new_pod.metadata.name = f"{pod_name}-replica-{i}"
        new_pod.metadata.uid = None
        new_pod.metadata.resource_version = None
        new_pod.metadata.creation_timestamp = None
        new_pod.metadata.self_link = None
        new_pod.metadata.annotations = None  # 可选：清理原有注解
        new_pod.metadata.labels = copy.deepcopy(new_pod.metadata.labels)  # 保留标签但深拷贝
        
        # 创建新Pod
        v1.create_namespaced_pod(namespace, new_pod)
    
    return f"已创建 {number_pods} 个Pod副本"

额外说明 #

• 优先使用控制器管理Pod，这是K8s的核心设计理念，能保证应用的高可用性和可维护性。
• 如果my-daemon-service-pod是DaemonSet的一部分，DaemonSet的副本数由集群节点数决定，手动修改副本数无效，需调整DaemonSet的节点选择器或污点容忍度来控制Pod分布。

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