扭曲的延迟链接

Question

我有一个异步管理模块调用的应用程序：

• 它请求一个触发自身的延迟
• 附加自定义回调
• 检查返回的代码是否=CONTINUE，否则处理错误

这是返回延迟到主应​​用程序的代码：

def xxfi_connect(self, hostname):
    d = defer.Deferred()
    d.callback(Milter.ReturnCodes.CONTINUE)
    return d

要异步附加一些代码，我需要将我的函数调用挂接到延迟函数中，如下所示：

d = defer.Deferred()
d.addCallback(self.run_mods, application.L_CONNECT)
d.callback(Milter.ReturnCodes.CONTINUE)

问题是每个连接的函数都会收到一个包含回调参数（application.L_CONNECT）的参数。

是否可以在不传输每个函数调用的返回码的情况下实现这一点？

理想情况下，我希望我的回调函数是这样的：

def run_mods(self, level):
    pass

而不是

def run_mods(self, code, level):
    pass

因为code (Milter.ReturnCodes.CONTINUE) 只需要在链的末端

Answer 1

区分成功或错误Deferred()s 已经是它们内置的功能。

>>> from twisted.internet import defer
>>> d = defer.Deferred()
>>> def errors(*args): raise Exception("i'm a bad function")
>>> def sad(*arg): print "this is not so good", arg
>>> def happy(*arg): print "this is good", arg
>>> d.addCallback(errors)
<Deferred at 0x106821f38>
>>> d.addCallbacks(happy, sad)
<Deferred at 0x106821f38>
>>> d.callback("hope")
this is not so good (<twisted.python.failure.Failure <type 'exceptions.Exception'>>,)

回调链中的任何给定“阶段”都可以很容易地知道它是否处于错误状态，无论是通过添加方式，作为addErrback() 的参数，还是addCallbacks() 的第二个参数，或者凭借它的论点是Failure()的一个实例@

有关延迟链接的更多信息，请参阅：https://twistedmatrix.com/documents/14.0.1/core/howto/defer.html