python Paramiko ssh die/hang with big output

dphi5xsq 于 2023-08-02 发布在 Python

关注(0)|答案(2)|浏览(74)

我尝试使用Paramiko和SSH调用tar命令来备份服务器。当文件数量有限时，一切正常，但当文件夹很大时，脚本会无休止地等待。下面的测试向我表明问题来自于标准输出的大小。
有没有一种方法可以纠正这种情况并执行这种命令？
箱大输出：

query = 'cd /;ls -lshAR -h'
chan.exec_command(query)
while not chan.recv_exit_status():
    if chan.recv_ready():
        data = chan.recv(1024)
        while data:
            print data
            data = chan.recv(1024)

    if chan.recv_stderr_ready():
        error_buff = chan.recv_stderr(1024)
        while error_buff:
            print error_buff
            error_buff = chan.recv_stderr(1024)
    exist_status = chan.recv_exit_status()
    if 0 == exist_status:
        break

字符串
结果是（不ok - block - die？？）

2015-07-25 12:57:07,402 --> Query sent

型
机箱小输出：

query = 'cd /;ls -lshA -h'
chan.exec_command(query)
while not chan.recv_exit_status():
    if chan.recv_ready():
        data = chan.recv(1024)
        while data:
            print data
            data = chan.recv(1024)

    if chan.recv_stderr_ready():
        error_buff = chan.recv_stderr(1024)
        while error_buff:
            print error_buff
            error_buff = chan.recv_stderr(1024)
    exist_status = chan.recv_exit_status()
    if 0 == exist_status:
        break

型
结果是（一切正常）

2015-07-25 12:55:08,205 --> Query sent
total 172K
4.0K drwxr-x---   2 root psaadm 4.0K Dec 27  2013 archives
   0 -rw-r--r--   1 root root      0 Jul  9 23:49 .autofsck
   0 -rw-r--r--   1 root root      0 Dec 27  2013 .autorelabel
4.0K dr-xr-xr-x   2 root root   4.0K Dec 23  2014 bin
2015-07-25 12:55:08,307 --> Query executed (0.10)

型
在GitHub上：
https://github.com/paramiko/paramiko/issues/563

python

来源：https://stackoverflow.com/questions/31625788/paramiko-ssh-die-hang-with-big-output

2条答案

按热度按时间

vmdwslir1#

如果ls -R打印出大量的错误输出（如果当前用户不是root =>，则很可能无法访问所有文件夹），则代码deadlocks最终将被删除。
这是因为，错误流的输出缓冲区最终会填满，所以ls停止工作，等待您读取流（清空缓冲区）。
当您等待常规输出流完成时，它永远不会这样做，因为ls等待您读取错误流，而您永远不会这样做。
您必须并行读取这两个流（请参阅Run multiple commands in different SSH servers in parallel using Python Paramiko）。
更简单的方法是使用Channel.set_combine_stderr将两个流合并为一个。