使用Kubernetes Python客户端调用connect_get_namespaced_pod_exec报错503如何解决

一、核心错误根因（对应报错failed CONNECT via proxy status: 503） #

• 网络代理不兼容：K8s exec操作底层依赖WebSocket协议，你运行代码的环境配置的HTTP/HTTPS代理不支持WebSocket的CONNECT请求，就会返回503错误。
• 集群权限配置缺失：你所用的K8s上下文对应的身份，没有pods/exec资源的create权限，请求被apiserver或前置网关拦截也会返回该错误。

二、代码本身的明显问题 #

• 变量名拼写错误：你定义的exec返回对象是res，读取stderr时写为resp.peek_stderr()，运行到此处会直接抛出NameError。
• sh -c命令格式错误：用sh -c执行命令时，后续完整指令必须是单个字符串，你当前写成['sh','-c', 'nslookup', tstfqdn]的格式，实际只会执行无参数的nslookup，不会传入域名参数。
• 不必要的TTY配置：你未开启stdin却设置了tty=True，无交互需求的exec场景建议关闭TTY，避免额外的协议协商错误。

三、修正后的核心代码片段 #

for tstfqdn in TEST_FQDNS:
    pod = whois_pods[0]['name']
    # 修正sh -c命令格式
    whois_command = ['sh','-c', f'nslookup {tstfqdn}']
    res = stream(k8conn.connect_get_namespaced_pod_exec,
    name=pod, namespace='kube-system',
    command=whois_command, container='whois',
    stderr=True, stdin=False,
    stdout=True, tty=False) # 关闭不必要的TTY
    while res.is_open():
        if res.peek_stdout():
            print("STDOUT: %s" % res.read_stdout())
        if res.peek_stderr(): # 修正变量拼写错误
            print("STDERR: %s" % res.read_stderr())

四、代理问题快速验证方案 #

运行代码前先执行以下命令，将K8s apiserver地址加入跳过代理的列表：

# 将尖括号内容替换为你实际的K8s apiserver域名/IP
export NO_PROXY=$NO_PROXY,<你的K8s apiserver地址>
export no_proxy=$no_proxy,<你的K8s apiserver地址>

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