我尝试在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最新
我会很感激任何帮助。如果你需要更多的细节就告诉我。
1条答案
按热度按时间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。所以他们帮不上忙。我把它们联系起来只是为了提供更广泛的画面和背景。