树莓派MQTT的物联网IOT方案案例

在之前的文章里已经简单介绍了MQTT协议,这里结合树莓派+按钮开关(输入)和继电器(输出)制作一个简单的物联网MQTT案例来演示现场端设备与云端服务器的数据信息采集和远程控制功能。

案例流程架构图:


数据采集:
现场端按钮开关的开关状态情况还有树莓派自身的信息,通过树莓派联网发送到云端服务器,人可以用手机或电脑在云端网站页面里看到信息。

远程控制:
人在人可以用手机或电脑在云端网站网站页面里进行点击输入操作,树莓派接收到云服务器发来的远程控制指令,树莓派通过GPIO接口通断信号控制现场继电器的吸合和断开。

准备阶段工作:
现场端工作:
1、准备好树莓派主板通上电,安装好Raspberry Pi OS系统
2、按钮开关和继电器接到树莓派的GPIO模块接口
云端网站工作:
1、准备好云端服务器配置好网络和IP,这里安装好LAMP网站应用环境(Linux+Apache+Mysql+PHP/Python),关键是mysql数据库结构,为之后的python编程和网站编程制作做好数据对接准备
2、安装MQTT服务端,关键是构思好发送和订阅的数据结构,为之后的python编程做发送指令和接受信息的拼接、转变、解析等做准备。

python编程阶段工作:
一、树莓派里运行的python:
1、按钮开关的数据采集:
(1)监控GPIO输入状态
(2)MQTT发布:状态信息
2、控制输出给继电器:
(1)订阅MQTT信息
(2)控制GPIO输出
(3)MQTT发布:回复控制状态
3、树莓派自身信息的心跳数据:
(1)获取树莓派自身数据信息
(2)MQTT发布:树莓派心跳信息
二、服务器里运行的python:
1、数据采集:
订阅MQTT各种数据消息,数据放入mysql
2、远程控制:
(1)收到mysql里控制线圈信息
(2)发布MQTT消息:控制线圈

PHP网站搭建阶段工作:
1、这里做法是用html/CSS/JS制作如上图里的前端人机交互的页面,显示相关数据信息和设置按钮操作。
2、后台里用PHP做html页面与mysql数据库之间的数据对接传输分析转换的接口用来调取。

这里用最简单的开关量设备案例做演示说明,举一反三现场端的其他类型设备,比如Modbus、温度、湿度、串口等,也可通过这样的方式做物联网的数据采集传输分析和远程控制

MQTT结合Python将树莓派与云端组网

MQTT(消息队列遥测传输)是ISO 标准(ISO/IEC PRF 20922)下基于发布/订阅范式的消息协议。它工作在 TCP/IP协议族上,是为硬件性能低下的远程设备以及网络状况糟糕的情况下而设计的发布/订阅型消息协议,MQTT是一个基于客户端-服务器的消息发布/订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。在很多情况下,包括受限的环境中,如:机器与机器(M2M)通信和物联网(IoT)。其在,通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。

安装MQTT:
apt-get install mosquitto
apt-get install mosquitto-clients
apt-get install mosquitto-dev

本机测试:
打开一个终端,执行以下命令订阅主题”mqtt”
mosquitto_sub -h localhost -t “mqtt” -v

打开另外一个终端,发布消息到主题 “mqtt”
mosquitto_pub -h localhost -t “mqtt” -m “Hello MQTT”

现在你会看到消息被显示在前一个终端上了
将localhost更换成服务器IP就是可远程操作MQTT

 

MQTT添加用户权限:
编辑文件:sudo nano /etc/mosquitto/mosquitto.conf
添加如下信息:
allow_anonymous false       #不允许匿名使用
password_file /etc/mosquitto/pwfile  #用户账号密码文件位置

添加用户指令:
sudo mosquitto_passwd -c /etc/mosquitto/pwfile {用户名}
然后输入确认密码

MQTT服务重启:
sudo mosquitto -c /etc/mosquitto/mosquitto.conf
sudo service mosquitto restart
或重启服务器 sudo reboot

测试用户权限,发送和订阅指令带有用户信息
mosquitto_sub -h localhost -t “mqtt” -v -u {用户名} -P {密码}
mosquitto_pub -h localhost -t “mqtt” -u {用户名} -P {密码} -m “Hello MQTT”

MQTT调试工具MQTT.fx 是目前主流的mqtt客户端,可以快速验证是否可以与IoT Hub 服务交流发布或订阅消息。

Python paho-mqtt 模块使用
安装:pip install paho-mqtt

MQTT订阅消息的python案例:
import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
print(“Connected with result code “+str(rc))

def on_message(client, userdata, msg):
print(msg.topic+” “+str(msg.payload))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect(“{ip}”, 1883, 60)
client.loop_forever()

MQTT发布消息的python案例:
import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
print(“Connected with result code “+str(rc))

def on_publish(client, userdata, msg):
print(“payload=”,payload)

payload = {‘key’:’value’}

client = mqtt.Client()
client.on_connect = on_connect
client.on_publish = on_publish
client.connect(“{ip}”, 1883, 60)
client.publish(‘mqtt’,payload=str(payload),qos=0)

MQTT中的QoS等级
MQTT设计了一套保证消息稳定传输的机制,包括消息应答、存储和重传。在这套机制下,提供了三种不同层次QoS(Quality of Service):

QoS0,At most once,至多一次;
QoS1,At least once,至少一次;
QoS2,Exactly once,确保只有一次。
QoS 是消息的发送方(Sender)和接受方(Receiver)之间达成的一个协议:

QoS0 代表,Sender 发送的一条消息,Receiver 最多能收到一次,也就是说 Sender 尽力向 Receiver 发送消息,如果发送失败,也就算了;
QoS1 代表,Sender 发送的一条消息,Receiver 至少能收到一次,也就是说 Sender 向 Receiver 发送消息,如果发送失败,会继续重试,直到 Receiver 收到消息为止,但是因为重传的原因,Receiver 有可能会收到重复的消息;
QoS2 代表,Sender 发送的一条消息,Receiver 确保能收到而且只收到一次,也就是说 Sender 尽力向 Receiver 发送消息,如果发送失败,会继续重试,直到 Receiver 收到消息为止,同时保证 Receiver 不会因为消息重传而收到重复的消息。

QoS等级使用建议
在以下情况下你可以选择 QoS0:
Client 和 Broker 之间的网络连接非常稳定,例如一个通过有线网络连接到 Broker 的测试用 Client;可以接受丢失部分消息,比如你有一个传感器以非常短的间隔发布状态数据,所以丢一些也可以接受;
你不需要离线消息。

在以下情况下你应该选择 QoS1:
你需要接收所有的消息,而且你的应用可以接受并处理重复的消息;
你无法接受 QoS2 带来的额外开销,QoS1 发送消息的速度比 QoS2 快很多。

在以下情况下你应该选择 QoS2:
你的应用必须接收到所有的消息,而且你的应用在重复的消息下无法正常工作,同时你也能接受 QoS2 带来的额外开销。

 

python 文件处理方法简介

利用python处理文件

一、File(文件) 方法
打开文件:open(file, mode=’r’)
关闭文件:file.close()
读取文件:file.read([size])、file.readline([size])、file.readlines([sizeint])
移动文件读取指针到指定位置:file.seek(offset[, whence])
写入文件:file.write(str)、file.writelines(sequence)

二、EXCEL文件
python对于excel文件有处理模块:读取用xlrd、写入用xlwt
安装命令:pip install xlrd
引用代码:import xlrd
官网:http://www.python-excel.org/

三、配置文件
比如配置文件config.ini或config.txt
安装命令:pip install configparser
引用代码:import configparser
pypi:https://pypi.org/project/configparser/

 

辰匠科技IOT物联网方案:基于树莓派GPIO的温度数据采集

温度(temperature)是表示物体冷热程度的物理量,微观上来讲是物体分子热运动的剧烈程度。

温度传感器(temperature transducer)是指能感受温度并转换成可用输出信号的传感器。温度传感器是温度测量仪表的核心部分,品种繁多。按测量方式可分为接触式和非接触式两大类,按照传感器材料及电子元件特性分为热电阻和热电偶两类。

这里先介绍可直接利用树莓派GPIO端口的温度传感器:DHT11和DS18B20。其他的温度传感器PT100温度传感器WZP-PT100热电偶/阻 PT100铂电阻+智能巡检仪的温度数据采集方案将会在之后的文章关于modbus的部分做介绍。

(一)DHT11是一款有已校准数字信号输出的温湿度传感器。其精度湿度+-5%RH, 温度+-2℃,量程湿度20-90%RH, 温度0~50℃。其单串口进行通讯输出温湿度信息。

将DHT传感器引脚接入树莓派GPIO接口,方案的原理其实是由树莓派GPIO发出脉冲信号给DHT11传感器,DHT11再发出温湿度信息的脉冲给树莓派GPIO接口。

这里就不介绍如何用python编程如何发脉冲通信,这里推荐使用python的模块Adafruit-DHT。

安装命令:sudo pip3 install Adafruit_DHT。

python编程模块引用一般是:import Adafruit_DHT。

这样就可以将DHT11传感器的温度信息转变成程序里的变量来利用

详细内容可参见pypi。

(二)DS18B20是常用的数字温度传感器,其输出的是数字信号,具有体积小,硬件开销低,抗干扰能力强,精度高的特点。

将模块封装后可以测空气温度或是水温。

DS18B20与树莓派GPIO端口相接,其实与DHT11用法相似。

这里就不介绍如何用python编程如何发脉冲通信,这里推荐使用python的模块ds18b20pi。

安装命令:sudo pip3 install ds18b20pi。

python编程模块引用一般是:import ds18b20pi。

这样就可以将DS18B20传感器的温度信息转变成程序里的变量来利用

详细内容可参见pypi。

特别提示:DS18B20传感器是可以并联的,即一个GPIO端口可以采集多个DS18B20传感器数据的,在python程序里会以字典形式存在。

温度采集方案搞定后,将数据采集传送到云服务器的数据库里,接下来就可制作人机用户界面了,在手机或电脑等终端查看采集到的温度数据。

之后还可以对数据做可视化分析,这里建议按每分钟对采集的数据做统计分析,每分钟会采集到多个数值,记录每分钟的初始值、最终值、最大值、最小值用K线图表示。

DHT11温湿度曲线

DS18B20温度曲线

通过数据查看,会发现DS18B20比DHT11的稳定性要好、数据正确率高。

因此建议:

比如要利用温度做设备控制,精度要求高的场景下建议用DS18B20。

如果需要既要测温又要测湿度而且成本要再低些,不需要做其他设备关联控制仅是观察读数的建议使用DHT11。

辰匠科技愿与大家一同合作,一起玩转物联网!

树莓派运行python代码

Python是一种跨平台的计算机程序设计语言。是一种面向对象的动态类型语言,最初被设计用于编写自动化脚本(shell),随着版本的不断更新和语言新功能的添加,越来越多被用于独立的、大型项目的开发。可以应用于以下领域:Web 和 Internet开发、科学计算和统计、物联网、人工智能、教育、桌面界面开发、软件开发、后端开发。

Python 是一种解释型、面向对象、动态数据类型的高级程序设计语言。Python 由 Guido van Rossum 于 1989 年底发明,第一个公开发行版发行于 1991 年。像 Perl 语言一样, Python 源代码同样遵循 GPL(GNU General Public License) 协议。官方宣布,2020 年 1 月 1 日, 停止 Python 2 的更新。Python 2.7 被确定为最后一个 Python 2.x 版本。

树莓派官方系统Raspbian,可利用命令终端lxterminal,使用命令python或python3 XXX.py文件,就可以运行python代码。

案例:
$ python3 hello.py

python有许多功能包,可以利用pip或pip3(对应python版本)命令管理功能模块。
比如控制树莓派GPIO模块的功能包安装指令:
pip3 install gpio
pip详情可参见:https://pypi.org/