python - 使用多处理时 paramiko 卡在 _get_channel 处

Question

我有以下代码(使用 paramiko 编写)，它在多处理过程中被调用

       def traffic(q, e):
            e.open()

       def open()
            assert self.closed
            self._channel = self._get_channel()
            self.stdin      = io.TextIOWrapper(CommandStdIn(self._channel))
            self.stdout = self._channel.makefile()
            self.stderr = self._channel.makefile_stderr()

       q = Queue()
       p = Process(target = self.traffic, args = (q, other_args))
       p.start()
       p.join()

没有多重处理，这工作得很好。但对于多处理，它会停止在

 %paramiko.transport-WARNING: Success for unrequested channel! [??]
 %paramiko.transport-ERROR: Channel request for unknown channel 19

它卡在 self._get__channel() 部分。可能是什么原因？

Answer 1

当在另一个进程内建立连接时，子进程会获取与 channel 关联的套接字的副本。发生的情况是，我们有两个对象尝试与单个套接字通信，并且 session 被损坏。在这里解释 Paramiko Sessions Closes Transport in the Child Process和这里 https://github.com/paramiko/paramiko/issues/446