【发布时间】:2021-12-28 11:08:14
【问题描述】:
我正在尝试在 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(冻结)。
为什么它会冻结并且不发送输出?
环境详情:
视窗 10
Eclipse 最新
我会很感激这里的任何帮助。如果您需要更多详细信息,请告诉我。
【问题讨论】: