commands/management/commands/mqtt.py

@@ -4,7 +4,7 @@ import logging

                 import random
              

                 import time
              

                 
              

                -from django_six import CompatibilityBaseCommand
              

                +from django_six import CompatibilityBaseCommand, close_old_connections
              

                 from paho.mqtt import client as mqtt_client
              

                 
              

                 from api.eqpt_views import mqtt_upload_temperature
              
@@ -87,7 +87,9 @@ def subscribe(client: mqtt_client):

                         # }
              

                         payload = msg.payload.decode()
              

                         print(f'Received `{payload}` from `{msg.topic}` topic')
              

                +        close_old_connections()
              

                         mqtt_upload_temperature(payload)
              

                +        close_old_connections()
              

                 
              

                     client.subscribe(topic)
              

                     client.on_message = on_message