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
目录
相关文章
|
3月前
|
物联网 数据管理 Apache
拥抱IoT浪潮,Apache IoTDB如何成为你的智能数据守护者?解锁物联网新纪元的数据管理秘籍!
【8月更文挑战第22天】随着物联网技术的发展,数据量激增对数据库提出新挑战。Apache IoTDB凭借其面向时间序列数据的设计,在IoT领域脱颖而出。相较于传统数据库,IoTDB采用树形数据模型高效管理实时数据,具备轻量级结构与高并发能力,并集成Hadoop/Spark支持复杂分析。在智能城市等场景下,IoTDB能处理如交通流量等数据,为决策提供支持。IoTDB还提供InfluxDB协议适配器简化迁移过程,并支持细致的权限管理确保数据安全。综上所述,IoTDB在IoT数据管理中展现出巨大潜力与竞争力。
106 1
|
3月前
|
物联网 区块链 vr&ar
未来已来:探索区块链、物联网与虚拟现实技术的融合与应用安卓与iOS开发中的跨平台框架选择
【8月更文挑战第30天】在科技的巨轮下,新技术不断涌现,引领着社会进步。本文将聚焦于当前最前沿的技术——区块链、物联网和虚拟现实,探讨它们各自的发展趋势及其在未来可能的应用场景。我们将从这些技术的基本定义出发,逐步深入到它们的相互作用和集成应用,最后展望它们如何共同塑造一个全新的数字生态系统。
|
6天前
|
传感器 安全 算法
物联网发布者在数据传输过程中如何防止数据被篡改
在物联网数据传输中,为防止数据被篡改,可采用加密技术、数字签名、数据完整性校验等方法,确保数据的完整性和安全性。
|
6天前
|
存储 安全 算法
物联网发布者在发送数据时如何保证数据的安全性和完整性
数据加密、密钥管理和数据完整性验证是物联网安全的重要组成部分。对称加密(如AES)和非对称加密(如RSA)分别适用于大量数据和高安全需求的场景。密钥需安全存储并定期更新。数据完整性通过MAC(如HMAC-SHA256)和数字签名(如RSA签名)验证。通信协议如MQTT over TLS/SSL和CoAP over DTLS增强传输安全,确保数据在传输过程中的机密性和完整性。
|
1月前
|
Rust 资源调度 安全
为什么使用 Rust over C++ 进行 IoT 解决方案开发
为什么使用 Rust over C++ 进行 IoT 解决方案开发
66 7
|
2月前
|
物联网 C# C语言
物联网开发中C、C++和C#哪个更好用
在物联网(IoT)开发中,C、C++和C#各有优缺点,适用场景不同。C语言性能高、资源占用低,适合内存和计算能力有限的嵌入式系统,但开发复杂度高,易出错。C++支持面向对象编程,性能优秀,适用于复杂应用,但学习曲线陡峭,编译时间长。C#易于学习,与.NET框架结合紧密,适合快速开发Windows应用,但性能略低,平台支持有限。选择语言需根据具体项目需求、复杂性和团队技术栈综合考虑。
|
3月前
|
存储 分布式计算 物联网
Apache IoTDB进行IoT相关开发实践
当今社会,物联网技术的发展带来了许多繁琐的挑战,尤其是在数据库管理系统领域,比如实时整合海量数据、处理流中的事件以及处理数据的安全性。例如,应用于智能城市的基于物联网的交通传感器可以实时生成大量的交通数据。据估计,未来5年,物联网设备的数量将达数万亿。物联网产生大量的数据,包括流数据、时间序列数据、RFID数据、传感数据等。要有效地管理这些数据,就需要使用数据库。数据库在充分处理物联网数据方面扮演着非常重要的角色。因此,适当的数据库与适当的平台同等重要。由于物联网在世界上不同的环境中运行,选择合适的数据库变得非常重要。 原创文字,IoTDB 社区可进行使用与传播 一、什么是IoTDB 我
174 9
Apache IoTDB进行IoT相关开发实践
|
2月前
|
存储 传感器 物联网
结合物联网开发探讨C语言的变量
在物联网(IoT)开发中,C语言的变量起着至关重要的作用。由于物联网设备资源有限,C语言的高效性和对硬件的直接控制使其成为开发嵌入式系统的首选。
|
3月前
|
存储 传感器 监控
理解并利用物联网(IoT)数据的技术探索
【8月更文挑战第11天】物联网数据是数字化转型的重要资源。通过深入理解物联网数据的特性和价值,并采取有效的收集、处理和分析策略,我们可以更好地利用这些数据为企业决策提供支持、优化运营效率、创造新的商业模式并推动数字化转型的深入发展。
|
4月前
|
存储 分布式计算 物联网
Apache IoTDB进行IoT相关开发实践
IoTDB是专为物联网(IoT)设计的开源时间序列数据库,提供数据收集、存储、管理和分析。它支持高效的数据写入、查询,适用于处理大规模物联网数据,包括流数据、时间序列等。IoTDB采用轻量级架构,可与Hadoop和Spark集成,支持多种存储策略,确保数据安全和高可用性。此外,它还具有InfluxDB协议适配器,允许无缝迁移和兼容InfluxDB的API和查询语法,简化物联网项目的数据管理。随着物联网设备数量的快速增长,选择适合的数据库如IoTDB对于数据管理和分析至关重要。
246 12

相关产品

  • 物联网平台