Каналы Django с MQTT

Пытаюсь создать websocket с помощью django channels и интегрировать mqtt с каналами, а сообщение mqtt publish должно быть получено функцией внутри consumer.py и отправлено клиенту websocket. У меня есть канал потребителя, как показано ниже

consumer.py

from channels.consumer import AsyncConsumer
from paho.mqtt import client as Mqtt

class Testing(AsyncConsumer):
    async def websocket_connect(self, event):
        obj = Mqtt.Client()  
        obj.connect("localhost", 1883, 60)
        obj.on_message = self.updater
        obj.subscribe("Testing")
        obj.loop_start()


    async def updater(self, arg1, arg2, message):
           print(message)
           await self.send({
                "type": "websocket.send",
                "text": message})

    async def websocket_receive(self, text_data):
        pass

В приведенном выше примере mqtt соединение произошло, но если я публикую сообщение в теме, оно не работает. Функция updater внутри consumer.py не вызывается. Как этого добиться?

Вернуться на верх