使用FTPLIB为多线程上传
-
23-09-2019 - |
题
我试图做多线程上传,但得到的错误。 我猜想,也许这是不可能使用多线程与FTPLIB?
下面来我的代码:
class myThread (threading.Thread):
def __init__(self, threadID, src, counter, image_name):
self.threadID = threadID
self.src = src
self.counter = counter
self.image_name = image_name
threading.Thread.__init__(self)
def run(self):
uploadFile(self.src, self.image_name)
def uploadFile(src, image_name):
f = open(src, "rb")
ftp.storbinary('STOR ' + image_name, f)
f.close()
ftp = FTP('host') # connect to host, default port
ftp.login() # user anonymous, passwd anonymous@
dirname = "/home/folder/"
i = 1
threads = []
for image in os.listdir(dirname):
if os.path.isfile(dirname + image):
thread = myThread(i , dirname + image, i, image )
thread.start()
threads.append( thread )
i += 1
for t in threads:
t.join()
获取一串FTPLIB误差的像
养error_reply,RESP error_reply:200类型设定为I
如果我试图通过一个上载一个,一切工作正常。
解决方案
您是否尝试过把连接代码的线程里面?
在换言之,使每个线程做FTP.host()和FTP.login()自己的单独的连接。服务器可能不喜欢在同一时间在单个连接上的多个上载的,因为它可以被解析命令一次一个,并且无法处理的第二载或“STOR”命令。但是,如果你可以从同一个IP地址做多个连接,你就必须要在其上发出“STOR”命令单独的会话。
下面是一个例子:
class myThread (threading.Thread):
def __init__(self, threadID, src, counter, image_name):
###############
#Add ftp connection here!
self.ftp = FTP('host') # connect to host, default port
self.ftp.login() # user anonymous, passwd anonymous@
################
self.threadID = threadID
self.src = src
self.counter = counter
self.image_name = image_name
threading.Thread.__init__(self)
def run(self):
uploadFile(self.src, self.image_name)
def uploadFile(src, image_name):
f = open(src, "rb")
self.ftp.storbinary('STOR ' + image_name, f)
f.close()
dirname = "/home/folder/"
i = 1
threads = []
for image in os.listdir(dirname):
if os.path.isfile(dirname + image):
thread = myThread(i , dirname + image, i, image )
thread.start()
threads.append( thread )
i += 1
for t in threads:
t.join()
,看看是否能更好的行为
P.S。不知道如果我所有的标签对齐。
不隶属于 StackOverflow