在Django中使用MQTT的方法_Python

安装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内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！

原文链接：https://blog.csdn.net/qq_36963372/article/details/88866459

在Django中使用MQTT的方法

安装MQTT

使用Python MQTT

在Django项目中启动脚本

相关文章

热门资讯