Python DBus 中异步方法的实现

Question

如何在 Python DBus 中实现异步方法？下面的例子：

class LastfmApi(dbus.service.Object):
    def __init__(self):
        bus_name = dbus.service.BusName('fm.lastfm.api', bus=dbus.SessionBus())
        dbus.service.Object.__init__(self, bus_name, '/')

    @dbus.service.method('fm.last.api.account', out_signature="s")
    def getUsername(self):
        ## How do I get this method done asynchronously ??
        ##  For example, this method should go off and retrieve the "username"
        ##  asynchronously. When this method returns, the "username" isn't available
        ##  immediately but will be made available at a later time.

我正在使用 Twisted 的 glib2 反应器。

更新：我知道这种行为是可以实现的 - DBus 包含方法调用的“序列”（唯一标识符），并且被调用的方法可以访问此标识符，以便将“调用”与“回复”相匹配”。

Answer 1

我还没有尝试过这个，但是阅读 dbus.service.method 的文档揭示了 async_callbacks 参数。听起来像是使用此参数来提供异步结果。例如：

@dbus.service.method('fm.last.api.account', out_signature="s",
                     async_callbacks=("callback", "errback"))
def getUsername(self, callback, errback):
    reactor.callLater(3, callback, "alice")

如果您有一个返回 Deferred 的 API，那么您可以轻松地将 Deferred 与这些回调关联起来：

d.addCallbacks(callback, errback)

就调用和响应之间的相关性而言，我假设所有序列号处理都隐藏在 <代码>dbus.service.method。我怀疑当您使用 async_callbacks 功能时传入的回调和 errback 函数要么是某个可调用且具有序列号作为属性的类的实例，要么被定义为嵌套函数并关闭序列号。这样，当您调用其中一个时，它们可以确保将正确的值传递回连接，以将响应与原始请求相关联。

然而，这只是根据您提到的序列号和我实现各种异步系统的经验而进行的稍微有根据的猜测。 :) 阅读 dbus.service.method 的实现可能会揭示实际的策略，而不会造成太大的痛苦。

（好吧，我现在实际上去查看了实现，不幸的是它相当复杂，当它到达 C 级 dbus 绑定中定义的一些代码时我丢失了踪迹，这比我更深入地挖掘我仍然怀疑我上面描述的总体想法是正确的，但实现的细节比我预期的要复杂。）