1

像大多数人一样，我需要一段时间才能习惯使用 Deferreds，但我正在慢慢适应。但是，我不清楚如何处理响应，然后在使用 Twisted 的 FTP 模块时使用处理后的响应调用另一个 FTP 命令。我使用示例 FTP 代码作为我的起点。

我想连接到 FTP 服务器，获取所有顶级目录，然后输入每个目录并下载所有文件。

首先我连接：

creator = ClientCreator(reactor, FTPClient, config.opts['username'], config.opts['password'], passive=config.opts['passive'])
creator.connectTCP(config.opts['host'], config.opts['port']).addCallback(connectionMade).addErrback(connectionFailed)
reactor.run()

它连接成功，所以我的connectionMade函数被调用：

def connectionMade(ftpClient):
    # Get a detailed listing of the current directory
    fileList = FTPFileListProtocol()
    d = ftpClient.list('.', fileList)
    d.addCallbacks(getSortedDirectories, fail, callbackArgs=(fileList,))
    d.addCallback(enterDirs)

如您所见，我排队getSortedDirectories，然后enterDirs。

def getSortedDirectories(result, fileListProtocol):
    # Go through all directories from greatest to least
    dirs = [directory for directory in sorted(fileListProtocol.files, reverse=True) if directory['filetype'] == 'd']
    return dirs

我的问题是，我如何浏览 中的目录enterDirs？

def enterDirs(dirs):
    for directory in dirs:
        print "We'd be entering '%s' now." % directory

我应该传递ftpClient给enterDirs喜欢fileList传递给getSortedDirectories然后发出我的下载请求吗？

d.addCallback(enterDirs, callbackArgs=(ftpClient,))

def enterDirs(dirs, ftpClient):
    for directory in dirs:
        fileList = FTPFileListProtocol()
        d = ftpClient.list(directory, fileList)
        d.addCallbacks(downloadFiles, fail, callbackArgs=(directory, fileList, ftpClient))

def downloadFiles(result, directory, fileListProtocol, ftpClient):
    for f in fileListProtocol.files if f.filetype == '-':
        fileConsumer = FileConsumer()
        ftpClient.retrieveFile(os.path.join(directory['filename'], file['filename']), fileConsumer)

这是最好的方法吗？

4

1 回答 1

1

我是否应该将 ftpClient 传递给 enterDirs，例如将 fileList 传递给 getSortedDirectories 然后发出我的下载请求？...这是最好的方法吗？

我确实认为将客户端对象作为参数显式传递确实是最好的方法——主要是，它是多余的和优雅的。主要的替代方法是编写一个类并将客户端对象存储到一个实例变量中，这似乎有点麻烦；在我看来，为此目的使用全局变量将是最不可取的选择（周围的全局变量越少越好！-）。

于 2010-07-22T23:57:24.517 回答