How to use paho mqtt client in django?


If you need Django running in multiple threads then to publish messages from your Django app you can use helper functions from Publish module of Paho - You don't need to create an instance of mqtt client and start a loop in this case. And to subscribe to some topic consider running mqtt client as a standalone script and import there needed modules of your Django app (and don't forget to setup the Django environment in the script).

The answer below is good only if you run Django in a single thread, which is not usual in production.

Create in your application folder and put all related code there. For example:

import paho.mqtt.client as mqtt

def on_connect(client, userdata, rc):

def on_message(client, userdata, msg):
    # Do something

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect("", 1883, 60)

Don't call loop_forever() here!

Then in your application call loop_start():

from . import mqtt


Using loop_start() instead of loop_forever() will give you not blocking background thread.