赞
踩
目录
基于Air780E开发板:Air780E文档中心
简介:AT开发
本系列主要探讨MQTT手动接入OneNET(中国移动物联网开放平台)的基本操作及手动鉴权步骤、信息订阅及发布的基本原理。
参考阅读:物联网模组AT命令接入云平台(1)-MQTT基本原理及步骤
MQTT手动接入OneNET(中国移动物联网开放平台)的基本操作及手动鉴权。
Air780E开发板1块,SIM卡1张。
Revision: AirM2M_780E_V1108_LTE_AT
任意串口调试工具(本文使用llcom1.1.1.9,波特率9600)
产品名称、所属省市、产品类别根据自己需求填写,物模型没有要求可以选择标准物模型
节点类型选择直连设备、接入协议选择MQTT、数据协议固定为OneJson、联网方式选择蜂窝
填入设备名,选择产品,这里我使用的是模块的IMEI或IMSI来做设备名称
MQTT设备连接_开发者文档_OneNET (10086.cn))
可以看到,登入onenet时,mqtt的clientID、username和password都有指定
clientId即为刚才创建的设备名称
username为创建的产品ID
password是需要经过加密计算得来的鉴权token
设备鉴权参数(鉴权三元组)如下:
参数 | 描述 |
---|---|
ProductId | 产品ID,平台生成唯一ID |
DeviceName | 设备名称 |
Token | 鉴权token |
Token由多个参数构成,如下表:
名称 | 类型 | 是否必须 | 参数说明 | 参数示例 |
---|---|---|---|---|
version | string | 是 | 参数组版本号,日期格式,目前仅支持"2018-10-31" | 2018-10-31 |
res | string | 是 | 访问资源 resource格式为:products/{产品id}/devices/{设备名字} | 'products/ft6uTZ****/devices/4600112503*****' |
et | int | 是 | 访问过期时间 expirationTime,单位秒,unix时间当一次访问参数中的et时间小于当前时间时,平台会认为访问参数过期从而拒绝该访问 | '1670846247510'表示:北京时间 2022-12-12 19:57:27 |
method | string | 是 | 签名方法 signatureMethod支持hmacmd5、hmacsha1、hmacsha256 | sha1(代表使用hmacsha1算法) |
sign | string | 是 | 签名结果字符串signature | sign_Device:ah4jKmujuN11+Edt7*****==sign_Product:lwsm/g+PrJZz/WbpP*****== |
参数sign的生成算法为:
sign = base64(hmac_<method>(base64decode(key), utf-8(StringForSignature)))
其中: Key为OneNET为资源分配的访问密钥(产品级、设备级均可),其作为签名算法参数之一参与签名计算,为保证访问安全,请妥善保管 Key参与计算前应先进行base64decode操作 用于计算签名的字符串 StringForSignature的组成顺序按照参数名称进行字符串排序,以'\n'作为参数分隔,当前版本中按照如下顺序进行排序:et、method、res、version StringForSignature组成示例如下:
StringForSignature = et + '\n' + method + '\n' + res+ '\n' + version
注意:每个参数均为key=value格式组成,但是仅参数中的value参与计算签名的字符串 StringForSignature的组成。
示例:'1670846247510\nmd5\nproducts/ft6uTZ****/devices/4600112503*****
2018-10-31'
用于计算签名的字符串StringForSignature为(按照et、method、res、version的顺序)
计算出sign后,将每个参数均采用key=value的形式表示,并用'&'作为分隔符,
'version=2018-10-31&res=products%2Fft6uTZ****%2Fdevices%2F4600112503*****&et=1670846247510&method=md5&sign=ah4jKmujuN11%2BEdt7*****%3D%3D'
Token中key=value的形式的value部分需要经过URL编码,可使用quote或urlencode。需要进行编码的特殊符号如下
序号 | 特殊符号 | URL编码 |
---|---|---|
1 | + | %2B |
2 | 空格 | %20 |
3 | / | %2F |
4 | ? | %3F |
5 | % | %25 |
6 | # | %23 |
7 | & | %26 |
8 | = | %3D |
编码后,上例中实际传输Token为:
version=2018-10-31&res=products%2F123123%2Fdevices%2Fche1&et=1537255523&method=sha1&sign=ZjA1NzZlMmMxYzIOTg3MjBzNjYTI2MjA4Yw%3D
需要注意:官方文档中的Python算法示例有误,需修改后使用,注意对照文档方法自行甄别。
基本步骤思路:将平台生成的ProductKey或DeviceKey重新编码为base64格式,按文档规则生成StringForSignature,之后就行选定算法的计算,得到sign。最后生成MQTT的AT+MCONFIG连接配置。
- import time
- import hmac
- import hashlib
- import base64
- from urllib.parse import urlencode
-
- def hmac_sha256(key, value):
- """
- hmacsha256加密
- return:加密结果转成16进制字符串形式
- """
- message = value.encode('utf-8') # 加密内容
- sign_b=hmac.new(key, message, digestmod=hashlib.sha256)
- sign = base64.b64encode(sign_b.digest()).decode('UTF-8')
- return sign
-
- def hmac_sha1(key, value):
- """
- hmacsha1加密
- return:加密结果转成16进制字符串形式
- """
- message = value.encode('utf-8') # 加密内容
- sign_b=hmac.new(key, message, digestmod=hashlib.sha1)
- sign = base64.b64encode(sign_b.digest()).decode('UTF-8')
- return sign
-
- def hmac_md5(key,value):
-
- message = value.encode('utf-8')
- sign_b=hmac.new(key, message, digestmod=hashlib.md5).digest()
- sign_t = base64.b64encode(sign_b)
- sign=sign_t.decode('UTF-8')
- return sign
-
-
-
- #1、时间戳生成及基本注册数据
-
- et=str(int(time.time()*1000)+60*60) #60*60有效时间3600s,可按需延长
- version = "2018-10-31"
- ProductId = "ft6uTZ****"
- ProductKey=base64.b64decode("YRHzukQHuV0md3djYjiwT0zWQqB1m5qxRENkB*****=")
- DeviceName = "4600112503*****"
- DeviceKey =base64.b64decode("XKY7QG/xOJRjEbySZkYTdOjXnxJukxf2ObHoi/*****=")
- sm1 = "sha1" #加密方式选择,不参与计算
- sm5 = "md5"
- sm6 = "sha256"
-
- #2、res及StringForSignature组成
-
- res = "products"+"/"+ProductId+"/"+"devices"+"/"+DeviceName
- StringForSignature =str(et) + "\n" + sm5+ "\n" + res+ "\n" + version
-
- #3、sign鉴权计算
- sign_Product=hmac_md5(ProductKey, StringForSignature)
- sign_Device=hmac_md5(DeviceKey, StringForSignature)
-
-
- #4、 token参数拼接
-
- token_Product=urlencode([('version',version),('res',res),('et',et),('method',sm5),('sign',sign_Product)])
- token_Device=urlencode([('version',version),('res',res),('et',et),('method',sm5),('sign',sign_Device)])
-
-
- #5、MQTT的AT+MCONFIG连接配置生成
-
- print('AT+MCONFIG="'+DeviceName+'","'+ProductId+'","'+token_Product+'"')
- print('AT+MCONFIG="'+DeviceName+'","'+ProductId+'","'+token_Device+'"')
为便于开发者开发,平台提供Token生成工具(点击下载)
打开生成工具 token.exe
填写对应参数,点击generate
生成Token如下:
- 采用产品级:
- ← AT+MCONFIG="4600112503*****","ft6uTZ****","version=2018-10-31&res=products%2Fft6uTZ****%2Fdevices%2F4600112503*****&et=1670846247510&method=md5&sign=lwsm%2Fg%2BPrJZz%2FWbpP*****%3D%3D"
- 或者采用设备级参数:
- ← AT+MCONFIG="4600112503*****","ft6uTZ****","version=2018-10-31&res=products%2Fft6uTZ****%2Fdevices%2F4600112503*****&et=1670846247510&method=md5&sign=ah4jKmujuN11%2BEdt7*****%3D%3D"
- ← AT+MIPSTART="studio-mqtt.heclouds.com",1883
- → AT+MIPSTART="studio-mqtt.heclouds.com",1883
- OK
- →
- CONNECT OK
- ← AT+MCONNECT=1,120
- → AT+MCONNECT=1,120
- OK
- →
- CONNACK OK
可以从平台上看到设备已经在线了
onenet studio有固定的通信TOPIC,可以到官网查看,这里演示下设备属性上报与响应的主题
- 订阅
- [2022/12/12 19:45:16.9790] ← AT+MSUB="$sys/ft6uTZ****/4600112503*****/thing/property/post/reply",0
- [2022/12/12 19:45:17.0845] → AT+MSUB="$sys/ft6uTZ****/4600112503*****/thing/property/post/reply",0OK
- [2022/12/12 19:45:17.2683] → SUBACK
向设备上报属性的主题发布消息,消息携带设备的属性,不同的产品具有不同的属性,可以在设备物模型处查看
例如:在文章开始创建的产品具有如下图所示的属性
温度、湿度和地理位置
- [2022/12/12 19:45:21.7628] ← AT+MPUB="$sys/ft6uTZ****/4600112503*****/thing/property/post",0,0,"{\22id\22:\22125\22,\22params\22:{\22CurrentTemperature\22:{\22value\22:-25.0}}}"
- [2022/12/12 19:45:21.8729] → AT+MPUB="$sys/ft6uTZ****/4600112503*****/thing/property/post",0,0,"{\22id\22:\22125\22,\22params\22:{\22CurrentTemperature\22:{\22value\22:-25.0}}}"OK
- [2022/12/12 19:45:22.4680] → +MSUB: "$sys/ft6uTZ****/4600112503*****/thing/property/post/reply",39 byte,{"id":"125","code":200,"msg":"success"}
可以看到平台已经有数据更
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。