0

I am working on a project which is eventually going to be a website displaying device data with the option to control these devices. I am currently working on the code in python using Paho MQTT Python library. I successfully managed to send and receieve ecrypted messages via mosquitto broker. I have created a client which is a sort of monitoring client that subscribes to a wildcard topic in order to receieve all messages going through the broker and is eventually going to store them into a database. I am using django 2.1.5, mosquitto broker 1.5, working in python.

The problem I am facing right now is that I can't figure out a way to send messages to the mosquitto broker as soon as a database change happens. Let's say I have a website that shows all connected devices and I want to turn one off, I'd click a button, that would change a database table, then a message has to be send to the broker to notify the device that it should switch off. I know I can make the website a client, which would then use MQTT over websockets but that is not a desirable option.

I tried django signals, which seems to work fine. The problem is that the function that the django signal triggers creates a new instance of a new mqtt client. I would like the already running monitoring client to send the message, that is trigger one of its defined functions which would send the message whenever a signal is sent.

class Post(models.Model):
    title = models.CharField(max_length=50)
    def __str__(self):
        return self.title

def save_post(sender, instance, **kwargs):
    message = {
        "client_id": "abc",
        "message": "Created new model: " + str(instance),
    }
     publish.single("house/StateServer/receive", 
         payload=json.dumps(message), 
         port=8081, hostname="localhost", retain=False, 
         auth = {'username':"abc", 'password':"abc"}, 
         client_id="abc",tls = {"ca_certs":"","certfile":"","keyfile":"",})


post_save.connect(save_post, sender=Post)

I would like the "save_post" function to trigger a function of the monitoring client that is running 24/7 and is stored in a different file, let's say "monitor.py". This function of the monitoring client would receieve the desired data: the payload of the message and the topic of the end device, and send it to the mosquitto broker.

hardillb
  • 54,545
  • 11
  • 67
  • 105
Ondřej Holík
  • 31
  • 5

2 Answers2

0

I recently had to do something similar from a django post_save. In my case, the equivalent "different file monitor.py" running as a different process launches a thread running a simple SimpleHTTPServer which does all the work of publishing. This allows you to do things asynchrounosly as well since your SimpleHTTPServer could add the received data to be published to a queue and let another thread handle the publish part while your POST handler returns right away.

For reference there is an SO about json and simplehttpserver here: Reading JSON from SimpleHTTPServer Post data

jnvilo
  • 157
  • 1
  • 10
  • I don't see a big difference between my solution and yours. Is there a difference in terms of performance? – Ondřej Holík Feb 19 '19 at 14:40
  • That is correct. I just telling you the way I did it when I wanted to do things outside of post_save in another process. You can use RPC instead of http or you can use multiprocessing wtih queues for communication. Honestly I do not see big performance improvement since it seems publish.single seems to be async already. – jnvilo Feb 20 '19 at 09:56
0

Yes you can do it in post_save signal See this answer. But I would recommend doing in a thread and you can keep qos=2 for delivery but it wont guarantee in case you want the acknowledgement publish back from receiver

Yugandhar Chaudhari
  • 3,831
  • 3
  • 24
  • 40
  • I am sorry but I don't see how this thread solves my problem, could you please elaborate a bit more? My main problem is the running mqtt client sending the message, not creating a new one every time I need to send a message. – Ondřej Holík Feb 19 '19 at 14:42