扭曲的延迟回调链

Question

阅读文档和一些用例后。问题出现了如何使用回调链。更准确地说，如何在回调之间传输数据

这是代码：

d = defer.Deferred()
d.addCallback(self.min_active_stack)
d.addCallback(self.min_normalization)
d.addCallback(self.insert_db)
d.callback(0)

def min_active_stack(self,d):
    ...
    return self.dbconn.runQuery(sql_query)

def min_normalization(self,min):
    ...
    return min[0][0]+self.x

def insert_db(self,min_norm):
    ...
    return self.dbconn.runQuery(sql_query)

首先，在 min_active_stack 中，我向 db 发出请求。在 min_normalization 中我处理数据。处理后的数据上的 insert_db 我确实对数据库有一个请求。

这种情况下，数据是通过链来传输的，很简单。 但是，如果在链的中间需要运行比回调更多的内容怎么办？

d = defer.Deferred()
d.addCallback(self.min_active_stack)
d.addCallback(self.stack_shift)
d.addCallback(self.min_normalization)
d.addCallback(self.insert_db)
d.callback(0)

def stack_shift(self, d):
    return self.dbconn.runQuery(query)

stack_shift 中不使用任何外部数据，但它应该在 min_active_stack 之后和 insert_db 之前运行。事实证明，min_normalization 来自延迟的 stack_shift 而不是 min_active_stack。

对于我自己来说，我通过在 stack_shiftt: 中添加一行来解决这个问题：

self.temp=d   

并在 min_normalization 中使用 self.temp 。

但至于正确的决定呢？

Answer 1

我其实不明白这个问题。为什么不能将 min_active_stack() 的结果通过 stack_shift() 传递到 min_normalization() 中？

def stack_shift(res):
    # do something usefull
    return res

或者因为看起来您想在 stack_shift 中执行异步操作，所以 Deferred 等效项：

def stack_shift(res):
    d = runQuery(query)
    d.addCallback(lambda ignored: res)
    return d