安装MQTT
Python环境下安装MQTT也很简单，需要注意的就是不要输错命令
在Python3环境下安装Python MQTT的命令是：
|
1
|
pip3 install paho-mqtt |
使用Python MQTT
编写Python MQTT脚本
代码如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
# 为了能在外部脚本中调用Django ORM模型，必须配置脚本环境变量，将脚本注册到Django的环境变量中import os, sysimport django# 第一个参数固定，第二个参数是工程名称.settingsos.environ.setdefault('DJANGO_SETTING_MODULE', 'my_django.settings')django.setup()# 引入mqtt包import paho.mqtt.client as mqtt# 使用独立线程运行from threading import Threadfrom app名 import modelsimport timeimport 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 中引入要执行的脚本文件，然后执行启动函数即可。
如：
|
1
2
3
|
from 存放MQTT脚本的模块 import 脚本名# 假如脚本名是：mqtt_functionsmqtt_functions.mqtt_run() |
到此这篇关于在Django中使用MQTT的方法的文章就介绍到这了,更多相关Django使用MQTT内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://blog.csdn.net/qq_36963372/article/details/88866459
