Django MQTT Subscriber сохранение в базе данных и обновление представления

Я создаю живую приборную панель для данных о гонках, где тайминги и другая информация будут публиковаться несколькими клиентами на основе каждого круга. В качестве брокера я использую Mosquitto. Руководствуясь этим решением, я могу подписаться на различные темы и увидеть опубликованные результаты.

on_message received from lap_data QOS:0 retain:False - `{"LapCompleted": 32 ... }` 
on_message received from weather_data QOS:0 retain:False - `{ "RelativeHumidity":0.449}

Я прошел учебник по чату каналов и запустил Redis на WSL.

Теперь я хотел бы:

  1. добавьте полученные сообщения в базу данных
    2. .
  2. обновляйте представление при получении сообщения.

Я надеялся, что смогу добавлять записи через on_message_callback, но когда я пытаюсь импортировать модели в мой файл MQTTClient.py, я получаю следующую ошибку:

raise AppRegistryNotReady("Apps aren't loaded yet.")
django.core.exceptions.AppRegistryNotReady: Apps aren't loaded yet.

Если кто-нибудь сможет указать мне правильное направление для 1 & 2, я буду благодарен.

Спасибо. MQTT запускается через функцию готовности приложения

def ready(self):
    if os.environ.get('RUN_MAIN'):
        mqtt_client = MqttRemote()
        mqtt_client.start()
Вернуться на верх