paramiko 结合了 stdout 和 stderr

Question

我正在尝试合并 stdout 和 stderr 的输出。我相信这可以通过 Channel 对象的 set_combine_stderr() 来完成。

这就是我正在做的：

SSH = paramiko.SSHClient()
#I connect and everything OK, then:
chan = ssh.invoke_shell()
chan.set_combine_stderr(True)
chan.exec_command('python2.6 subir.py')
resultado = chan.makefile('rb', -1.)

但是，当我尝试存储结果时出现以下错误（上面的最后一行， chan.makefile() ）：

错误：频道已关闭。

任何帮助将不胜感激

Answer 1

虽然 set_combine_stderr 确实将 stderr 转移到 stdout 流，但它是以混乱的顺序进行的，因此您不会得到您可能得到的结果想要，即按写入顺序组合的行，就像在本地终端窗口中运行命令一样。相反，请使用 get_pty。这将导致服务器通过伪终端运行这些行，使它们按时间顺序排列。

这是一个测试程序 outerr.py，它在 stdout 和 stdin 上交替写入行。假设它位于 llmps@meerkat2 的主目录中。

#!/usr/bin/env python

import sys

for x in xrange(1, 101):
    (sys.stdout, sys.stderr)[x%2].write('This is line #%s, on std%s.\n' %
                (x, ('out', 'err')[x%2]))

现在尝试以下代码来远程运行它：

#!/usr/bin/env python

import paramiko

def connect():
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    ssh.connect('meerkat2', username='llmps', password='..')
    return ssh

def runTest(ssh):
    tran = ssh.get_transport()
    chan = tran.open_session()
    # chan.set_combine_stderr(True)
    chan.get_pty()
    f = chan.makefile()
    chan.exec_command('./outerr.py')
    print f.read(),

if __name__ == '__main__':
    ssh = connect()
    runTest(ssh)
    ssh.close()

如果运行上面的代码，您应该会看到按顺序排列的 100 行。相反，如果您注释掉 chan.get_pty() 调用并取消注释 chan.set_combine_stderr(True) 调用，您将得到一堆 stdout code> 和 stderr 行在运行之间随机散布。

Answer 2

好吧，我知道这是一个相当老的话题，但我遇到了同样的问题，并且我得到了一个（也许不那么）漂亮的解决方案。只需调用远程服务器上的命令，将 stderr 重定向到 stdout，然后始终从 stdout 读取。例如：

client = paramiko.SSHClient()
client.load_system_host_keys()
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
client.connect('hostname', username='user', password='pass')

stdin,stdout,stderr = client.exec_command('python your_script.py 2> \&1')
print stdout.read()

Answer 3

@AaronMcSmooth：我指的是我正在连接的计算机的标准输出和标准错误（通过 SSH）。

我最终这样做了：

stdin, stdout, stderr = ssh.exec_command(...)

output = stdin.read().strip() + stdout.read().strip()

出于我的应用程序的目的，区分 stdout 和 stderr 并不重要，但我认为这不是结合两者的最佳方式。

SSHClient.exec_command() 的代码是（查看 paramiko 的源代码）：

def exec_command(self, command, bufsize=-1):
    chan = self._transport.open_session() 
    chan.exec_command(command) 
    stdin = chan.makefile('wb', bufsize) 
    stdout = chan.makefile('rb', bufsize) 
    stderr = chan.makefile_stderr('rb', bufsize) 
    return stdin, stdout, stderr

我在通道上执行相同的操作，但收到通道已关闭错误。