使用Kubernetes Client在Pod执行命令遇WebSocket 400错误求助

核心错误点排查 #

1. 命令参数格式错误 #

你传入的exec_command = ['nodetool status']格式错误，Kubernetes的exec接口要求命令与参数拆分列表的独立元素。如果把整个命令字符串作为单个元素，容器会将其识别为一个不存在的命令名，进而触发API层面的400错误。正确格式应为：

exec_command = ['nodetool', 'status']

2. 集群上下文不匹配 #

你通过client1（对应cluster1）获取了pod1_name，却用client2（对应cluster2）执行exec操作。cluster2中大概率不存在这个Pod，或Pod所在命名空间在cluster2中不存在，导致API返回400错误。必须确保执行exec的客户端与Pod所在集群一致：

• 若Pod在cluster1中，就用client1调用connect_get_namespaced_pod_exec
• 若需操作cluster2的Pod，需先从cluster2的Pod列表中获取对应cassandra实例名称

3. 命名空间有效性验证 #

确认namespace变量的值在目标集群（如cluster1）中真实存在，且cassandra-0 Pod确实属于该命名空间。可通过以下方式验证：

kubectl --context=<cluster-name> get pods -n <namespace>

修正后的代码示例 #

以下是调整后的完整代码，修复了上述问题：

config.load_kube_config()
configuration.assert_hostname = False

contexts, active_context = config.list_kube_config_contexts()
contexts = [context["name"] for context in contexts]
cluster1 = contexts[0]
cluster2 = contexts[1]

print(f"First cluster is: {cluster1}")
print(f"Second cluster is: {cluster2}")

# 初始化集群客户端
client1 = client.CoreV1Api(api_client=config.new_client_from_config(context=cluster1))
client2 = client.CoreV1Api(api_client=config.new_client_from_config(context=cluster2))

# 从cluster1获取cassandra Pod
namespace = "your-namespace-here"  # 替换为实际命名空间
pod1_name = None
for i in client1.list_namespaced_pod(namespace).items:
    if "cassandra-0" in i.metadata.name:
        pod1_name = i.metadata.name
        print(f"Cassandra Pod Name in {cluster1}: {pod1_name}")

if pod1_name:
    # 使用对应集群的客户端执行命令，拆分命令参数
    exec_command = ['nodetool', 'status']
    resp = stream(client1.connect_get_namespaced_pod_exec,
                  pod1_name,
                  namespace,
                  command=exec_command,
                  stderr=True,
                  stdin=False,
                  stdout=True,
                  tty=False)
    print("Response: " + resp)
    resp.close()
else:
    print(f"cassandra-0 Pod not found in {cluster1}/{namespace}")

额外验证步骤 #

1. 先用kubectl手动测试exec命令，确认集群层面支持该操作：

kubectl --context={cluster1} exec -n {namespace} cassandra-0 -- nodetool status

若此命令能正常输出，说明集群配置无问题，再聚焦代码参数排查。
2. 检查kubeconfig文件的权限与上下文配置，确保当前用户拥有pod/exec的执行权限。

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