다중 스레드 업로드에 ftplib 사용

Question

다중 스레드 업로드를 시도하고 있지만 오류가 발생합니다. ftplib에서 멀티 스레드를 사용하는 것이 불가능할 수도 있습니다.

인상 error_reply 같은 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() 

가져 오기 무리 error_reply RESP : 나는 하나 하나를 업로드하려고하면 I

로 설정 200 유형 여기

내 코드를 제공 , 다 잘 작동

Answer 1

스레드 안에 연결 코드를 넣으려고 했습니까?

즉, 각 스레드를 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. 모든 탭이 정렬되어 있는지 확실하지 않습니다.