1

对不起，首先是文字墙。我一般很难理解 Twisted 和异步编程。

我正在使用带有 Twisted 15.4.0 的 Python 2.7。

我为 downloadPage()尝试了这个示例，它运行良好。

我对其进行了一些修改，将回调从 lambda 更改为正确的函数。有效。我还尝试从回调和 errback 中删除 reactor.stop() 语句，它的唯一影响是脚本在下载后不会停止。这是有道理的，因为事件循环仍在运行。

我还尝试提供一个损坏的 URL。

如果我只有一次调用 downloadPage()，程序会阻塞。它不会触发 errback。

如果我有两个调用，一个带有损坏的 URL，一个带有正确的 URL，它会运行、完成并触发回调（我假设是正确的）并终止。

我的第一个问题是：为什么会发生这种情况？为什么不为损坏的 URL 触发 errback？损坏的 URL 不应该引发错误吗？

我有一个单独的代码，看起来像这样：

def receive_some_data():
   # Do some non twisted stuff - The script runs and passes these lines
   While True:
       try:
           # Do some other non twisted stuff
           print "1"
           downloadPage("http//:www.google.com", "foo").addCallbacks(
               lambda value:(println('Good'),reactor.stop()),
               lambda error:(println("an error occurred",error),reactor.stop()))
           print "2"
       except Exceptions as e:
           print str(e)

def main():
    reactor.callWhenRunning(receive_some_data)
    reactor.run()

此代码不起作用。它打印“1”，打印“2”，但没有回调或 errback 调用。该页面也没有下载到“foo”。

我的第二个问题是：为什么这段代码不起作用？是因为While循环吗？如果是这样，while 循环如何影响延迟和它的回调链？

编辑 1：我将“While True”更改为“While 条件”，在 3 次迭代后终止。现在下载文件并调用回调。为什么无限循环会干扰下载？

此外，我在 While 循环中的“# Do some other non twisted stuff”行执行从管道读取。这是我获取网址的地方。

我可以连续阅读我的网址并在下载完成时安排回调的最佳方式是什么？

编辑2：我将代码更改为这样的：

def receive_some_data():
    # Do some non twisted stuff
    if condition:
        # Request more urls
        downloadPage(url,file).addCallbacks(success,fail)
    else:
        # Ask sender not to send urls atm

def main():
    reactor.callWhenRunning(receive_some_data)
    reactor.run()

我将代码的结构更改为这样的想法 callWhenRunning() 将继续调用 receive_some_data 函数（就像一个无限循环）。它没有。

如何让事件循环继续调用此函数？

编辑 3：设法使这个工作有点。我发现了循环调用方法。我每隔 x 秒使用循环调用从Edit 2调用我的代码。有用。还有其他方法吗？

谢谢！

4

1 回答 1

2

downloadPage基本上，当您多次调用时，您正在做的是并行启动多个下载。第一个完成的将是第一个调用它的回调或错误返回的，这将停止反应器以及所有其他下载。

因此，当您将一次呼叫的 URL 更改为不良主机时，请求超时需要一些时间。届时，其他（好的）下载将完成，并停止反应堆。这就是为什么您的代码只能使用一个好的 URL 的原因。

您while在另一个示例中将创建一个又一个下载，而不是从函数返回receive_some_data。但它需要返回以允许执行下载的调用/错误返回。Twisted 一次只运行一个呼叫。

于 2015-12-01T14:06:28.897 回答