使用Paramiko invoke_shell/send/recv读取阅读命令输出永远不会完成

jdg4fx2g  于 2023-10-23  发布在  Shell
关注(0)|答案(1)|浏览(652)

我尝试在Paramiko中使用send/recv函数。根据我所看到的,该行抛出超时异常
正在评估:self.shell.recv(1024)在3.00秒后未完成。

tmp = shell.recv(1024)

函数实现有什么问题?我从while True的退出条件是一个异常,我如何改变它以无异常地退出?

完整代码:

self.shell = self.SSHConnect(ip, username, password)

def SSHConnect(self, ip, username, passowrd):
    ssh = paramiko.SSHClient()
    LOGGER.debug(msg="Open SSH Client to :" + str(ip))
    try:
        ssh.set_missing_host_key_policy(policy=paramiko.AutoAddPolicy())
        ssh.connect(ip, port=22, username=username, password=passowrd, allow_agent=False, look_for_keys=True)
        if self.device_type != 'linux_host':
            session = ssh.invoke_shell()
            return session
    except Exception as ex:
        LOGGER.critical(msg="SSH Client wasn't established! Device name : " + str(self.device_name))
        return None 
    
    LOGGER.info(msg="Open SSH Client to :" + str(ip) + " established!")
    return ssh

def run_command(self,cmd):
    # New run command without throwing exception at the end:
    LOGGER.debug('Start new Run command with cmd =  ' + str(cmd))
    try:
        #Check the shell is activated before sending command:
        LOGGER.debug('Check the shell is activated before sending command: ' + cmd)
        if self.shell.get_transport().active:
            LOGGER.debug('Shell is Activated ! Running the command ')
            if self.device_type == 'linux_host':
                stdin, stdout, stderr = self.shell.exec_command(cmd)
            else:
                try:
                    #Command for switch of UFMAPL
                    LOGGER.debug('Sending command to UFMAPL/Switch with send()')
                    out = ''
                    self.shell.send(cmd)
                    while not self.shell.recv_ready():
                        time.sleep(3)
                    counter = 1
                    print('\ncommand is : ' + cmd + '\n' )
                    while True:
                        try:
                            print('iteration number is : #' + str(counter))
                            tmp = self.shell.recv(1024)
                            counter = counter + 1 
                            if not tmp:
                                break
                        except Exception as e:
                            break
                        out += tmp.decode("utf-8")
                        print('After iteration #' + str(counter) + ' out = ' + out + '\n\n')
                    ansi_escape = re.compile(r'\x1B\[[0-?]*[ -/]*[@-~]')
                    out = ansi_escape.sub('', out)
                    print('Printing final value before return : ' + str(out +'\n'))
                    return out
                except Exception as e:
                    LOGGER.error('Exception in send() : ' +str(e) )
                    return None
        else:
            LOGGER.critical('Shell is not activated !')
            return ""
    
        if stderr.read():
            LOGGER.critical('stderr is not empty which means the last command was failed, the command might not exist on host/switch ' )
            return stderr.read().decode('utf-8')
    
        out = stdout.read()
        if out:
            return out.decode("utf-8")
        else:
            LOGGER.critical('Run command sucussfully but return empty...')
            return out.decode("utf-8")
    except Exception as e:
        LOGGER.error('Exception received in run command : ' + str(e))
  • 打印到屏幕:*
IM HEREEEEEEEEEEEEEEEEEEEEEEEEEEEEEEEEEEE

command is : enable

iteration number is : #1

After iteration #2 out =
UFM Appliance

UFM is configured as standalone.
UFM mode: Management.
RAID state is: Degraded ( DRIVE1:Online,SpunUp, DRIVE2:Failed )
smg-ib-apl008-gen2 [ mgmt-sa ] >

iteration number is : #2

After iteration #3 out =
UFM Appliance

UFM is configured as standalone.
UFM mode: Management.
RAID state is: Degraded ( DRIVE1:Online,SpunUp, DRIVE2:Failed )
smg-ib-apl008-gen2 [ mgmt-sa ] > e

iteration number is : #3

After iteration #4 out =
UFM Appliance

UFM is configured as standalone.
UFM mode: Management.
RAID state is: Degraded ( DRIVE1:Online,SpunUp, DRIVE2:Failed )
smg-ib-apl008-gen2 [ mgmt-sa ] > enable
smg-ib-a

iteration number is : #4

After iteration #5 out = 
UFM Appliance

UFM is configured as standalone.
UFM mode: Management.
RAID state is: Degraded ( DRIVE1:Online,SpunUp, DRIVE2:Failed )
smg-ib-apl008-gen2 [ mgmt-sa ] > enable
smg-ib-apl00

iteration number is : #5

After iteration #6 out =
UFM Appliance

UFM is configured as standalone.
UFM mode: Management.
RAID state is: Degraded ( DRIVE1:Online,SpunUp, DRIVE2:Failed )
smg-ib-apl008-gen2 [ mgmt-sa ] > enable
smg-ib-apl008-gen2 [ mgmt-sa ] #

iteration number is : #6

正如你所看到的,调试器在iteration #6上卡住了(冻结)。为什么它冻结并且不发送输出?

  • 环境详情:*
  • Windows 10
  • Eclipse最新

我会很感激任何帮助。如果你需要更多的细节就告诉我。

j2cgzkjk

j2cgzkjk1#

您的代码到达服务器停止等待另一个输入的点。同时等待服务器输出一些东西。永远不会发生的事这就是所谓的deadlock
您可能期望得到某种信号,表明第一个命令执行已经完成。没有这样的信号。您正在使用“shell”(SSHClient.invoke_shell)。shell是一个有输入和输出的黑盒子。除了您已经在阅读的输出之外,没有其他信号。
“shell”不应用于自动执行命令。对于命令自动化,有“exec”通道(Paramiko中的SSHClient.exec_command)。
虽然我知道,对于一些特殊的设备,你的服务器似乎是什么,你可能没有任何其他选择(见Executing command using Paramiko exec_command on device is not working)。此外,我不确定enable命令是如何工作的。无论是一个已经完成的命令,还是一个新的shell,它仍然在运行并等待子命令。
所以最后你所能做的就是解析输出,等待命令提示符(smg-ib-apl008-gen2 [ mgmt-sa ] #)。基本上,当检测到命令完成时,当交互地使用shell/终端时,您需要实现您自己(作为一个人)使用的“智能”。
是的,很丑。你正在尝试自动化一些本来不打算自动化的东西。也许你的服务器有一个更好的API,然后enable shell命令,这将是更好的自动化。但那是另一个问题。从SSH/Python/Paramiko的Angular 来看,如果您需要坚持在shell中执行enable命令,那么没有更好的解决方案。
相关问题:

虽然它们是关于更常规的服务器,如Linux。所以他们帮不上忙。我把它们联系起来只是为了提供更广泛的画面和背景。

相关问题