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