マルチスレッドアップロードに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_re plyが、RESP error_re plyが私に200種類のセット
私は1つずつアップロードしようとした場合、は、すべての作品罰金
解決
は、スレッド内の接続コードを入れてみましたがありますか?
つまり、各スレッドはFTP.host()とFTP.login()と自分の別の接続を行います。それは一度にコマンド1を解析することができる第二のアップロードまたは「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