我编写了此脚本以将更新文件复制到数千个字段中的客户端。它适用于客户超时的情况。我正在捕获异常,但它杀死了我的脚本。将不胜感激一些建议,如何调整此脚本,以防止死亡。以下是异常的输出和错误消除脚本。线程脚本中的Python脚本open_sftp_client错误
( 'ABCD SAT6', '超时')[错误113]没有举办
回溯(最近通话最后一个)路线: 文件 “StackUpdateLocoImage.py”,第48行,在 池。 map(worker,infile) 文件“/usr/lib64/python2.6/multiprocessing/pool.py”,第148行,在地图中 return self.map_async(func,iterable,chunksize).get() File“/ usr/lib64/python2.6/multiprocessing/pool.py“,第422行,获得 raise self._value AttributeError:'NoneType'对象没有属性'open_sftp_client'
#!/usr/bin/python
import paramiko, os, string, threading
import socket
import sys
import logging
import multiprocessing
##Python Logging##
LOG_FILENAME = 'updateLocos.out'
logging.basicConfig(filename=LOG_FILENAME, level=logging.DEBUG,)
## Paramiko Logging##
paramiko.util.log_to_file("Paramiko_Connections.log")
def worker(line):
locoid = line.split()
try:
if locoid[0] == 'ABCD' :
locoip = locoid[4]
##Start SFTP
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(locoip, username='user', password='password', timeout=3.0)
except paramiko.AuthenticationException,e:
print ('ABCD ' + locoid[1], 'Auth Error: ',e)
#exit()
except paramiko.SSHException,e:
print "Connection Error: ",e
#exit()
except socket.error,e:
print ('ABCD ' + locoid[1], 'Timed Out'),e
#exit()
filepath = '/usr/local/bin/scripts/update3.2.2.tar.gz'
localpath = '/root/update3.2.2.tar.gz'
sftp = ssh.open_sftp()
sftp.put(filepath, localpath)
sftp.close()
ssh.close()
## set up processing pool
pool = multiprocessing.Pool()
with open('hostslists.txt') as infile:
pool.map(worker, infile)
pool.close()
pool.join()
是的,将它改为return()修复了这个问题。谢谢。 – teamg