通过阅读测试，我猜链接的文档中已经包含了您的答案。
应使用以下命令完成调用：

api.connect_get_namespaced_pod_exec('pod',
                                   'namespace',
                                    command='/bin/bash'
                                    stderr=True,
                                    stdin=True,
                                    stdout=True,
                                    tty=True)

字符串
相关的kubectl exec --tty ... x1e0f01x以相同的方式实现，也可用作参考。

import sys,os
sys.path.append(os.getcwd())
import lib.debug as debug
debug.init()
from threading import Thread
import shared.kube as kube
from kubernetes.stream import stream
import tty 
import termios
core_api = kube.get_client().get_core_api()
#open stream
resp = stream(core_api.connect_get_namespaced_pod_exec,
                          "nsctl-0",
                          "gs-cluster",
                          command="/bin/bash",
                          stderr=True,
                          stdin=True,
                          stdout=True,
                          tty=True, _preload_content=False)
#redirect input
def read():
    #resp.write_stdin("stty rows 45 cols 130\n")
    while resp.is_open():
        char = sys.stdin.read(1)
        resp.update()
        if resp.is_open():
            resp.write_stdin(char)
t = Thread(target=read, args=[])
#change tty mode to be able to work with escape characters
stdin_fd = sys.stdin.fileno()
old_settings = termios.tcgetattr(stdin_fd)
try:
    tty.setraw(stdin_fd)
    t.start()
    while resp.is_open():
        data = resp.read_stdout(10)
        if resp.is_open():
            if len(data or "")>0:
                sys.stdout.write(data)
                sys.stdout.flush()
finally:
    #reset tty 
    print("\033c")
    termios.tcsetattr(stdin_fd, termios.TCSADRAIN, old_settings)
    print("press enter")

字符串