在Django中使用MQTT的方法
安裝MQTT
Python環境下安裝MQTT也很簡單,需要註意的就是不要輸錯命令
在Python3環境下安裝Python MQTT的命令是:
pip3 install paho-mqtt
使用Python MQTT
編寫Python MQTT腳本
代碼如下:
# 為瞭能在外部腳本中調用Django ORM模型,必須配置腳本環境變量,將腳本註冊到Django的環境變量中 import os, sys import django # 第一個參數固定,第二個參數是工程名稱.settings os.environ.setdefault('DJANGO_SETTING_MODULE', 'my_django.settings') django.setup() # 引入mqtt包 import paho.mqtt.client as mqtt # 使用獨立線程運行 from threading import Thread from app名 import models import time import json # 建立mqtt連接 def on_connect(client, userdata, flag, rc): print("Connect with the result code " + str(rc)) client.subscribe('test/#', qos=2) # 接收、處理mqtt消息 def on_message(client, userdata, msg): out = str(msg.payload.decode('utf-8')) print(msg.topic) print(out) out = json.loads(out) # 收到消息後執行任務 if msg.topic == 'test/newdata': print(out) # mqtt客戶端啟動函數 def mqttfunction(): global client # 使用loop_start 可以避免阻塞Django進程,使用loop_forever()可能會阻塞系統進程 # client.loop_start() # client.loop_forever() 有掉線重連功能 client.loop_forever(retry_first_connection=True) client = mqtt.Client(client_id="test", clean_session=False) # 啟動函數 def mqtt_run(): client.on_connect = on_connect client.on_message = on_message # 綁定 MQTT 服務器地址 broker = '192.168.1.88' # MQTT服務器的端口號 client.connect(broker, 1883, 62) client.username_pw_set('user', 'user') client.reconnect_delay_set(min_delay=1, max_delay=2000) # 啟動 mqttthread = Thread(target=mqttfunction) mqttthread.start() # 啟動 MQTT # mqtt_run() if __name__ == "__main__": mqtt_run()
在Django項目中啟動腳本
在Django2.1下,隻需要在 wsgi.py 中引入要執行的腳本文件,然後執行啟動函數即可。
如:
from 存放MQTT腳本的模塊 import 腳本名 # 假如腳本名是:mqtt_functions mqtt_functions.mqtt_run()
到此這篇關於在Django中使用MQTT的方法的文章就介紹到這瞭,更多相關Django使用MQTT內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!
推薦閱讀:
- Python中使用matplotlib繪制mqtt數據實時圖像功能
- 使用 Node-RED對 MQTT 數據流處理
- springboot+rabbitmq實現智能傢居實例詳解
- 分佈式消息隊列RocketMQ概念詳解
- 前端與RabbitMQ實時消息推送未讀消息小紅點實現示例