脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 脚本专栏 → python → Twisted框架中Deferred的用法

实例解析Python的Twisted框架中Deferred对象的用法

 更新时间：2016年05月25日 12:04:26   作者：Danny Man  
Deferred对象在Twsited框架中用于处理回调,这对于依靠异步的Twisted来说十分重要,接下来我们就以实例解析Python的Twisted框架中Deferred对象的用法

Deferred对象结构
Deferred由一系列成对的回调链组成，每一对都包含一个用于处理成功的回调（callbacks）和一个用于处理错误的回调（errbacks）。初始状态下，deffereds将由两个空回调链组成。在向其中添加回调时将总是成对添加。当异步处理中的结果返回时，Deferred将会启动并以添加时的顺序触发回调链。
用实例也许更容易说明，首先来看看addCallback：

from twisted.internet.defer import Deferred
 
def myCallback(result):
  print result
 
d = Deferred()
d.addCallback(myCallback)
d.callback("Triggering callback.")

运行它将会得到如下结果：

Triggering callback.

上例中创建了一个deffered并利用其addCallback方法注册一个用于处理成功的回调。d.callback会启动deffered并调用callback链。传入callback的参数也会被各callback链中的第一个函数接收到。
有addCallback，那另一个错误的分支，我想也能猜测到了那就是addErrorback，同样来看个例子：

from twisted.internet.defer import Deferred
 
def myErrback(failure):
  print failure
 
d = Deferred()
d.addErrback(myErrback)
d.errback(ValueError("Triggering errback."))

运行它将会得到如下结果：

复制代码 代码如下:

[Failure instance: Traceback (failure with no frames): <type 'exceptions.ValueError'>: Triggering errback.]

可以看出Twisted会把错误封装在Failure里。
值得注意的是，在之前提到过注册回调总是成对的。在使用d.addCallback和d.addErrorback方法时，我们看似只是添加了一个callback或一个errback。而实际上，为了完成这一级回调链的创建，这些方法还会为另一半注册一个pass-through。要记住，回调链总是具有相同的长度。如果要分别指定这一级回调的callback和errback。可以使用d.addCallbacks方法：
d = Deferred()
d.addCallbacks(myCallback, myErrback)
d.callback("Triggering callback.")
那么...今天就先到这里。

进阶示例
接下来就应该来点更为实际的，那就是放进Reactor。先来看一个例子：

from twisted.internet import reactor, defer
 
class HeadlineRetriever(object):
  def processHeadline(self, headline):
    if len(headline) > 50:
      self.d.errback(Exception("The headline ``%s'' is too long!" % (headline,)))
    else:
      self.d.callback(headline)
 
  def _toHTML(self, result):
    return "<h1>%s</h1>" % (result,)
 
  def getHeadline(self, input):
    self.d = defer.Deferred()
    reactor.callLater(1, self.processHeadline, input)
    self.d.addCallback(self._toHTML)
    return self.d
 
def printData(result):
  print result
  reactor.stop()
 
def printError(failure):
  print failure
  reactor.stop()
 
h = HeadlineRetriever()
d = h.getHeadline("Breaking News: Twisted Takes us to the Moon!")
d.addCallbacks(printData, printError)
 
reactor.run()

上例接收一个标题并对其进行处理，如果标题超长会返回超长的错误，否则将其转为HTML并返回。

因所给的标题少于50个字符，故执行以上代码会得到如下返回：

<h1>Breaking News: Twisted Takes us to the Moon!</h1>

有一点值得注意的，上面用到了reactor的callLater方法，它可以用来做定时事件从而模拟一个异步的请求。

如果我们将标题变得很长，比如说：

h = HeadlineRetriever()
d = h.getHeadline("1234567890"*6)
d.addCallbacks(printData, printError)

那结果是可以遇见的：

复制代码 代码如下:

[Failure instance: Traceback (failure with no frames): <type 'exceptions.Exception'>: The headline ``123456789012345678901234567890123456789012345678901234567890'' is too long!]

我们用图看一下触发流程：
2016525120051862.jpg (547×368)

Deferreds中的关键之处
1. Deferreds将会在调用其callback或errback时被触发；
2. Deferreds仅能被触发一次！如果尝试多次触发将会导致AlreadyCalledError异常；
3. 第N级callback或errback中的Exceptions将会传入第N+1级的errback中；如果没有errback，则会抛出Unhandled Error。如果第N级callback或errback中没有抛出Exception或返回Failure对象，那接下来将会由第N+1级中的callback进行处理；
4. callback中返回的结果将会传入下一级callback，并作为其第一个参数；
5. 如果传入errback的错误不是一个Failure对象，那将会被自动包装一次。

您可能感兴趣的文章:

相关文章

  • 简单谈谈python中的lambda表达式

    简单谈谈python中的lambda表达式

    Lambda表达式在Python中经常使用到，本文是给大家分享的小编总结出来的Lambda表达式的常用方法。
    2018-01-01
  • python自定义类并使用的方法

    python自定义类并使用的方法

    这篇文章主要介绍了python自定义类并使用的方法,涉及Python中类的定义与使用技巧,需要的朋友可以参考下
    2015-05-05
  • django中资源文件夹的引入及配置方法

    django中资源文件夹的引入及配置方法

    这篇文章主要介绍了django中资源文件夹的引入,主要包括静态资源文件夹的引入及媒体资源文件夹的引入，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2022-08-08
  • Python小程序爬取今日新闻拿走就能用

    Python小程序爬取今日新闻拿走就能用

    这篇文章主要教大家怎样实现一个Python小程序，爬取今日新闻，文中给出了详细的示例代码，拿走就能用，有需要的朋友可以借鉴参考下，希望能够有所帮助
    2021-09-09
  • python文档字符串（函数使用说明）使用详解

    python文档字符串（函数使用说明）使用详解

    这篇文章主要介绍了python文档字符串（函数使用说明）使用详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-07-07
  • Pytorch计算网络参数的两种方法

    Pytorch计算网络参数的两种方法

    PyTorch是一个流行的深度学习框架,它允许研究人员和开发者快速构建和训练神经网络,计算一个PyTorch网络的参数量通常涉及两个步骤,本文给大家介绍了在PyTorch中计算网络参数量的一般方法,需要的朋友可以参考下
    2024-05-05
  • 超简单的scrapy实现ip动态代理与更换ip的方法实现

    超简单的scrapy实现ip动态代理与更换ip的方法实现

    这篇文章主要介绍了超简单的scrapy实现ip动态代理与更换ip的方法实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2021-03-03
  • Python字符串和二进制字符串之间的转换方法示例

    Python字符串和二进制字符串之间的转换方法示例

    python中没有0-1形式的二进制类型,但我们依然可以存储二进制类型的数据,下面这篇文章主要给大家介绍了关于Python字符串和二进制字符串之间的转换方法,需要的朋友可以参考下
    2023-06-06
  • 如何使用Python发送HTML格式的邮件

    如何使用Python发送HTML格式的邮件

    这篇文章主要介绍了如何使用Python发送HTML格式的邮件,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-02-02
  • python+opencv边缘提取与各函数参数解析

    python+opencv边缘提取与各函数参数解析

    这篇文章主要介绍了python+opencv边缘提取与各函数参数解析，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-03-03

最新评论