1

我需要下载 ftp 目录中的所有文件。在我的程序启动时我不知道目录中的文件，所以我希望程序列出目录的内容，然后下载它找到的每个文件。

我制作了一个小演示脚本，可以从 ftp 下载文件并在执行此操作时更新进度条。下载和更新进度条工作正常，但是，我正在尝试执行下一步，即列出一些目录的内容并下载文件，但这部分不起作用。

目前，我只是想在任何目录上做一个列表并将结果打印到命令行。

当我尝试执行 listInfo.connect 时，我收到一条错误消息：

QObject::connect: 不能对“QUrlInfo”类型的参数进行排队（确保使用 qRegisterMetaType() 注册了“QUrlInfo”。）

...据我了解， qRegisterMetaType 不能在 PyQt 中完成，也是一个基本问题的标志，这就是我的问题。我可以毫无问题地执行 commandFinished.connect 和 dataTransferProgress.connect，但 listInfo.connect 似乎不起作用（如我所料）。

任何想法如何纠正这个问题？

这是一些示例代码（请原谅长度）。我希望能够从函数“lister”打印列出的文件/url。最终，我想让该函数制定新的 url 并将它们传回 connectAndDownload 以下载每个文件（当然，这需要对 connectAndDownload 进行修改，但我们还没有）。

#!/usr/bin/env python

from PyQt4 import QtCore, QtGui, QtNetwork

class FtpWorker(QtCore.QThread):
    dataTransferProgress = QtCore.pyqtSignal(int,int)
    def __init__(self,url,parent=None):
        super(FtpWorker,self).__init__(parent)
        self.ftp = None
        self.outFile = None
        self.get_index = -1

        self.url = url

    def run(self):
        self.connectAndDownload()
        self.exec_()

    def ftpCommandFinished(self, command_index, error):
        print "-----commandfinished-----",command_index

        if self.ftp.currentCommand == QtNetwork.QFtp.ConnectToHost:
            if error:
                QtGui.QMessageBox.information(self, "FTP",
                        "Unable to connect to the FTP server at %s. Please "
                        "check that the host name is correct.")
            return

        if self.ftp.currentCommand == QtNetwork.QFtp.Get or command_index == self.get_index:
            if error:
                print "closing outfile prematurely"
                self.outFile.close()
                self.outFile.remove()
            else:
                print "closed outfile normally"
                self.outFile.close()

            self.outFile = None

    def ftpDataTransferProgress(self,a,b):
        self.dataTransferProgress.emit(a,b)


    def lister(self,url_info):
        print url_info.name()


    def connectAndDownload(self):
        if self.ftp:
            self.ftp.abort()
            self.ftp.deleteLater()
            self.ftp = None
            return

        self.ftp = QtNetwork.QFtp()
        self.ftp.commandFinished.connect(self.ftpCommandFinished)
        self.ftp.listInfo.connect(self.lister)
        self.ftp.dataTransferProgress.connect(self.ftpDataTransferProgress)

        url = QtCore.QUrl(self.url)

        print "connect",self.ftp.connectToHost(url.host(), url.port(21))
        print "login",self.ftp.login(url.userName(), url.password())


        print "Connecting to FTP server %s..." % str(url.host())

        import os
        fileName = os.path.basename(self.url)

        if QtCore.QFile.exists(fileName):
            print "removing '%s'" % fileName
            os.unlink(fileName)

        self.outFile = QtCore.QFile(fileName)
        if not self.outFile.open(QtCore.QIODevice.WriteOnly):
            QtGui.QMessageBox.information(self, "FTP",
                    "Unable to save the file %s: %s." % (fileName, self.outFile.errorString()))
            self.outFile = None
            return

        tmp = self.ftp.list()
        print "starting list",tmp

        print "ftp.get(%s,%s)" % (str(url.path()), self.outFile)
        self.get_index = self.ftp.get(url.path(), self.outFile)



class AddProgresWin(QtGui.QWidget):
    def __init__(self, parent=None):
        super(AddProgresWin, self).__init__(parent)

        self.thread = FtpWorker(url="ftp://ftp.qt.nokia.com/developerguides/qteffects/screenshot.png")

        self.thread.dataTransferProgress.connect(self.updateDataTransferProgress)

        self.nameLabel = QtGui.QLabel("0.0%")
        self.nameLine = QtGui.QLineEdit()

        self.progressbar = QtGui.QProgressBar()

        mainLayout = QtGui.QGridLayout()
        mainLayout.addWidget(self.progressbar, 0, 0)
        mainLayout.addWidget(self.nameLabel, 0, 1)

        self.setLayout(mainLayout)
        self.setWindowTitle("Processing")

        self.thread.start()

    def updateDataTransferProgress(self, readBytes, totalBytes):
        self.progressbar.setMaximum(totalBytes)
        self.progressbar.setValue(readBytes)
        perct = "%2.1f%%" % (float(readBytes)/float(totalBytes)*100.0)
        self.nameLabel.setText(perct)


if __name__ == '__main__':

    import sys
    app = QtGui.QApplication(sys.path)

    pbarwin = AddProgresWin()
    pbarwin.show()

    sys.exit(app.exec_())
4

1 回答 1

1

看来这是一个 Qt 错误。来自 Phil Thompson，“可以说这是一个 Qt 错误 - 它应该为信号参数中使用的任何类型调用 qRegisterMetaType() 本身。”

我还注意到，为此目的，不需要线程，因为 QFtp 是异步的并且带有自己的信号。我在主线程中重新实现了 ftp.list() （以及相关的信号处理），一切都很好。

于 2012-11-20T19:48:30.977 回答