基于Python Docker SDK，如何为Docker Exec创建独立的stdout/stderr套接字？

我正在开发一个可运行多语言代码的网站，选用Docker来隔离进程、网络及文件系统。常规Docker使用流程如下：

• 创建具备所需环境的容器（调用client.containers.run）
• 为每个步骤执行独立的exec操作（第一步编译，第二步运行）
• 分析每个步骤的进程返回码、stdout和stderr

我遇到的问题是：每个步骤中，获取的用于读写运行中exec的套接字会混合stdout与stderr。了解到attach_socket方法可连接多个套接字，但该方法仅适用于运行中的容器（docker run），请问如何为Docker Exec创建独立的套接字？

我的具体代码流程：

1. 创建容器

# 启动编译器容器，让其保持运行
self.container = client.containers.run(
            'python:3.10',
            command=f"sleep infinity",
            working_dir='/app',
            volumes=[f'{Path(self.folder.name)}:/app'],
            tty=True,
            detach=True,
            network_disabled=True,
        )

2. 创建exec

self.exec['Id'] = client.api.exec_create(self.container.id, command, tty=True, stdin=True)

3. 运行exec，返回读写套接字

self.socket = client.api.exec_start(self.exec['Id'], socket=True, tty=True, demux=True)

我希望使用attach_socket方法，但它仅适用于容器（self.container.id）而非exec命令（self.exec['Id']）。是否有办法分别连接两个套接字，一个用于stdout，一个用于stderr？

解决方案：利用demux=True分离流，而非创建独立套接字 #

Docker Exec API本身并不支持为stdout和stderr创建独立的套接字，但你可以通过exec_start的demux=True参数来分离这两个流，不需要额外的套接字。

你的代码里已经设置了demux=True，但可能没正确处理返回的流。当启用demux时，exec_start返回的套接字会返回二元组：第一个元素是stdout的字节数据，第二个是stderr的字节数据。你可以通过循环读取套接字来区分两者：

import docker

# 假设已经初始化了client和创建了container、exec_id
exec_id = self.exec['Id']
socket = client.api.exec_start(exec_id, socket=True, tty=False, stdin=True, demux=True)

try:
    while True:
        data = socket.recv(4096)
        if not data:
            break
        stdout, stderr = data
        if stdout:
            print(f"STDOUT: {stdout.decode('utf-8')}")
        if stderr:
            print(f"STDERR: {stderr.decode('utf-8')}")
finally:
    socket.close()

注意这里要把tty=True改为tty=False——当启用TTY时，Docker会把stdout和stderr合并成一个流，demux=True会失效。因为TTY模式下，容器内的进程会把所有输出都发送到同一个伪终端，无法区分流。

额外提示 #

• 如果需要保留TTY（比如需要交互式输入），那确实无法分离stdout和stderr，这是TTY的特性导致的。这种情况下只能通过解析输出内容来区分，但可靠性很低。
• 如果你需要更精细的流控制，可以考虑在容器内执行命令时，将stderr重定向到一个文件，然后单独读取该文件内容：

  # 创建exec时，将stderr重定向到容器内的临时文件
  exec_id = client.api.exec_create(
      self.container.id,
      f"{command} 2>/tmp/stderr.log",
      tty=False,
      stdin=True
  )
  # 执行exec并获取stdout
  stdout = client.api.exec_start(exec_id, socket=False).decode('utf-8')
  # 读取stderr文件内容
  stderr = self.container.exec_run(f"cat /tmp/stderr.log").output.decode('utf-8')
  

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