IoT企业物联网平台,数据服务开发实战

简介: IoT企业物联网平台开发实战

一、企业物联网平台开发实战

1、设备通过MQTT协议与您在阿里云上购买的IoT企业实例建立双向连接,上报设备采集的数据。

2、通过数据解析与分析洞察功能将上传数据进行分析并将通过自定义Topic以及AMQP服务端使用户获取分析后的数据。

二、创建企业实例

首先,我们登录物联网平台控制台(https://iot.console.aliyun.com), 点击购买实例来创建一个企业实例。

然后,在购买页面,根据实际业务需求,选择地域、实例类型、设备数量、消息上下行TPS、规则引擎TPS等参数,点击立即购买,付费成功后,即可看到企业实例创建中。

稍等几分钟后,企业实例创建完成。进入企业实例,我们可以看到当前规格参数,设备接入点信息,AMQP订阅接入点信息,云端API调用接入点信息。如下图:

1689842981040-0841088c-c965-4bd5-ad65-2079c180bc20.png

三、创建产品和注册设备

在企业实例的设备管理页面,我们需要先创建一个产品温湿度传感器,数据通信以JSON格式,认证方式为设备秘钥

1689905801297-2e558001-feb2-410f-822c-5222d97368a7.png

产品功能定义页面,我们可以添加电量、状态等属性,具体细节如下图:

1689910346106-bb674f05-52b6-42d6-9402-32f31b3c67ec.png

最后,我们在设备管理页面,基于温湿度传感器产品,注册一个物理设备,并获取设备身份认证的三元组。如下图:

1689910436327-a3a74848-d200-4869-8986-9296d3a048a3.png

四、设备接入和上报数据

获取设备身份三元组后,即可通过MQTT协议接入到我们开通的企业实例,并上报物模型数据。设备端应用程序示例如下:


开发环境:

1、下载Demo代码,并解压。

2、打开IntelliJ IDEA,导入Demo包中的示例工程data-service-demo,在pom.xml文件中,已添加Maven依赖。

3、在src/main/java/com/iot/demo/subsample/MqttSample/MqttTest.java文件中,参照下表,修改参数值。

1690164419422-1dbac317-cf46-46b1-99d4-267a80926483.png1692954067942-877fd211-25b6-481d-9193-78b82b45ea2c.png

参数

示例

说明

deviceName

device1

您添加设备后,保存的设备证书信息,请参见设备证书信息

您可在控制台中设备device1设备详情页面查看。

deviceSecret

b2e6e4f102458d84***

productKey

g18l***

productSecret

a2rt******

已烧录至设备的产品ProductSecret,可登录物联网平台控制台,在产品详情页查看。

4、运行src/main/java/com/iot/demo/DemoApplication.java文件中的demo.mqtt()即可

private void reportProperty(){
    if (StringUtils.isEmptyString(identity) || valueWrapper == null) {
        ALog.e(TAG, "数据格式错误");
        return;
    }
    LinkKit.getInstance().getDeviceThing().thingPropertyPost(reportData, new IPublishResourceListener() {
        public void onSuccess(String s, Object o) {
            // 属性上报成功
            ALog.d(TAG, "上报成功 onSuccess() called with: s = [" + s + "], o = [" + o + "]");
        }
        public void onError(String s, AError aError) {
            // 属性上报失败
            ALog.d(TAG, "上报失败onError() called with: s = [" + s + "], aError = [" + getError(aError) + "]");
        }
    });
}

获取的是缓存在设备本地的属性数据,不是云端实时的属性数据,代码如下:

// 根据 identifier 获取当前物模型中该属性的值
String identifier = "xxx";
LinkKit.getInstance().getDeviceThing().getPropertyValue(identifier);
// 获取默认模块(非用户自定义模块)的属性列表
LinkKit.getInstance().getDeviceThing().getProperties()

完整代码链接:https://code.alibaba-inc.com/IoT-DSD/data-service-demo

程序运行后,我们看到设备状态为在线物模型数据中可以看到最新上报的温度湿度值。

1689911724441-f69df1cb-4f22-49c8-9dbf-cf71dc6f286a.png

监控运维日志服务里,也可以看到设备上报数据的日志。如下图:

1689911961637-c1ea4e89-e575-4424-8a80-cacacbb80283.png

五、创建自定义Topic

在温湿度传感器产品Topic类列表页面,选择自定义Topic,点击定义Topic类来创建自定义Topic。

设备操作权限选择发布并将Topic类填写完整

1689918400591-7304fecf-ecf7-498e-9d59-fc30cea32439.png

1689918586388-c9e23b2e-b270-44be-ada3-bf97f17cd26e.png

六、数据解析

首先,在数据服务数据解析里,新建温湿度解析任务用以对上报数据进行预处理。

1689853132229-5e24dcbd-ad60-49d8-a7f3-7a5808740a57.png

点击温湿度解析,进入数据解析工作台进行节点配置。

在源节点处,所属产品选择温湿度传感器,Topic类型选择物模型通信,可以处理设备通过物模型Topic上报的数据,如下图所示:

1689918788377-11ae67d8-af5d-4d6e-8f54-3be59d61dd51.png

按需配置数据处理节点,如数据计算,相邻消息计算等。

1689918846872-08b91a13-2255-4ca3-ab19-8dbd5772e10c.png

在目标节点处,目标类型选择IoT实例Topic,所属产品选择温湿度传感器,目标Topic选择步骤五新创建的Topic类。

1689918984154-2f3a7ad3-8a7e-40c8-9050-7aee223e4577.png

完成校验启动,便可通过自定义Topic进行实时处理后数据的通信。

七、服务器实时接收数据

我们可以通过服务端订阅AMQP方式,实时接收自定义Topic上报的处理后的数据。

首先,我们要在企业实例的服务端订阅中,创建一个新的消费组,用来接收特定类型的消息。如下图:

1689920756331-a4acf327-9c6c-4efa-ba34-8fc95d16e5e3.png

然后,在服务端订阅中进入订阅列表页签,来创建订阅。

消费组选择上一步新建的温湿度传感器数据接收消费组。

1689920999740-646c2710-6509-4490-8fd5-008c14cc3e31.png

最后,我们在业务服务器编写程序,使用阿里云账号的AccessKey与IoT企业实例建立AMQP连接,代码示例如下:


开发环境:

1、下载Demo代码,并解压。

2、打开IntelliJ IDEA,导入Demo包中的示例工程data-service-demo,在pom.xml文件中,已添加Maven依赖。

3、在src/main/java/com/iot/demo/pubsample/AmqpClient.java文件中,参照下表,修改参数值。

1692955325279-5b1e19a6-cbae-4b32-88b4-5313c047e469.png

参数

示例

说明

accessKey

LTAI4GFGQvKuqHJhFa******

登录物联网平台控制台,将鼠标移至账号头像上,然后单击AccessKey管理,获取AccessKey ID和AccessKey Secret。

accessSecret

iMS8ZhCDdfJbCMeA005sieKe******

consumerGroupId

VWhGZ2QnP7kxWpeSSjt******

已创建的温控器数据接收消费组ID。请参见配置AMQP服务端订阅的步骤2。

iotInstanceId

"iot-cn-6ja***"

IoT测试环境的实例ID。

您可在控制台的实例概览页面查看。

clientId

12345

客户端ID,可自定义,长度不可超过64个字符。建议设置为您的AMQP客户端所在服务器UUID、MAC地址、IP等唯一标识,方便您识别区分不同的客户端。

AMQP客户端接入成功后,在控制台的温控器数据接收的消费组详情页面,显示该参数。

connectionCount

4

启动AMQP客户端的连接数,最大不超过64个。用于实时消息推送的扩容。

消费组详情页面会以${clientId}+"-"+数字形式,显示连接的客户端。其中数字最小值为0。

host

iot-***.amqp.iothub.aliyuncs.com

您购买实例成功后,保存的AMQP接入域名,请参见创建企业版实例

您可在控制台中实例IoT测试环境实例详情页面,单击查看开发配置,单击AMQP页签查看。

4、运行运行src/main/java/com/iot/demo/DemoApplication.java文件中的demo.amqp()即可

完整代码链接:https://code.alibaba-inc.com/IoT-DSD/data-service-demo

启动后,我们可以看到处理的数据,如下图:

1692956087469-a4ad4b62-608a-4b8f-83f5-65cd0538edb9.png

返回参数:

参数

参数值

说明

topic

/***********/******/user/devmsg

自定义Topic

messageId

1682274939191261184

消息的ID

content

{"temperature":23,"humidity":21,"time":1604548451951}

消息的内容


相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台,通过云产品流转到函数计算FC,调用钉钉群机器人API,实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
目录
相关文章
|
12天前
|
传感器 存储 物联网
在物联网(IoT)快速发展的今天,C语言作为物联网开发中的关键工具,以其高效、灵活、可移植的特点
在物联网(IoT)快速发展的今天,C语言作为物联网开发中的关键工具,以其高效、灵活、可移植的特点,广泛应用于嵌入式系统开发、通信协议实现及后端服务构建等领域,成为推动物联网技术进步的重要力量。
21 1
|
1月前
|
安全 物联网 网络安全
智能设备的安全隐患:物联网(IoT)安全指南
智能设备的安全隐患:物联网(IoT)安全指南
74 12
|
28天前
|
传感器 监控 安全
物联网(IoT):定义、影响与未来
物联网(IoT):定义、影响与未来
63 3
|
1月前
|
存储 JSON 运维
智能物联网平台:Azure IoT Hub在设备管理中的实践
【10月更文挑战第26天】随着物联网技术的发展,Azure IoT Hub成为企业管理和连接数百万台设备的强大平台。本文介绍Azure IoT Hub的设备管理功能,包括设备注册、设备孪生、直接方法和监控诊断,并通过示例代码展示其应用。
49 4
|
2月前
|
Rust 资源调度 安全
为什么使用 Rust over C++ 进行 IoT 解决方案开发
为什么使用 Rust over C++ 进行 IoT 解决方案开发
76 7
|
1月前
|
SQL 监控 物联网
ClickHouse在物联网(IoT)中的应用:实时监控与分析
【10月更文挑战第27天】随着物联网(IoT)技术的快速发展,越来越多的设备被连接到互联网上,产生了海量的数据。这些数据不仅包含了设备的状态信息,还包括用户的使用习惯、环境参数等。如何高效地处理和分析这些数据,成为了一个重要的挑战。作为一位数据工程师,我在一个物联网项目中深入使用了ClickHouse,以下是我的经验和思考。
76 0
|
2月前
|
人工智能 安全 物联网
|
4月前
|
存储 分布式计算 物联网
Apache IoTDB进行IoT相关开发实践
当今社会,物联网技术的发展带来了许多繁琐的挑战,尤其是在数据库管理系统领域,比如实时整合海量数据、处理流中的事件以及处理数据的安全性。例如,应用于智能城市的基于物联网的交通传感器可以实时生成大量的交通数据。据估计,未来5年,物联网设备的数量将达数万亿。物联网产生大量的数据,包括流数据、时间序列数据、RFID数据、传感数据等。要有效地管理这些数据,就需要使用数据库。数据库在充分处理物联网数据方面扮演着非常重要的角色。因此,适当的数据库与适当的平台同等重要。由于物联网在世界上不同的环境中运行,选择合适的数据库变得非常重要。 原创文字,IoTDB 社区可进行使用与传播 一、什么是IoTDB 我
182 9
Apache IoTDB进行IoT相关开发实践
|
3月前
|
存储 物联网 关系型数据库
PolarDB在物联网(IoT)数据存储中的应用探索
【9月更文挑战第6天】随着物联网技术的发展,海量设备数据对实时存储和处理提出了更高要求。传统数据库在扩展性、性能及实时性方面面临挑战。阿里云推出的PolarDB具备高性能、高可靠及高扩展性特点,能有效应对这些挑战。它采用分布式存储架构,支持多副本写入优化、并行查询等技术,确保数据实时写入与查询;多副本存储架构和数据持久化存储机制保证了数据安全;支持动态调整数据库规模,适应设备和数据增长。通过API或SDK接入IoT设备,实现数据实时写入、分布式存储与高效查询,展现出在IoT数据存储领域的巨大潜力。
78 1
|
3月前
|
传感器 安全 物联网
物联网安全实战:保护你的智能设备免受攻击
【9月更文挑战第3天】物联网安全是一项复杂而艰巨的任务,需要我们共同努力来应对。通过采取上述实战措施,我们可以有效保护智能设备免受攻击,保障用户的数据隐私和网络安全。在未来的物联网发展中,我们将继续面临新的安全挑战和威胁,但只要我们保持警惕和不断创新,就一定能够构建一个更加安全、可靠的物联网生态系统。

相关产品

  • 物联网平台