python manage.py shell

python manage.py shell < my.py

import os
import django
os.environ["DJANGO_SETTINGS_MODULE"] = 'myprojects.settings'
django.setup()
import paho.mqtt.client as paho_mqtt
from mqtt.mqtt import on_connect, on_message
username = "****"
password = "****"

client = paho_mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.username_pw_set(username=username, password=password)
client.connect("********", 1883, 60)

client.loop_forever()

def on_connect(client, userdata, flags, rc):
    try:
        client.subscribe(topic="********")
        print('subcriptions')
    except Exception as e:

        print("connect subscribe error " + str(e))


def on_message(client, userdata, msg):
    data = msg.payload.decode('utf-8')
    res_json = json.loads(data)
    print(res_json)