python - Crossbar.io:如何使用Django服务发布有关主题的消息？

我刚开始使用Crossbar.io来实现一个实时统计页面。我看过很多代码示例，但我不知道如何做到这一点：
我有一个Django服务（为了避免混淆，您可以假设我在views.py中讨论的是一个函数），我希望它在每次被调用时都在特定的主题中发布消息。我见过这些方法：（1）Extending ApplicationSession和（2）using an Application instance that is "runned"。
它们都不适合我，因为Django服务不在类中，也不是作为独立的python文件执行的，所以我找不到调用“publish”方法的方法（这是我在服务器端唯一想做的事情）。
我试图获取“StatsBackend”的一个实例，它扩展了ApplicationSession，并发布了一些东西。。。但是StatsBackend.\u instance始终不是（即使我执行'crossbar start'并调用StatsBackend.init（））。
StatsBackend.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

最佳答案

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这样的阻塞应用程序中进行发布。