python - 交叉开关 : How to publish a message on a topic using a Django service?

Question

我刚开始使用 Crossbar.io 来实现实时统计页面。我看过很多代码示例，但我不知道该怎么做:

我有一个 Django 服务(为避免混淆，您可以假设我在谈论 views.py 中的一个函数)并且我希望它在被调用时发布特定主题的消息。我见过这些方法:(1) Extending ApplicationSession和 (2) using an Application instance that is "runned" .

它们都不适合我，因为 Django 服务不在类中，也不作为独立的 python 文件执行，所以我找不到调用“发布”方法的方法(这是我唯一想在服务器端做的事情)。

我试图获取“StatsBackend”的一个实例，它扩展了 ApplicationSession，并发布了一些东西......但是 StatsBackend._instance 始终为 None(即使当我执行“crossbar start”和 StatsBackend.init() 被调用)。

统计后端.py:

from twisted.internet.defer import inlineCallbacks
from autobahn import wamp
from autobahn.twisted.wamp import ApplicationSession

class StatsBackend(ApplicationSession):

    _instance = None

    def __init__(self, config):
        ApplicationSession.__init__(self, config)
        StatsBackend._instance = self

    @classmethod
    def update_stats(cls, amount):
        if cls._instance:
            cls._instance.publish('com.xxx.statsupdate', {'amount': amount})

    @inlineCallbacks
    def onJoin(self, details):
        res = yield self.register(self)
        print("CampaignStatsBackend: {} procedures registered!".format(len(res)))

测试.py:

import StatsBackend

StatsBackend.update_stats(100) #Doesn't do anything, StatsBackend._instance is None

Answer 1

Django 是一个阻塞的 WSGI 应用程序，它不能很好地与 AutobahnPython 融合，后者是非阻塞的(在 Twisted 或 asyncio 之上运行)。

但是，Crossbar.io 有一个内置的 REST 桥，其中包括一个 HTTP Pusher您可以通过任何支持 HTTP/POST 的客户端向其提交事件。 Crossbar.io 会将这些事件转发给常规 WAMP 订阅者(例如，通过 WebSocket 实时转发)。

Crossbar.io 还附带了一个完整的应用程序模板来演示上述功能。尝试:

cd ~/test1
crossbar init --template pusher
crossbar start

在 http://localhost:8080(打开 JS 控制台)和第二个终端中打开浏览器

curl -H "Content-Type: application/json" \
   -d '{"topic": "com.myapp.topic1", "args": ["Hello, world"]}' \
   http://127.0.0.1:8080/push

然后您可以从 Django 等阻塞应用程序中进行发布。