Python使用MQTT连接新版ONENet

Python MQTT 连接新版ONENet

简介

前几个教程我们使用mqtt.fx连接了新版的ONENet, 只是跑通了MQTT协议，但是在实际操作下还需要实现具体环境、具体设备的MQTT连接，本章教程将以Python MQTT的方式连接 ONENet

参考文档：

paho-mqtt · PyPI

OneNET - 中国移动物联网开放平台 (10086.cn)

准备环境

pip安装 paho-mqtt

pip install paho-mqtt

获取ONENet 三元组

准备好Onenet的三元组
在这里插入图片描述

三元组分别为

DeviceName=“wenshidap” #设备ID

Productid = “kuerSLKlo8” #产品ID

accesskey=“QUR4cEhqcVRCSHowQ01QdXE3QTVIUmRDblpoOHU1aFk=”#秘钥

根据ONENet手册的文档说明，mqtt连接onenet需要进行鉴权，可以访问链接查看鉴权算法，但是我们可以根据鉴权算法说明生成鉴权的秘钥

使用Pyhon生成的鉴权秘钥的函数为

#认证token生成函数
def get_token(id,access_key):version = '2018-10-31'#   res = 'products/%s' % id  # 通过产品ID访问产品API# res = 'userid/%s' % id  # 通过产品ID访问产品APIres="products/"+ Productid + "/devices/" + DeviceName# 用户自定义token过期时间et = str(int(time.time()) + 36000000)# et = str(int(1722499200))# 签名方法，支持md5、sha1、sha256method = 'sha1'method1 = 'sha256'# 对access_key进行decodekey = base64.b64decode(access_key)# 计算signorg = et + '\n' + method+ '\n' + res + '\n' + versionsign_b = hmac.new(key=key, msg=org.encode(), digestmod=method)sign = base64.b64encode(sign_b.digest()).decode()# value 部分进行url编码，method/res/version值较为简单无需编码sign = quote(sign, safe='')res = quote(res, safe='')# token参数拼接token = 'version=%s&res=%s&et=%s&method=%s&sign=%s' % (version, res, et, method, sign)return token

MQTT订阅和发布Topic说明

我们可以点击产品开发->设备开发->topic管理->数据流topic来查看当前设备可以订阅哪些topic，在这里我们是上传数据流，所以我们只关心发布的topic 和订阅上传成功和上传失败的topic

在这里插入图片描述

发布的topic :$sys/kuerSLKlo8/{device-name}/dp/post/json

只需要将我们的device-name换成当前的devicename即可 在本项目就是wenshidap

即：$sys/kuerSLKlo8/wenshidap/dp/post/json

订阅的topic:

上传成功：$sys/kuerSLKlo8/{device-name}/dp/post/json/accepted

上传失败：$sys/kuerSLKlo8/{device-name}/dp/post/json/rejected

当我们订阅上传成功topic时，数据流上传成功后就会返回msg的id 失败时 reject topic就会返回失败的原因

MQTT连接ONENet主程序

import paho.mqtt.client as mqtt
from paho.mqtt.client import MQTTv311
import struct
import json
import base64
import hmac
import time
from urllib.parse import quoteServerUrl = "mqtts.heclouds.com" #服务器url
ServerPort = 1883#服务器端口
DeviceName="wenshidap" #设备ID
Productid = "kuerSLKlo8" #产品ID
accesskey="QUR4cEhqcVRCSHowQ01QdXE3QTVIUmRDblpoOHU1aFk="# 发布的topic
Pub_topic1 = "$sys/"+Productid+"/"+ DeviceName+"/dp/post/json"#需要订阅的topic
#数据上传成功的消息
Sub_topic1 = "$sys/"+Productid+"/"+DeviceName+"/dp/post/json/accepted"
#接收数据上传失败的消息
Sub_topic2 = "$sys/"+Productid+"/"+DeviceName+"/dp/post/json/rejected"#测试用json数据格式
jsonstr = "{\"id\": 123,\"dp\": {\"ConEnv_Temp\": [{\"v\": 22.1}],\"ConEnv_Humi\": [{\"v\": 61.2}]}}"#认证token生成函数
def get_token(id,access_key):version = '2018-10-31'#   res = 'products/%s' % id  # 通过产品ID访问产品API# res = 'userid/%s' % id  # 通过产品ID访问产品APIres="products/"+ Productid + "/devices/" + DeviceName# 用户自定义token过期时间et = str(int(time.time()) + 36000000)# et = str(int(1722499200))# 签名方法，支持md5、sha1、sha256method = 'sha1'method1 = 'sha256'# 对access_key进行decodekey = base64.b64decode(access_key)# 计算signorg = et + '\n' + method+ '\n' + res + '\n' + versionsign_b = hmac.new(key=key, msg=org.encode(), digestmod=method)sign = base64.b64encode(sign_b.digest()).decode()# value 部分进行url编码，method/res/version值较为简单无需编码sign = quote(sign, safe='')res = quote(res, safe='')# token参数拼接token = 'version=%s&res=%s&et=%s&method=%s&sign=%s' % (version, res, et, method, sign)return tokendef on_subscribe(client, userdata, mid, reason_code_list, properties):# Since we subscribed only for a single channel, reason_code_list contains# a single entryif reason_code_list[0].is_failure:print(f"Broker rejected you subscription: {reason_code_list[0]}")else:print(f"Broker granted the following QoS: {reason_code_list[0].value}")def on_unsubscribe(client, userdata, mid, reason_code_list, properties):# Be careful, the reason_code_list is only present in MQTTv5.# In MQTTv3 it will always be emptyif len(reason_code_list) == 0 or not reason_code_list[0].is_failure:print("unsubscribe succeeded (if SUBACK is received in MQTTv3 it success)")else:print(f"Broker replied with failure: {reason_code_list[0]}")client.disconnect()# 当客户端收到来自服务器的CONNACK响应时的回调。也就是申请连接，服务器返回结果是否成功等
def on_connect(client, userdata, flags, reason_code, properties):if reason_code.is_failure:print(f"Failed to connect: {reason_code}. loop_forever() will retry connection")else:# we should always subscribe from on_connect callback to be sure# our subscribed is persisted across reconnections.# client.subscribe("$SYS/#")print("连接结果:" + mqtt.connack_string(reason_code))#连接成功后就订阅topicclient.subscribe(Sub_topic1)client.subscribe(Sub_topic2)# 从服务器接收发布消息时的回调。
def on_message(client, userdata, message):print(str(message.payload,'utf-8'))#当消息已经被发送给中间人，on_publish()回调将会被触发
def on_publish(client, userdata, mid):print(str(mid))def main():passw=get_token(DeviceName,accesskey)print(passw)mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2,DeviceName)mqttc.on_connect = on_connectmqttc.on_message = on_messagemqttc.on_subscribe = on_subscribemqttc.on_unsubscribe = on_unsubscribe# client = mqtt.Client(DeviceName,protocol=MQTTv311)#client.tls_set(certfile='/Users/mryu/PycharmProjects/MyProject/onenet/MQTTS-certificate.pem') #鉴权证书mqttc.connect(ServerUrl, port=ServerPort, keepalive=120)mqttc.username_pw_set(Productid,passw)mqttc.loop_start()while(1):mqttc.publish(Pub_topic1,jsonstr,qos=0)print("okk")time.sleep(2)if __name__ == '__main__':main()

运行测试一下

在这里插入图片描述

可以看到我们订阅的topic 返回了我们消息的ID 123 说明我们的数据上传成功 ，平台上也可以看到我们的数据流

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/web/17233.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

数据结构 顺序表

数据结构 顺序表

目录 1. 什么是数据结构？2. 顺序表2.1 线性表2.2 顺序表 3. 动态顺序表的实现 正文开始 1. 什么是数据结构？ 在学习顺序表前，我们先来了解一下什么是数据结构：数据结构是计算机存储、组织数据的方式，具有一定逻辑关系…
阅读更多...
用了那么久的可道云teamOS，居然才发现这个隐藏的功能：一键存图，无需下载

用了那么久的可道云teamOS，居然才发现这个隐藏的功能：一键存图，无需下载

在日常的工作或学习中，我们在遇到喜欢的图片时，总会想要保存下来以备后用。 然而，传统的图片保存方式通常需要我们右键另存为，或者复制链接、打开下载工具，甚至可能需要跳转到其他应用或网页才能完成下载。 存在电脑本…
阅读更多...
数据整理的Compact流程 （二）｜OceanBase数据转储合并技术解读（二）

数据整理的Compact流程 （二）｜OceanBase数据转储合并技术解读（二）

上篇文章《数据整理的Compact流程 （一）｜OceanBase数据转储合并技术解读（二）》中，有讲解到，在OceanBase数据库中，当MemTable写满时，将其下刷到Mini SSTable的过程包含两个…
阅读更多...
ubuntu移动硬盘重命名

ubuntu移动硬盘重命名

因为在ubuntu上移动硬盘的名字是中文的，所以想要改成英文的。 我的方法： 将移动硬盘插到windows上，直接右键重命名。再插到ubuntu上名字就改变了。 别人的方法： ubuntu下如何修改U盘名字-腾讯云开发者社区-腾讯云 在自带的软件…
阅读更多...
盘点10大灵动惊艳小演员❗谁是你的心头好？

盘点10大灵动惊艳小演员❗谁是你的心头好？

盘点国内影视那些惊艳观众的小演员们无疑为影视作品注入了新的活力。以下是10个备受赞誉的小演员： 1.韩昊霖：凭借在《我和我的祖国》和《庆余年》中的出色表现 韩昊霖的演技赢得了观众和业界的广泛认可 他能够准确地把握角色的情感和细节，展…
阅读更多...
雷达基数据绘制成雷达图

雷达基数据绘制成雷达图

x波段雷达基数据绘制成雷达图 1.雷达基数据格式Z_RADR_I_ZR001_20240521020002_O_DOR_YLD2-D_CAP_FMT.bin.bz2 2.基数据读取 python f StandardData(i) # 新版本标准数据radarTime f.scantime # 获取雷达时次date_str radarTime.strftime(%Y-%m-%d %H:%M:%S)date_str d…
阅读更多...
832. 翻转图像 - 力扣

832. 翻转图像 - 力扣

1. 题目 给定一个 n x n 的二进制矩阵 image ，先 水平 翻转图像，然后 反转 图像并返回 结果 。 水平翻转图片就是将图片的每一行都进行翻转，即逆序。 例如，水平翻转 [1,1,0] 的结果是 [0,1,1]。 反转图片的意思是图片中的 0 全部被…
阅读更多...
一.ffmpeg 将内存中的H264跟PCM 数据流合成多媒体文件

一.ffmpeg 将内存中的H264跟PCM 数据流合成多媒体文件

在有一些嵌入式平台中，H264数据流一般来自芯片内部的硬编码器， AAC音频数据则是通过采集PCM进行软编码，但是如何对它实时进行封装多媒体文件 ，参考ffmpeg example，花了一些时间终于实现了该功能。 流程图如下&#xf…
阅读更多...
【Pandas】深入解析`pd.read_pickle()`函数

【Pandas】深入解析`pd.read_pickle()`函数

【Pandas】深入解析pd.read_pickle()函数 🌈 欢迎莅临我的个人主页👈这里是我深耕Python编程、机器学习和自然语言处理（NLP）领域，并乐于分享知识与经验的小天地！🎇 🎓 博主简介&…
阅读更多...
Ora-32004错误处理

Ora-32004错误处理

问题现象 处理方法 观察alert会发现报错的参数在加载spfile的阶段 按照mos的方法对其reset 重新启动无报错 观察日志无报错
阅读更多...
ora-00392 ora-00312错误处理

ora-00392 ora-00312错误处理

检查当前日志组状态 对日志组进行clear操作 重新开库无报错
阅读更多...
java的变量关系~使用和扩展

java的变量关系~使用和扩展

一、变量的概述 1、什么是变量 白话:变量就是一个装东西的盒子。 通俗:变量是用于存放数据的容器。我们通过变量名 获取数据，甚至数据可以修改。 2、变量在内存中的存储 本质:变量是程序在内存中申请的一块用来存放数据的空间，类似我们酒店的房间&a…
阅读更多...
C++ (week5)：Linux系统编程3：线程

C++ (week5)：Linux系统编程3：线程

文章目录 三、线程1.线程的基本概念①线程相关概念②我的理解 2.线程的基本操作 (API)(1)获取线程的标识：pthread_self(2)创建线程：pthread_create()(3)终止线程①pthread_exit()：当前线程终止，子线程主动退出②pthread_cancel()&…
阅读更多...
OrangePi AIpro(8T) 基本介绍和资料汇总

OrangePi AIpro(8T) 基本介绍和资料汇总

OrangePi AIpro 基本介绍和资料汇总 1 介绍1.1 香橙派(Orange Pi) 公司概述1.2 OrangePi AIpro(8T) 介绍概述硬件规格参数引脚图产品详细图芯片优缺点优点 2 资料汇总2.1 官方资料概述资料下载 参考 1 介绍 1.1 香橙派(Orange Pi) 公司概述 香橙派（Orange Pi&…
阅读更多...
惊喜:我一晚上赚了10万！深扒挖瑞幸1.8亿起死回生的商业真相

惊喜:我一晚上赚了10万！深扒挖瑞幸1.8亿起死回生的商业真相

■ ■ ■ ■ 瑞幸咖啡 2020年1月，浑水报告发出后，瑞幸股价一路颠簸，最终退市停牌。 然而，19个月后，在粉单市场股价再次增长781.16% 暴雷后的19个月，瑞幸经历了怎样的起死回生？ 2020年4月2日…
阅读更多...
【RuoYi】如何启动RuoYi项目

【RuoYi】如何启动RuoYi项目

一、前言 最近，在做一个管理系统的项目，接触到了RuoYi这个前后端分离的框架，自己是第一次接触这个框架，所以刚开始有点好奇，在用该框架写了一些代码后。发现RuoYi这个框架做的真的好，它包含了权限管理和一些…
阅读更多...
【稳定检索】2024年电子技术、传感器与信号处理国际会议(ETSS 2024)

【稳定检索】2024年电子技术、传感器与信号处理国际会议(ETSS 2024)

2024年电子技术、传感器与信号处理国际会议 2024 International Conference on Electronic Technology, Sensors, and Signal Processing 【1】会议简介 2024年电子技术、传感器与信号处理国际会议，作为业内领先的学术交流平台，将汇聚全球顶尖的电子技术…
阅读更多...
99%的人都不知道，微信才是真正的学习神器

99%的人都不知道，微信才是真正的学习神器

微信，作为一款全球最受欢迎的社交应用之一，除了聊天、朋友圈、小程序等功能外，还有许多隐藏的学习功能，今天小编就给大家分享10个微信隐藏的学习功能，助您轻松成为学霸。 1、微信笔记 用过代办清单软件的朋友都知道&…
阅读更多...
如何调用通义千问大模型API

如何调用通义千问大模型API

目录 登录阿里云 大模型服务平台百炼 登录控制台 QWen Long QWen 通义千问开源系列 大语言模型 OpenAI接口兼容 登录阿里云 阿里云-计算，为了无法计算的价值 大模型服务平台百炼 降价信息： 登录控制台 右上角取得API key 创建Key QWen Long qw…
阅读更多...
Linux网络编程：传输层协议|UDP

Linux网络编程：传输层协议|UDP

知识引入： 端口号： 当应用层获得一个传输过来的报文时，这时数据包需要知道，自己应该送往哪一个应用层的服务，这时就引入了“端口号”，通过区分同一台主机不同应用程序的端口号，来保证数据传输…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023