带你动手设计一个高速公路多节点温度采集系统_多路温度采集器

本文分享自华为云社区《鍗庝负浜戣鍧沖浜戣绠楄鍧沖寮€鍙戣€呰鍧沖鎶€鏈鍧�-鍗庝负浜�》，作者：DS小龙哥一、前言当前的场景是，在高速公路上部署温度采集设备，在高速路地表安装温度检测传感器，检测当前路段的路面实际温度。

0 ?: M; D1 o* |

一段高速路上有多个地点需要采集温度数据 采集温度数据需要上传到云平台进行数据存储，并且通过可视化界面展示温度变化曲线，支持查询最近几天的温度信息二、设计思路（1）云平台选型：使用华为云物联网云平台（2）云数据存储： 使用OBS存储，存放设备上传的历史数据。

2 Y4 T$ q* D2 i5 D! ]; q

（3）设备选项：NBIOT模块+温度采集模块，实现温度采集上报（4）数据可视化：采用华为云IoT应用侧接口，获取传感器设备上传到云端的数据，在本地设计界面进行可视化显示温度数据下面是温度数据可视化展示效果：。

本篇文章主要介绍设备上云的详细流程，介绍华为云物联网云端产品、设备创建流程，数据转存方式，应用侧开发接口等等。硬件选型：（1）STM32开发板: STM32F103C8T6

（2）NBIOT模块--BC26BC26模块是一款高性能、低功耗、多频段LTE Cat NB1无线通信模块。

" e$ O/ x, J( R8 z. c8 D; d# t

（3）温度采集模块pt100是铂热电阻，它的阻值会随着温度的变化而改变PT后的100即表示它在0℃时阻值为100欧姆，在100℃时它的阻值约为138.5欧姆其工作原理：当PT100在0℃时，其电阻为100欧姆。

它的电阻会随着温度的升高而上升，并且它的电阻会匀速增加热电阻是一种常用于中低温的温度传感器它的工作原理是基于电阻的热效应，即电阻的阻值随温度的变化而变化铂金热敏电阻的热阻精度最高，具有抗振动、稳定性好、耐高压等特点。

因此，它被制成各种标准温度计进行测量和校准

三、华为云IOT平台3.1 创建产品官网地址: https://www.huaweicloud.com/3.1.1设备接入IOTDA在产品页面找到iot物联网，选择设备接入IOTDA

, L, w- _0 L' p

设备接入服务（IoT Device Access）是华为云的物联网平台，提供海量设备连接上云、设备和云端双向消息通信、批量设备管理、远程控制和监控、OTA升级、设备联动规则等能力，并可将设备数据灵活流转到华为云其他服务，帮助物联网行业用户快速完成设备联网及行业应用集成，基础版每月一百万条消息免费。

9 p' j w& D, B% Y1 p

在页面上选择免费试用。

点击后，会进入到设备接入控制台页面。

3.1.2设备接入地址在基础版详情页面，点击右边的按需计费详情，可以查看物联网服务器接入的IP地址，端口号、接入方式。

0 i0 |6 k+ U1 {% t; I4 e

如果是设备接入，可以选择MQTT或者MQTTS协议，在单片机上只有MQTT协议验证比较方便，通过MQTT三元组即可完成设备连接，当前我这里的设备选择是MQTT协议连接华为云平台 域名：a161a58a78。

& v, U' y0 d* A& R( ~& h4 c6 C

.iot-mqtts.cn-north-4.myhuaweicloud.comIP地址: 121.36.42.100 3 y: W J+ z5 O5 @" [4 Z3 B7 T7 v 端口号: 1883 3.1.3创建产品在左边选项卡里点击产品，进入产品页面，点击右上角创建产品。

5 m# w. w% k6 W6 T

根据自己的产品信息，填写表单：

8 J* L2 X. `9 F

3.1.4完成产品创建

点击查看详情，可以进入到创建成功的产品页面。

3.1.5定义产品模型产品创建之后，接着需要在平台上构建一款设备的抽象模型，使平台理解该款设备支持的功能比如：温度采集设备肯定会向云平台上传采集的温度信息；在产品模型里就可以定义一个温度的属性字段

& G% N+ o' }8 B! B

选择下面的自定义模型。

+ h7 U* m! f4 V+ a

添加服务ID。

添加属性。

y1 ~, p& Y5 Y' S( d

新增属性字段。当前在多节点温度采集的设备里，主要是采集温度上传，这里就新增一个温度的属性。

7 h" l" d6 e, T( {9 m6 b3 d# w. W

产品模型创建完成。

% j2 f" e6 \) y% a3 m U

3.2 创建设备3.2.1创建单个设备设备注册的方式有很多：【1】创建支持单个设备手动创建【2】如果设备特别多可以选择批量注册【3】通过API接口进行动态注册当前为了演示流程，这里选择第一种方式，手动创建单个设备。

在设备页面，选择所有设备选项，点击右边的注册设备按钮。

3.2.2单设备注册填写信息点击注册设备之后，会弹出一个表单填写信息其中产品就选择刚才创建的产品，设备标识码这一项一般是填设备的ID（设备的唯一标识符，方便绑定设备）目前还没有对接硬件，我这里就填dev1，方便接下来的测试。

4 y0 ~: }6 V/ `( ~- b/ H' C

下面的设备ID这一项如果不填，会自动生成，可以不管；最后输入密匙（这个密匙的作用：通过对每个设备进行身份验证，可以安全地将每个设备连接到平台，并且安全地管理这些设备），填好之后点击确定

3.2.3设备创建完成创建好之后，保存生成的设备ID和密匙。

得到的密匙和ID的格式文本如下： { "device_id": "6353a8163ec34a6d03c8dfe5_dev1", "secret": "12345678" : h3 |" U8 h4 f6 k) T7 P) h } 6 e T: f1 v/ M. i. i! t5 H 这个设备密匙和ID，后面生成MQTT登录参数时需要用到。

' X9 E6 _* _) [0 M! ?" S( d7 k7 Y

3.2.4创建多个温度设备节点由于本项目是实现多节点温度上传到云平台，每个节点都是一个独立的温度采集设备，为了方便演示效果，还需要多创建几个设备接下来的创建流程，和刚才第一个设备一样，这里就不再截图演示了。

点击创建设备按钮，继续注册。

! Q6 W5 C+ A; n3 k8 ~

目前一共创建了4个设备，其中main_dev设备是用来作为显示终端，在本地用显示屏显示其他温度采集节点采集的温度信息。 剩下3个设备dev1，dev2，dev3是表示3个独立的温度采集节点。

. }! u( E7 W' q4 G; L7 S9 H

这4个设备的密匙和ID信息如下： { $ `/ X/ z5 k% v3 G1 p p9 N "device_id": "6353a8163ec34a6d03c8dfe5_dev1", . T* L. n' l( k) q9 ~ "secret": "12345678" 6 U% c9 X" p: _ } 7 t3 n; T$ u% K3 H' U3 H! J( S ​ ' r" Z9 j2 |* d& \4 B { 1 e& l9 s# A1 a d+ g4 a

"device_id": "6353a8163ec34a6d03c8dfe5_dev2", "secret": "12345678" & u0 z. K) ^$ Y& M" x$ Y } ​ ​ - F" b3 h9 \5 ^+ { { "device_id":

* A( J# }7 J% }( q' y% x

"6353a8163ec34a6d03c8dfe5_dev3", "secret": "12345678" } ​ + Y/ R" J& V0 w8 ^# p1 ] ​ 2 \8 N, J1 R0 o% Z& l; _/ G8 W { "device_id": "6353a8163ec34a6d03c8dfe5_main_dev"

; l7 m' X9 z+ ?( c

, . J6 n; z7 G# R1 d. Q5 F* Q/ U0 z "secret": "12345678" , \( M' ^0 M3 ]2 _7 H. e* ^+ O } 3.3 模拟设备上云测试目前设备创建之后，这些设备都还没有激活接下来会使用MQTT客户端来模拟真实设备上云，上传温度数据这里的上云，包括数据交互都采用MQTT客户端来模拟实现，不涉及到实际的硬件，只要模拟能测试成功，并且能得到自己想要的结果，那硬件就没有问题了。

3.3.1生成MQTT鉴权三元组设备要连接华为云平台的方式，在第一节创建产品的时候就已经介绍了，本次项目里的设备是采用MQTT协议接入云平台 在完成设备模拟上云之前，需要先生成设备的MQTT协议鉴权三元组。

! X; Q" t. z! @* D# h

华为云提供了一个在线工具，用来生成MQTT鉴权三元组： https://iot-tool.obs-website.cn-north-4.myhuaweicloud.com/工具打开的界面如下效果：

* t. v6 c* U& T' }0 d1 {

前面两行就是填设备创建后生成的设备ID和设备密匙，填好之后，生成下面3行信息，生成的3行就是MQTT协议登录需要用的参数。按照格式分别生成4个设备的鉴权信息：

2 M4 C- S8 C% [1 C

得到的三元组如下：ClientId6353a8163ec34a6d03c8dfe5_dev1_0_0_2022102209Username6353a8163ec34a6d03c8dfe5_dev1Password

& `# E' s @# e, y# W, y3 w0 N

c58c45d514832b119b4302eafb3e74854849ca94079e9aed75efedf176e9c388​ClientId6353a8163ec34a6d03c8dfe5_dev2_0_0_2022102209

Username6353a8163ec34a6d03c8dfe5_dev2Passwordc58c45d514832b119b4302eafb3e74854849ca94079e9aed75efedf176e9c388

​ClientId6353a8163ec34a6d03c8dfe5_dev3_0_0_2022102209Username6353a8163ec34a6d03c8dfe5_dev3Passwordc58c45d514832b119b4302eafb3e74854849ca94079e9aed75efedf176e9c388

8 `/ u0 N% d4 M

​ClientId6353a8163ec34a6d03c8dfe5_main_dev_0_0_2022102209Username6353a8163ec34a6d03c8dfe5_main_devPassword

7 Q, s- f6 E( y- y' E! g

c58c45d514832b119b4302eafb3e74854849ca94079e9aed75efedf176e9c3883.3.2MQTT客户端模拟设备登录得到MQTT三元组之后，接下来用MQTT客户端模拟设备登录云平台。

1 g" N% E8 F7 C

按照软件的输入框提示，输入对应的信息，点击登录。 其中的IP地址和端口号在第一小节的产品创建里就介绍过了。 后面输入的这3行就是上一步生成的MQTT鉴权三元组。

5 o5 g9 n4 P- ]; C

登录成功。

, y- l% U. t" M& x" _7 `

然后打开云平台的控制台，查看设备在线情况：

可以看到dev1已经在线了， 刚才模拟的设备就是dev13.3.3主题订阅与发布目前设备已经成功登录，接下来要解决的问题就是数据传输问题了MQTT协议里要理解的两个概念就是主题订阅，主题发布 设备上传数据到平台，属于 主题发布。

/ |0 Y4 J8 z# x: W' }

设备想要知道其他设备的数据或者云平台下发的指令，需要进行主题订阅帮助文档的地址：https://support.huaweicloud.com/api-iothub/iot_06_v5_3002.html

MQTT消息由固定报头（Fixed header）、可变报头（Variable header）和有效载荷（Payload）三部分组成其中固定报头（Fixed header）和可变报头（Variable header）格式的填写请参考MQTT标准规范，有效载荷（Payload）的格式由应用定义，即设备和物联网平台之间自己定义。

2 p# T) s# c" T! \6 ~# G% A6 @- P

常见MQTT消息类型主要有CONNECT、SUBSCRIBE、PUBLISH CONNECT：指客户端请求和服务端连接有效载荷（Payload）的主要参数，参考设备连接鉴权填写 SUBSCRIBE：指客户端订阅请求。

: L$ B: [; d5 L j

有效载荷（Payload）中的主要参数“Topic name”，参考Topic定义中订阅者为设备的Topic 8 r9 x2 G$ g, U/ ?3 C PUBLISH：平台发布消息 可变报头（Variable header）中的主要参数“Topic name”，指设备上报到物联网平台时发布者为设备的Topic。

详细请参考Topic定义 % C8 S1 j a7 o* C X/ W+ W9 y& |+ S 有效载荷（Payload）中的主要参数为完整的数据上报和命令下发的消息内容，目前是一个JSON对象 ​ / S/ K3 \, S6 T" x. ?# I 上行Topic是指设备向平台发送请求，或上报数据，或回复响应 # y9 e8 }) m G) ~) F 下行Topic是指平台向设备下发指令，或回复响应。

设备与平台建立连接后，需要订阅下行Topic，否则无法收到平台下发的指令或回复的响应应用侧接口的调用，需要设备侧的配合，例如应用侧下发命令，设备侧需要先订阅“平台命令下发”的下行Topic，否则设备无法收到平台命令，应用下发命令的接口也会报超时。

, Y+ W7 i! C6 T5 i2 L8 B

在产品页面，可以看到主题的格式，以及对于主题的用途：**

【1】订阅主题对于设备而言，一般会订阅平台下发消息给设备 这个主题设备想接收平台下发的消息，就需要订阅平台下发消息给设备 的主题，订阅后，平台下发消息给设备，设备就会收到消息主题的格式如下oc/devices/{device_id}/sys/messages/down 7 D O4 ^2 J5 W: `7 _0 \% X 5 W! ?' b" @6 V5 @- g8 _ 以dev1设备1为例，最终的格式:

$oc/devices/6353a8163ec34a6d03c8dfe5_dev1/sys/messages/down 【2】发布主题对于设备，发布主题，也就显示向云平台上传数据发布的主题格式如下oc

/devices/{device_id}/sys/properties/report ​ 以dev1设备1为例最终的格式: $ J' O5 Y l1 M/ ^) }$ D# W $oc/devices/6353a8163ec34a6d03c8dfe5_dev1/sys/properties/report 3 Z& _# ^; F6 e$ n/ t1 S1 I5 q

发布主题时，需要上传数据，这个数据格式是JSON格式上传的JSON数据格式如下: { "services": [ " I& h3 H! b+ X! P { "service_id": , "properties": { "。

": , 9 d1 Z B" u/ P0 B8 C "": , .......... } |6 \& c: P- e" c7 D: U } + T- i/ W9 F! o ] + Y2 H5 z8 G0 R! a: q } 根据JSON格式，一次可以上传多个属性字段。

6 O3 q8 k' Y# ~% Q3 h( R

这个JSON格式里的，服务ID，属性字段名称，属性值类型，在前面创建产品的时候就已经介绍了，不记得可以翻到前面去查看根据这个格式，组合温度节点一次上传的数据: {"services": [{"service_id"

: "temp","properties":{"temp":24.6}}]} # @! q L2 l# q0 c% \/ {( l 3.3.4MQTT客户端模拟设备上报数据打开MQTT客户端填入订阅主题，发布主题，和需要发布的数据，然后分别点击订阅主题按钮，

发布主题按钮。 右边提示成功之后，就可以打开云平台看上传的效果了。 （这里是以dev1，设备1为例）

& E1 ]2 { ^* A- w; Q

打开云平台看到dev1已经在线。

. x/ a- X5 B& R0 C

点击dev1,进去查看设备上传的数据。 可以看到，刚才上传的数据已经收到了。

到此，设备上传数据到云平台已经完成四、设备数据转存如果设备上传的数据需要进行保存，后续进行分析做其他用途，可以利用数据转发服务，让平台将设备上报数据推送给自己的应用服务器，由应用服务器进行保存；也可以选择让平台将设备上报数据转发给OBS对象存储服务，由OBS进行存储，进行永久保存，非常方便。

; W. B' F& P/ @( }1 S6 r& [6 v

如果存储在OBS里，自己设计应用侧界面时，也可以直接拉取OBS里的数据下来进行显示，处理，分析4.1 创建OSB存储桶地址: https://www.huaweicloud.com/product/obs.html

; W/ H& b8 V3 _/ v. A8 ?. H# \

对象存储服务（Object Storage Service,OBS）是一个基于对象的存储服务，提供了海量、安全、高可靠、低成本的数据存储能力。4.1.1选择管理控制台

# I( ?1 t! o! z3 c6 O# L# Y

4.1.2创建桶

填充桶信息： 我这里选择的是 华北-北京一

我这里因为要长期使用，这里选择1年的购买权。

' P* z. w4 q: q- n; r1 a

4.1.3创建成功

4.2 配置数据转发规则4.2.1创建规则选择左侧导航栏的规则>数据转发，单击右上角的创建规则。

填充规则转发的信息：

: H6 N0 {3 F* A7 s3 ]+ H

4.2.2设置转发目标单击添加，设置转发目标。这里的区域选择--华北-北京一。 因为前面的OBS桶创建的时候，设置区域设置的是北京一，然后点击授权。

授权之后，选择刚才创建的OBS桶，设置存储数据的目录和文件名字存储的数据可以直接转存JSON数据到OBS存储桶，也可以存放成CSV文件到存储桶如果选择存储JSON，就是直接将设备上传的数据存放到OBS存储里，如果选择存储CSV文件，可以自己选择需要存储的字段。

下面我演示一下存储成CSV文件时如何进行设置 （选择JSON文件不需要进行任何设置，直接将设备上传的数据JSON存储进去了）

下面设置转发的字段： （如果提示没有授权，点击授权即可）这个转发字段就是表示需要存放的数据是那些，对于路灯而言，肯定是需要存储上报的温度、湿度、电量、光照强度的属性的 这些属性在创建产品的时候设置，设备上报的也是这些属性。

" z) v# i) ^! U: ]" o7 J

这是设备上传一次云平台的完整JSON数据格式: { # n& P0 U8 y4 d& Q7 ^ "resource": "device.property", "event": "report", "event_time": "20221018T131627Z"

) v" L5 K( s; c

, "request_id": "5ee95a0c-262d-43c3-8d31-af453f9952ef", "notify_data": { 8 ], n1 x' v9 r0 k! L "header": {

4 w1 R. u; R6 }$ W/ B

"app_id": "7211833377cf435c8c0580de390eedbe", / c( h! @9 {- w' a "device_id": "634e3e423ec34a6d03c84bfb_1126626497"

2 A2 I! o5 ]! Y

, ' M- |$ w! \$ A7 k) w "node_id": "1126626497", "product_id": "634e3e423ec34a6d03c84bfb", "gateway_id"

: "634e3e423ec34a6d03c84bfb_1126626497" }, & U: D& r' {+ a "body": { "services": [ {

; `! M u1 h. l+ o2 ~! x' J( ^

"service_id": "temp", ! v$ {; a2 A, J& T' ~ "properties": { "temp": 28, }, "event_time"

: "20221018T131627Z" } " C8 K- I m% I/ h ] } } } % P! p! [7 J5 v7 q 当前设备上传到云端服务器有一个温度属性字段temp，如果想转发设备上传的这个温度字段，就可以这样写：

notify_data.body.services[0].properties.temp后面的存储目标字段，为了好区分，直接填temp即可如果设备还上传了其他属性字段也想转发，按照上面格式设置即可如果存储数据时，想知道这个数据是那个产品，那个设备上传的，也可以将设备ID和产品ID转发存储起来：格式如下。

notify_data.header.app_idnotify_data.header.device_id下面是我设置好，转发存储的字段：

确定后，点击设置完成。

! g4 D9 c6 J2 b. }) p* K

4.2.3测试规则设置好之后，在设置转发目标的页面点击测试。

. V; r! _+ d6 C0 B6 L( m1 m

输入数据模板，然后点击连通性测试。如果测试结果显示成功，说明整体流程没有问题了。

4.2.4启用规则设置完成后，点击启用规则。

4.2.5数据上报测试为了验证转发规则是否生效，接下来使用MQTT客户端多上报几次数据到云平台。

上传之后，打开OBS存储桶的控制台页面。打开转发规则存储的OBS桶。

/ ?9 U" w8 @" Z2 p$ A

找到存储数据的文件，点击下载。

下载下来，打开可以看到存储的数据:

到此，数据转发，存储已经成功了五、应用侧-可视化大屏开发对于数据的可视化显示，华为云提供了（Data Lake Visualization）一站式数据可视化平台，数据可视化服务(DLV)可以从OBS文件读取数据呈现为可视化报表，实现数据的可视化显示。

下面是华为云的DLV大屏从OBS读取数据显示的流程：

当前我这里的需求是需要在本地自己设计界面显示数据，没有采用华为云的DLV大屏，如果自己本地软件需要显示设备上传的数据，就需要使用华为云物联网的平台的应用侧API接口，读取设备上传的数据进行，本地进行显示；如果需要历史数据，可以读取OBS存储桶里存储的数据进行显示。

5.1 应用侧接口帮助文档地址: https://support.huaweicloud.com/usermanual-iothub/iot_01_0045.html

5.2 查询设备影子数据接口应用侧接口可以查询发送指令给设备查询属性，也可以读取设备的影子数据【1】查询设备查询: 这个是实时查询，相当于应用侧接口发送指令给在线设备，设备收到指令，将当前最新的数据再上传。

这个需要保证设备在线，离线是无法调用的【2】影子数据：影子数据相当于保存设备上传的最新一次数据。 读取读取影子设备数据，是不需要设备在线。5.2.1接口URI地址

5 a/ r- K0 a/ X* T1 l, M

5.2.2请求参数说明

+ I0 W+ I B! Y. X0 }* Q

5.2.3响应参数

5.2.4请求示例 GET https://{Endpoint}/v5/iot/{project_id}/devices/{device_id}/shadow Content-Type: application/json % N2 ~& z% R6 P8 D( P9 Q! a X-Auth-Token:

******** Instance-Id: ********5.2.5响应示例Status Code: 200 OKContent-Type: application/json ​ { "device_id"

# n4 i/ g5 w. {/ {/ B; n0 t% v

: "40fe3542-f4cc-4b6a-98c3-61a49ba1acd4", "shadow" : [ { " _( u( S( B$ Q! o" H "service_id" : "WaterMeter", 3 _3 Z* [/ M8 Y6 } "desired"

: { 6 N5 P2 z2 h$ l8 u. G. Z "properties" : { "temperature" : "60" 1 u6 {0 J& h1 d& O4 h4 d }, "event_time" : "20151212T121212Z"

4 a/ t4 I/ R1 J' c- ?

, g4 D2 V0 b2 j" X' c [; ` }, 1 ~1 M" h) I: [' r, z "reported" : { ) @* G+ W( |7 ~; C/ ]5 P2 f "properties" : { 5 [# X1 _: h% O4 ]/ b "temperature" : "60" }, + g; w& ?3 ^. C5 v9 O1 C! q "event_time"

: "20151212T121212Z" ; l A$ C5 F8 O2 Q2 P6 g j }, "version" : 1 } ] 3 |2 ^, J4 D9 M. p0 T+ i7 E0 L6 s } / x9 W3 j0 A: p 5.2.6错误码

7 o2 E Y: C% s3 i. K8 ?

5.3 接口调试在线调试地址：https://apiexplorer.developer.huaweicloud.com/apiexplorer/debug?product=IoTDA&api=ShowDeviceShadow

: y" d2 q, ?+ q4 ~" q

下面是调试影子 数据查询接口，查询设备影子数据： 右边返回的是设备上传的最新数据。

5.4 接口总结 请求地址: 4 C8 C t+ r' h% ]. @ https://iotda.cn-north-4.myhuaweicloud.com/v5/iot/{project_id}/devices/{device_id}/shadow * C9 C% w& E8 {7 I ​ 请求方式: GET ​ . Y7 W, F; S. g! B3 \6 ^: L 请求头: { & I7 A0 j% k7 T2 i, u+ p! ^, K6 \

"X-Auth-Token": "这个需要自己获取", "Content-Type": "application/json" , p0 P$ D( Z+ \0 | } 8 l: l1 O L& O. Y 5.5 如何获取X-Subject-Token使用API访问华为云的所有服务接口，都需要填X-Subject-Token参数，下面介绍步骤：

# @# d; {) s" a

5.5.1创建一个新的IAM帐户鼠标悬停在右上角的用户名称上，弹出下拉框，选择统一身份认证。

5.5.2选择创建用户

5.5.3使用调试接口测试获取oken调试接口地址: https://apiexplorer.developer.huaweicloud.com/apiexplorer/debug?product=IAM&api=

2 H3 o9 T* p4 l% [" D

KeystoneCreateUserTokenByPassword

右边响应头里的X-Subject-Token就是获取的token。

; K/ q8 Q4 N; Z: [$ ~, H

5.5.4上面的这些账户名称从哪里获取？

5.5.5请求地址和数据格式获取X-Subject-Token请求的地址：https://iam.cn-north-4.myhuaweicloud.com/v3/auth/tokens请求头数据: {

/ W4 O0 T1 O N! [) q/ F7 w

"User-Agent": "API Explorer", "X-Auth-Token": "******", - Y2 l) D8 X Y# c$ ]7 Q G "Content-Type": "application/json;charset=UTF-8"

} $ J \8 q* p* }" V 请求体数据: { "auth": { "identity": { ( `# | g" d4 H9 A5 p "methods": [ 8 _: U) o1 |$ e- Q6 n2 W5 F* L ? "password" / ~' ~0 e, h$ Y* w! I ],

"password": { "user": { & `# m7 A9 i; s+ W0 d" g8 z "domain": { "name": "xxxxx"//这里填当前主账户名称

( J. Y! f* R4 K( e r/ B/ E

}, "name": "xxxx", //这个新建的子账户名称"password": "xxxxx"//这个是新建的子账户密码 : u- {- Z. ]& K; D% |. C. [ } } }, * W! n* i: o* `! e! w

"scope": { , w* R: ?$ b0 j "project": { "name": "cn-north-4" } } 7 c/ x9 j V G4 c) }! T( _" n } ! K2 t! \3 |' [1 m } 5.5.6代码实现/* 功能: 获取token : y. f3 g- C6 x */

8 c. z* y: x) `- A2 l* B void Widget::GetToken() { //表示获取token function_select=3; * `$ m! t5 C; H' u3 E& P6 A " r' D5 s/ |# Y0 L8 f* { QString requestUrl; QNetworkRequest request; 0 |9 L5 F) @/ Q% K+ a

//设置请求地址 QUrl url; : I/ R l9 w( h; d8 H4 Z //获取token请求地址 6 i$ y1 P) ^- z( w requestUrl = QString("https://iam.%1.myhuaweicloud.com/v3/auth/tokens"

) .arg(SERVER_ID); 5 ?# J6 Z% F0 X' P% h //自己创建的TCP服务器,测试用//requestUrl="http://10.0.0.6:8080";//设置数据提交格式

1 w3 d3 d& V1 O" v6 O

. S' S: l7 l' u0 q2 m6 g w1 B request.setHeader(QNetworkRequest::ContentTypeHeader, QVariant("application/json;charset=UTF-8"

)); //构造请求 url.setUrl(requestUrl); ! d2 W% ]* V, [: p& Z request.setUrl(url); 2 c% L! S( x* {5 a QString text =QString(

"{"auth":{"identity":{"methods":["password"],"password":""{"user":{"domain": {"""name":"%1"},"name": "

%2","password": "%3"}}},"""scope":{"project":{"name":"%4"}}}}") .arg(MAIN_USER) - I$ w! }- R9 {1 c- ]0 X .arg(IAM_USER) .arg(IAM_PASSWORD) .arg(SERVER_ID); 8 M @8 _2 o( b3 N7 |$ v

//发送请求 , j3 D- p' c# ?( q& S0 N& Q manager->post(request, text.toUtf8()); 1 q3 Q* {. l$ J! U5 ^ } 2 c7 B3 p0 ?' h _2 R4 H 5.6 查询设备影子数据代码5.6.1这是请求代码//查询设备属性void Widget::Get_device_properties() + w8 f6 f. p0 g) K( s7 T3 U, d { , C# M4 ]8 t( u+ g

//表示获取token $ q5 s+ `# \$ b; o function_select=0; ​ QString requestUrl; QNetworkRequest request; ​ * ^* R" O D$ q1 ^* }0 ]; u

//设置请求地址 QUrl url; ​ 1 u5 x' x$ B# K' @1 q //获取token请求地址 5 d6 G( J! R, Y5 K requestUrl = QString("https://iotda.%1.myhuaweicloud.com/v5/iot/%2/devices/%3/shadow"

; q. y8 s, I' J6 D

) 6 `2 r1 A& b- G4 E' {2 v+ D .arg(SERVER_ID) .arg(PROJECT_ID) .arg(device_id); 6 O8 T- U+ w( X+ w4 c ​ 7 y/ D3 s/ h. n& d# A

//设置数据提交格式 1 z1 M3 K: f$ C! j request.setHeader(QNetworkRequest::ContentTypeHeader, QVariant("application/json")); ​ 2 G4 M. ^3 R% \$ G1 u

/ }# r% R O/ Z

//设置token request.setRawHeader("X-Auth-Token",Token); / _( ^5 ^( ]2 u5 e1 B J ​ //构造请求 - I9 u, S$ s! [- h% p$ l8 ]3 { url.setUrl(requestUrl); ' V8 O/ N, @/ @ ​ 9 b1 `! F' L9 @9 B4 [; `/ m# e, | request.setUrl(url); # ~4 W" i0 s9 s6 B1 O0 S ​ : h1 a9 {, r. @+ O7 Q

//发送请求 ( ]& R% p- H8 _1 Y! \ manager->get(request); 2 Z0 z( R2 q/ }' S/ h& v } 1 m. J' a: B- ]/ Q! U ​ ) ]/ I- @* a0 F //更新设备属性void Widget:n_pushButton_update_device_clicked() ' G4 S+ _2 c" g. k2 m; `- P { 2 f. e A5 L- P$ t Get_device_properties(); ( W0 o9 v$ _( R7 _ }

& M/ y* e% `' H

5.6.2这是请求一次返回的JSON数据 { - Y- P& c# {9 h# l' T, r "device_id": "6353a8163ec34a6d03c8dfe5_dev1", "shadow": [ 7 e" A0 V N/ R: p, @, c1 y: C { 5 U6 f# i: c9 B' E( T: {" `' [

"service_id": "temp", " p- @; t+ D" p4 Y "desired": { "properties": null, 8 a; m U. i6 s. v "event_time": null 1 ]3 m( J/ H' e+ \& { },

"reported": { 7 A' q3 H, `1 N9 r w/ N "properties": { "temp": 45.6 }, "event_time": "20221024T013607Z"

}, "version": 49 } / A% r: P- a" {( _+ g. ^5 x ] ( K( H x4 U+ P( O } ( S7 k0 x, F" W8 ?& L; y 5.7 界面设计最终效果

7 m3 L: W: Y3 j; a0 E

六、硬件部分6.1 MQTT版本注意：华为云、OneNet、腾讯IOT 等平台规定接入的MQTT协议版本必须是3.1.1 在BC26里，需要执行这行代码配置MQTT协议版本为3.1.1AT+QMTCFG=。

"version",0,4 ! v* u$ c2 Y7 D7 y5 y% K& } 6.2 BC26上云配置代码#include"BC26.h" # y$ \+ w5 [& P+ H$ m ​ 1 O9 @; ^! T; R5 L _0 h //BC26复位//引脚是PC0//高电平有效voidBC26_Reset(void){ //开时钟

0 q, H5 F0 k& A- G% Q+ A V8 {

RCC->APB2ENR|=1CRL|=0x00000003; r; J6 j$ M5 n# b% q , A( x- G7 O ?* ~/ h1 N

: |/ {3 D/ m# i. A. Q" O& l

//开始复位 5 l% Y' }# T+ l0 a; d) ^) b4 x9 i GPIOC->ODR|=1

9 a/ [7 f1 D( [, h: W

u8 BC26_SendCmd(char *cmd,char *check_data){ u16 i,j; for(i=0;i<5;i++) //测试的总次数 { ' z3 y: A- ]3 d! I6 H$ w; W USART2_RX_FLAG=

8 F* S5 U7 [' p7 L! f: ?5 Z

0; 3 K+ p- ~5 m4 m; ~7 g" P1 |1 N& p& M USART2_RX_CNT=0; memset(USART2_RX_BUFFER,0,sizeof(USART2_RX_BUFFER)); 7 _ \& [5 h# `5 P# P Y) l A5 Q, O USARTx_StringSend(USART2,cmd);

# k3 p& }9 I' s2 z

//发送指令for(j=0;j<500;j++) //等待的时间(ms单位) $ f* ?# j" Q# T, j9 Q/ } q { 0 `. ?! e0 S" G if(USART2_RX_FLAG) : L2 r7 p2 h! T+ z' @: v0 k { 1 u: w9 e/ W, w! Y7 C1 w* B USART2_RX_BUFFER[USART2_RX_CNT]=

\0; if(strstr((char*)USART2_RX_BUFFER,check_data)) " F% {5 L. D) E R# i$ ~5 { {

+ g( q, }2 z. }

return0; " N0 e% k+ ~. Y } elsebreak; ' M Z! ] i7 U+ n) S! q } delay_ms(30); //一次的时间 " w6 G2 x: E5 v) a( T- g } }

return1; } 1 w S. m1 Q' j; s8 I& r9 _ ​ ! a: K/ n) @" @) x; u4 N( [ \ ​ ​ 9 ]8 I! Y! f6 z6 v ​ //初始化BC26模块intBC26_Init(void){ $ K( T5 U+ r. u3 x$ E' B, ]- K if(BC26_SendCmd("AT\r\n","OK")) 9 Q+ g8 `$ U7 E+ n6 H { 2 k: Q k7 Q5 U$ K2 ]+ j) R5 s1 l+ I USART1_Printf(

. _. ?( @; j0 V1 X

"BC26模块不存在.\r\n"); 9 r. n4 l3 V/ j return1; } else % Y' S7 s6 g8 K0 P { 0 D1 R" Y3 I$ { USART1_Printf("BC26模块正常!\r\n"); } ​

/ M, p- x! T$ T

if(BC26_SendCmd("AT+CIMI\r\n","OK")) { USART1_Printf("模块未插卡.\r\n"); 6 D4 r# R0 \- d! m return3; 7 P0 k+ `( ]8 i1 i } * ` H) F- R% \

T' b8 |; ^. Y

else { f' w1 s! B9 t USART1_Printf("卡已经插好.\r\n"); 1 `7 ^$ a2 q2 J6 @ U } ​ if(BC26_SendCmd("AT+CGATT=1\r\n"

,"OK")) 4 m+ J- J' r6 i" Y/ x! { { 6 k( x6 H# `! B/ U USART1_Printf("配置:网络激活失败.\r\n"); return3; ! ^- @# S i5 A2 G } : r7 @# z) Z$ ]2 Z+ Q( L else { USART1_Printf(

! q0 N) @9 ]. f6 r) e8 f) v

"配置:网络激活成功.\r\n"); } if(BC26_SendCmd("AT+CGATT?\r\n","OK")) - `9 P; R8 A( X# x5 p/ k { : V/ T9 m# h9 k% G+ S USART1_Printf(

$ w {8 X$ _# l/ B( O6 X3 ]3 i8 f5 {

"状态:网络激活失败.\r\n"); " ~( [7 K4 i) z return4; } else - _/ \; C5 s) \ { 3 e' y) t' N* b; `# ^ USART1_Printf("状态:网络激活成功.\r\n"

); - O1 W \ _6 s4 [+ l } if(BC26_SendCmd("AT+CSQ\r\n","OK")) { USART1_Printf("查询信号质量失败.\r\n"

); , Z& Q: C) M# U5 e3 _8 A/ F return5; } . K0 I$ P/ k9 |& {5 t else : L& |! Y1 N) ~' I* K { USART1_Printf("信号质量:%s\r\n",USART2_RX_BUFFER); }

7 W! I0 Z3 P+ i3 g o3 m% P4 q

// if(BC26_SendCmd("AT+QGNSSC=1\r\n","OK"))// {// USART1_Printf("激活GPS定位失败.\r\n");// return 6;

// }// else // {// USART1_Printf("激活GPS定位成功.\r\n");// }// // if(BC26_SendCmd("AT+QGNSSAGPS=1\r\n","OK"))

( d; i9 n% J. h* z

// {// USART1_Printf("开启AGPS定位失败.\r\n");// return 6;// }// else // {// USART1_Printf("开启AGPS定位成功.\r\n");

// }// // if(BC26_SendCmd("AT+CGPADDR=1\r\n","OK"))// {// USART1_Printf("激活GPRS场景失败.\r\n");

# y+ y" ]6 ^( D3 c N

// return 7;// }// else // {// USART1_Printf("激活GPRS场景成功.\r\n");// }// // DelayMs(1000);

// DelayMs(1000);if(BC26_SendCmd("AT+CEREG?\r\n","+CEREG: 0,1")) ; s& q/ |$ X8 ^- C6 |- J; k { USART1_Printf("网络注册状态:失败.\r\n"

3 u0 W5 V- `) J* B+ _; @2 \' ]

); + { w" j7 A2 [2 s; { return9; 0 C' Q- z# R1 M7 B } ) r+ \2 N& q4 Z# F else { 9 q/ n' W# @, r$ R USART1_Printf("网络注册状态:成功.\r\n"); 2 w- H" q2 E) t4 ~9 Q, g }

0 w0 I* t' `# Z3 H) _& o$ \4 E

return0; * @. I8 W- w) t1 V1 u/ K } - t2 t/ }5 n; [( X, G ​ ; ?3 a% d) @# g; c9 X9 y ​ //发送使用的缓冲区char BC26_SEND_BUFF[500]; ​ + I" C% R# D, E. X //MQTT协议登录服务器intBC26_MQTT_Connect(void){

4 ^- J/ y3 u. N% V4 m. V

//1. 先关闭之前的连接 USART1_Printf("正在关闭之前的连接...\r\n"); BC26_SendCmd("AT+QMTCLOSE=0\r\n","OK"); . `5 \# R" |: e o- F* v7 A3 j$ Y DelayMs(

8 y2 [3 `; b: B" r9 \

4000); //关闭服务 BC26_SendCmd("AT+QMTCONN?\r\n","OK"); DelayMs(4000); //2. 连接MQTT服务器

. X8 ^5 y3 j3 e USART1_Printf("正在连接MQTT服务器..\r\n"); * I* g& O0 d/ C! v sprintf(BC26_SEND_BUFF,"AT+QMTOPEN=0,"%s",%s\r\n",MQTT_SERVER_ADDR,MQTT_SERVER_PORT); / {/ P- n- B8 C4 W

if(BC26_SendCmd(BC26_SEND_BUFF,"OK")) 3 J& P7 z5 G7 K/ Z! G { USART1_Printf("MQTT服务器连接失败:%s\r\n",BC26_SEND_BUFF);

return1; / H# }! w3 [0 q6 s& Z) V } $ t# d4 A1 R( ]9 _4 Z! c* z" K else $ }$ F" D Z5 T+ J4 ~+ n! F { USART1_Printf("MQTT服务器连接成功.\r\n"); % B! ^# H: A0 y6 E- D3 ` } 7 b$ Y z, i3 u! i DelayMs(3000

); * A5 r2 F/ C5 B1 c2 p7 x/ N4 b : ^; \. @* s3 [% ~# Q0 I4 i 5 I% R0 A2 y+ J //3. 登录MQTT服务器 " K1 u. a; v& o USART1_Printf("正在登录MQTT服务器...\r\n"); 0 S; u; @* U5 u/ H sprintf(BC26_SEND_BUFF,

# ?, y$ j# R) M' t' J' K

"AT+QMTCONN=0,"%s","%s","%s"\r\n",MQTT_CLIENT_ID,MQTT_USERNAME,MQTT_PASSWORD); ; b# x' S* Y, A9 J if(BC26_SendCmd(BC26_SEND_BUFF,

- d' l, d4 n: I- T3 W" s ^

"OK")) { USART1_Printf("MQTT服务器登录失败:%s\r\n",BC26_SEND_BUFF); % c8 `' J6 v2 Y$ |0 z return2; } " b* \8 V* E- S2 z. E3 d

else B/ j9 w* e8 V5 B! a+ u { USART1_Printf("MQTT服务器登录成功.\r\n"); % m( z4 `- I* R0 i } DelayMs(3000); //4. 订阅主题

0 H+ H( Y) ]' ^& i' E USART1_Printf("正在订阅主题...\r\n"); 7 s+ C( [7 y2 v sprintf(BC26_SEND_BUFF,"AT+QMTSUB=0,1,"%s",2\r\n",MQTT_TOPIC_SUB_GET);

if(BC26_SendCmd(BC26_SEND_BUFF,"OK")) { * S6 O: J: |: z: e! i% y USART1_Printf("MQTT主题订阅失败:%s\r\n",BC26_SEND_BUFF); ' M2 ^4 z8 k& d/ O" j } 3 N' j r T; Q" O% ]

else { 3 `/ {. U/ Y3 E5 w! O USART1_Printf("MQTT主题订阅成功.\r\n"); 3 X V# H! m0 n& O- x } return0; } ​ % Y+ i, K& O. P( i( _ ​ //MQTT发布主题intMQTT_PublishTheme

(char *text){ char send_buf[3]; ! x& |5 h' U2 {. D5 t3 S' j sprintf(BC26_SEND_BUFF,"AT+QMTPUB=0,0,0,0,"%s"\r\n",MQTT_TOPIC_SUB_SET);

1 G c" E3 D( l; n/ A

if(BC26_SendCmd(BC26_SEND_BUFF,">")) 3 w$ Y' m- Z8 F* Y# |+ P9 S; k# p { : _( T' j( x; m& D6 s L USART1_Printf("发布主题等待输入失败:%s\r\n",BC26_SEND_BUFF); ( j. ^) G6 F; l, e5 M" i

+ H0 ?, m5 D* V& l

return1; } ( V/ @4 \, o( {; Z o$ I USARTx_StringSend(USART2,text); //发送主题内容//发送结束符 0 z) B+ \+ I0 I1 U5 ^! Y6 r send_buf[0] = 0x1a; send_buf[

4 Q% v- C) N. u" ]* y& d3 L

1] = \0; 2 g' o6 P& v+ C, Z; ^0 j if(BC26_SendCmd(send_buf,"OK")) { USART1_Printf("发布主题内容失败:%s\r\n",BC26_SEND_BUFF); ) R u" i4 C r8 c, C% x9 k [

return2; //发送结束符号 } 4 G8 J$ L, T* c6 { else { 7 ~1 {* b9 ?9 S USART1_Printf("发布主题内容成功.\r\n"); 2 y7 }" T/ t: Z } 2 d2 S# S3 b/ V# w USART1_Printf(

"发布主题内容:%s\r\n",text); return0; " C: d* f, J+ c5 V } ' ]+ b7 ?" K, y& e ​ //MQTT响应应用层的属性请求intMQTT_SendAttribute(char *text,char *request_id)

" g Z% Z) |1 D( O$ `2 r4 C

{ char send_buf[3]; ; Q9 h% S8 l; b3 I sprintf(BC26_SEND_BUFF,"AT+QMTPUB=0,0,0,0,"%s%s"\r\n",MQTT_TOPIC_SUB_SET_RUN,request_id); * f$ E" e: s+ C, ~

. @+ @8 V7 |6 X" ]( R! V

if(BC26_SendCmd(BC26_SEND_BUFF,">")) # e2 |1 |& S) V0 u6 A { S& C7 N# Z% d0 L& [2 a- b# y1 i USART1_Printf("(响应)发布主题等待输入失败:%s\r\n",BC26_SEND_BUFF); : Y1 V' `+ ^$ J8 |: J

return1; 6 I7 e* T! q! p# R3 ] } 2 ^# x U3 X5 K+ ` USARTx_StringSend(USART2,text); //发送主题内容//发送结束符 4 e9 l# r0 V% t* P send_buf[0] = 0x1a; 3 z: l! {2 ^ E3 r+ b send_buf[

1] = \0; & r S$ j# J9 M( v4 Z3 o/ Y if(BC26_SendCmd(send_buf,"OK")) { USART1_Printf("(响应)发布主题内容失败:%s\r\n",BC26_SEND_BUFF);

. Q: H5 ^& F6 h( [5 X

return2; //发送结束符号 } - y" ~% o% a4 J else { # A. q8 ^" N9 s6 o: l USART1_Printf("(响应)发布主题内容成功.\r\n"); } , h7 `% L. w' R$ d4 ^2 n USART1_Printf(

"(响应)发布主题内容:%s\r\n",text); return0; 7 {4 P( e( }! b- ` } , p+ M5 E# L6 f' P) n ​ ​ ( c- _$ U3 o/ h0 Q+ y& R# y ​ + ]" u/ g# s. B /* 函数功能: 获取一次GPS经纬度数据 + @ e( Z, F* l- G5 I7 f. A- Z0 Q 函数参数: double *Longitude :经度 , b* }5 _/ ~2 H/ K4 ]6 W double *latitude :纬度 8 `( i N" h4 _ 返回值: 0表示定位成功,1表示数据接收失败,2表示定位失败 & u0 Y6 w1 u7 W( y- h */

& G* A( a2 J4 S' Y: r

u8 BC26_GetGPS_Data(double *Longitude,double *latitude){ /*1. 发送获取GPS数据的指令*/if(BC26_SendCmd("AT+QGNSSRD="

NMEA/RMC"\r\n", "OK\r\n"))return1; + c! J3 N0 i% x `( }/ q /*2. 对GPS数据进行解码*/if(GPS_GNRMC_Decoding((char *)USART2_RX_BUFFER,Longitude,latitude))

/ U b% }) q4 w7 P$ T' i

return2; $ X1 h1 d# I* y & d% v9 b, a( ]9 K6 M; c3 H5 B //解码成功return0; ) a$ E0 `' d' C, ?! Y } & V+ E X" l3 O5 Y ​ 3 L3 g9 D% c- w6 \+ P ​ /* 函数功能: 开启GPS功能 2 L8 F m6 _0 F5 _8 z8 g 返 回 值：0表示成功 1表示失败 */u8 BC26_StartGPS

(void){ 8 p, _* k& G, i, P8 p" Z+ x8 b$ t //先判断GPS功能是否启动if(BC26_SendCmd("AT+QGNSSC?\r\n","+QGNSSC: 1")) { 4 X. @" |) ^7 ]1 P/ u" l //没有启动就启动GPS功能

if(BC26_SendCmd("AT+QGNSSC=1\r\n","OK\r\n")) { : w' G, W! y. Q USART1_Printf("开启GPS功能失败.\r\n");

return1; //GPS功能启动失败 } else # Q' Z: t$ V, [4 ?' T3 j$ I { USART1_Printf("开启GPS功能成功.\r\n"

); } / W; p. N' l0 @ } return0; } 6.3 MQTT 3.1协议介绍地址: http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html

( \% [$ {( {9 a8 O, f/ N8 J

规范共分七章：第一章 - 介绍第二章 - MQTT控制包格式第三章 - MQTT控制包、第四章 - 操作行为第五章 - 安全第六章 - 使用WebSocket进行网络传输第七章 - 一致性目标点击下方，第一时间了解华为云新鲜技术~

华为云博客_大数据博客_AI博客_云计算博客_开发者中心-华为云

9 q$ b) I9 t; t4 E * `" o1 |' a1 M' K1 v r- B o9 z+ {0 @' b* j5 F

蹲了这么久，终于看到有价值的讨论，支持一下！