Почему QtNetwork.QFtp.get загружается с ошибкой в ​​for-loop для нескольких файлов?

Question

Я пытаюсь загрузить несколько файлов с ftp-сайта, используя for-loop. Следующий код, похоже, работает только для первых 2 файлов в цикле, прежде чем откроется окно выключения python.exe. Два загруженных файла идеальны, но третий загруженный файл пуст после выключения. Я не получаю остальные файлы. Любая идея, что может быть проблемой?

from PyQt4 import QtCore, QtGui, QtNetwork 


class FtpWindow(QtGui.QDialog): 

    def __init__(self, parent=None): 
     self.fileList = QtGui.QTreeWidget() 
     self.ftp = QtNetwork.QFtp(self) 
     self.progressDialog = QtGui.QProgressDialog(self) 
     self.downloadAllButton.clicked.connect(self.downloadAllFile) 
     self.ftp.commandFinished.connect(self.ftpCommandFinished) 

    def downloadAllFile(self): 
     for jj in range(self.fileList.topLevelItemCount()): # how many files in a particular folder 
      fileName = self.fileList.topLevelItem(jj).text(0) 
      self.outFile = QtCore.QFile(fileName) 

      self.ftp.get(fileName, self.outFile) #download one file at a time 
      self.progressDialog.setLabelText("Downloading %s..." % fileName)  
      self.progressDialog.exec_() 

    def ftpCommandFinished(self, _, error): 
     self.setCursor(QtCore.Qt.ArrowCursor) 
     if self.ftp.currentCommand() == QtNetwork.QFtp.Get: 
      if error: 
       self.statusLabel.setText("Canceled download of %s." % self.outFile.fileName()) 
       self.outFile.close() 
       self.outFile.remove() 
      else: 
       self.statusLabel.setText("Downloaded %s to current directory." % self.outFile.fileName()) 
       self.outFile.close() 

      self.outFile = None 
      self.enableDownloadButton() 
      self.progressDialog.hide() 

Answer 1

self.progressDialog.exec_() должно быть блокирующее модальный диалог. Используйте self.progressDialog.show() для неблокирующего вызова.

Похоже, что ftp get не блокируется, поэтому вам нужно подождать, пока загрузка закончится с использованием сигнала commandFinished().

Я предполагаю, что каждая итерация в цикле перезаписывает self.outFile, поэтому нет никаких ссылок на объект python. Это заставляет объект умирать всякий раз, когда python делает сборку мусора. Я предполагаю, что ваши первые два файла, где маленький и быстрый, и ваш третий файл были больше, поэтому другие файлы могли загружаться до сбора мусора. Либо это, либо сбор мусора был просто быстрее для последнего файла.

http://pyside.github.io/docs/pyside/PySide/QtNetwork/QFtp.html#PySide.QtNetwork.PySide.QtNetwork.QFtp.get

class FtpWindow(QtGui.QDialog): 

    def __init__(self, parent=None): 
     self.fileList = QtGui.QTreeWidget() 
     self.ftp = QtNetwork.QFtp(self) 
     self.progressDialog = QtGui.QProgressDialog(self) 
     self.progressDialog.canceled.connect(self.ftp.abort) 
     self.downloadAllButton.clicked.connect(self.downloadAllFile) 
     self.ref_holder = {} 
     self.ftp.commandFinished.connect(self.ftpCommandFinished) 

    def download_file(self, filename): 
     """Non blocking start downloading a file.""" 
     outFile = QtCore.QFile(filename) 
     cmd_id = self.ftp.get(filename, outFile) # Non blocking just start downloading 

     # This keeps the object alive and doesn't overwrite them. 
     self.ref_holder[cmd_id] = [filename, outFile] 

    def downloadAllFile(self): 
     self.progressDialog.reset() 
     num_downloads = self.fileList.topLevelItemCount() 
     self.progressDialog.setMaximum(num_downloads) 
     self.progressDialog.setValue(0) 
     self.progressDialog.setLabelText("Downloading %d files ..." % num_downloads) 
     self.progressDialog.show() 
     for jj in range(num_downloads): # how many files in a particular folder 
      fileName = self.fileList.topLevelItem(jj).text(0) 
      self.download_file(fileName) # Non blocking, and doesn't overwrite self.outFile with every iteration 

    def ftpCommandFinished(self, cmd_id, error=None): 
     """Increased the number of items finished.""" 
     self.progressDialog.setValue(self.progressDialog.value()+1) 
     item = self.ref_holder.pop(cmd_id) # Remove the reference for the finished item 
     if error: 
      self.progressDialog.setLabelText("Error downloading %s" % item[0]) 

     # Check if all downloads are done 
     if len(self.ref_holder) == 0: 
      self.progressDialog.setValue(self.progressDialog.maximium()) 
      self.progressDialog.close() # This shouldn't be needed 

Мой пример выше будет содержать имя файла и ссылку на объект Outfile, пока команда не будет завершена. Когда команда завершена, ссылка удаляется, позволяя python очищать объект.

Answer 2

Спасибо за вход HashSplat. У меня есть несколько обновлений, чтобы сделать его полностью работоспособным:

class FtpWindow(QtGui.QDialog): 

def __init__(self, parent=None): 
    self.fileList = QtGui.QTreeWidget() 
    self.ftp = QtNetwork.QFtp(self) 
    self.progressDialog = QtGui.QProgressDialog(self) 
    self.progressDialog.canceled.connect(self.ftp.abort) 
    self.downloadAllButton.clicked.connect(self.downloadAllFile) 
    self.ref_holder = {} 
    self.ftp.commandFinished.connect(self.ftpCommandFinished) 

def download_file(self, fileName): 
    """Non blocking start downloading a file.""" 
    self.outFile = QtCore.QFile(fileName) 

    """ Need this to have files saved locally """ 
    if not self.outFile.open(QtCore.QIODevice.WriteOnly): 
     QtGui.QMessageBox.information(self, "FTP", 
       "Unable to save the file %s." % fileName) 
     self.outFile = None 
     return 
    cmd_id = self.ftp.get(filename, self.outFile) # Non blocking just start downloading 

    # This keeps the object alive and doesn't overwrite them. 
    self.ref_holder[cmd_id] = [filename, self.outFile] 

def downloadAllFile(self): 
    self.progressDialog.reset() 
    self.num_downloads = self.fileList.topLevelItemCount() 
    self.counter=1 
    self.progressDialog.setLabelText("Downloading %d/%d files ..." % (self.counter, self.num_downloads)) 
    self.progressDialog.show() 
    for jj in range(num_downloads): # how many files in a particular folder 
     fileName = self.fileList.topLevelItem(jj).text(0) 
     self.download_file(fileName) # Non blocking, and doesn't overwrite self.outFile with every iteration 

def ftpCommandFinished(self, cmd_id, error=None): 
    """Increased the number of items finished.""" 
    self.progressDialog.setValue(self.progressDialog.value()+1) 
    item = self.ref_holder.pop(cmd_id) # Remove the reference for the finished item 
    if error: 
     self.progressDialog.setLabelText("Error downloading %s" % item[0]) 

    # Check if all downloads are done 
    if len(self.ref_holder) == 0: 
     self.progressDialog.close() # This closes the extra window 
     self.outFile.close() # You need this to have the last file saved 
    else: 
     self.counter+=1 
     self.progressDialog.setLabelText("Downloading %d/%d files ..." % (self.counter, self.num_downloads)) 

def updateDataTransferProgress(self, readBytes, totalBytes): 
    self.progressDialog.setMaximum(totalBytes) 
    self.progressDialog.setValue(readBytes)