使paramiko库执行命令时,在给定的时间强制退出
原因:
使用paramiko库ssh连接到远端云主机上时,非常偶现卡死现象,连接无法退出(可以是执行命令时云主机重启等造成)。需要给定一段时间,不管命令执行是否卡住,都退出连接,显示命令执行超时错误。
实现方式:
线程+事件,在线程中执行ssh命令,给事件配置超时时间。
代码示例:
1 from threading import Thread, Event
2 import paramiko
1 class SshClient(object): 2 3 def __init__(self, ip, port, username, password): 4 self.ip = ip 5 self.host = host 6 self.username = username 7 self.password = password 8 9 def exec_command(cmd, timeout):10 log.info(u"在ip:%s上执行命令%s" % (self.ip, cmd))11 sc = paramiko.SSHClient()12 sc.set_missing_host_key_policy(paramiko.AutoAddPolicy())13 14 # 用来接收stdout stderror status信息15 res = [None, None, None]16 17 def get_return(start_event, res_list):18 _, cmd_stdout, cmd_stderr = sc.exec_command(command=cmd, timeout=timeout)19 channel = cmd_stdout.channel20 cmd_status = channel.recv_exit_status()21 res_list[0] = cmd_stdout22 res_list[1] = cmd_stderr23 res_list[2] = cmd_status24 start_event.set() # 表示线程已经执行完毕25 26 try:27 sc.connect(hostname=self.ip, port=self.port, username=self.username, password=self.password, timeout=30) # 这里的timeout是连接使用的,与我们要的不同28 start_evt = Event()29 t = Thread(target=get_return, args=(start_evt, res))30 t.start()31 start_evt.wait(timeout=timeout)32 # 执行到这里说明线程已经退出33 if None in res:34 raise Exception(u"命令超时退出")35 stdout, stderr, status = res36 if status != 0:37 raise Exception(u"命令执行返回非0!返回值为%s,错误信息为%s" % (status, stdout.read() + stderr.read()))38 return stdout.read() + stderr.read()39 finally:40 sc.close()41 }
赞 (0)