将装饰器方法与AutobahnWS一起使用，如何独立于订阅回调及其会话引用发布消息？

Question

在使用Autobahn和WAMP之前，我一直在使用子类化方法，但偶然发现了装饰器/函数方法，我真的很喜欢子类化。

然而。我有一个从外部硬件(通过回调(调用的函数，每当调用该函数时，都需要发布到路由器 Crossbar.io。

这就是我的做法，在调用on_join -> async def joined(session, details)后立即保留Session的引用。

from autobahn.asyncio.component import Component
from autobahn.asyncio.component import run
global_session = None
comp = Component(
    transports=u"ws://localhost:8080/ws",
    realm=u"realm1",
)
def callback_from_hardware(msg):
    if global_session is None:
        return
    global_session.publish(u'com.someapp.somechannel', msg)
@comp.on_join
async def joined(session, details):
    global global_session
    global_session = session
    print("session ready")
if __name__ == "__main__":
    run([comp])

然而，这种在组件加入连接后保留引用的方法感觉有点"奇怪"。有没有不同的方法？这可以通过其他方式完成吗？

如果不是，那么子类化和将所有应用程序依赖的代码都放在该子类中感觉更"正确"(但是将我应用程序的所有内容保留在一个子类中也感觉很奇怪(。

Answer 1

我建议使用异步队列而不是共享会话：

import asyncio
from autobahn.asyncio.component import Component
from autobahn.asyncio.component import run
queue = asyncio.queues.Queue()
comp = Component(
    transports=u"ws://localhost:8080/ws",
    realm=u"realm1",
)

def callback_from_hardware(msg):
    queue.put_nowait((u'com.someapp.somechannel', msg,))

@comp.on_join
async def joined(session, details):
    print("session ready")
    while True:
        topic, message, = await queue.get()
        print("Publishing: topic: `%s`, message: `%s`" % (topic, message))
        session.publish(topic, message)

if __name__ == "__main__":
    callback_from_hardware("dassdasdasd")
    run([comp])

Answer 2

你可以在这里采取多种方法，尽管最简单的IMO是使用Crossbar的http桥。因此，每当从您的硬件收到事件回调时，您只需向 Crossbar 发出 http POST 请求，您的消息就会被传递

有关 http 桥接 https://crossbar.io/docs/HTTP-Bridge-Publisher/的更多详细信息