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
目录
相关文章
|
4月前
|
物联网
STC51单片机-实验开发装置仿真-物联网应用系统设计
STC51单片机-实验开发装置仿真-物联网应用系统设计
50 0
|
4月前
|
存储 物联网 大数据
助力工业物联网,工业大数据之脚本开发【五】
助力工业物联网,工业大数据之脚本开发【五】
39 0
|
7月前
|
关系型数据库 物联网 PostgreSQL
沉浸式学习PostgreSQL|PolarDB 11: 物联网(IoT)、监控系统、应用日志、用户行为记录等场景 - 时序数据高吞吐存取分析
物联网场景, 通常有大量的传感器(例如水质监控、气象监测、新能源汽车上的大量传感器)不断探测最新数据并上报到数据库. 监控系统, 通常也会有采集程序不断的读取被监控指标(例如CPU、网络数据包转发、磁盘的IOPS和BW占用情况、内存的使用率等等), 同时将监控数据上报到数据库. 应用日志、用户行为日志, 也就有同样的特征, 不断产生并上报到数据库. 以上数据具有时序特征, 对数据库的关键能力要求如下: 数据高速写入 高速按时间区间读取和分析, 目的是发现异常, 分析规律. 尽量节省存储空间
595 1
|
4月前
|
传感器 物联网 5G
物联网的通信技术以及Wi-Fi、一键配网技术、BLE、GPRS(2G)、LTE-Cat1 、NB-IoT简介
物联网的一个重要的特点是接入了网络,因此这些设备才能将传感器采集的数据上传到云平台,然后根据平台对数据的分析做出反应。而这种接入网络的技术,就是通信技术,是物联网的基础之一。通信的方式可以分为有线和无线两种方式,因为有线通信的成本较高,无线通信技术在物联网中应用比较广泛。
|
1月前
|
消息中间件 存储 Cloud Native
深度剖析 RocketMQ 5.0,IoT 消息:物联网需要什么样的消息技术?
本文来学习一个典型的物联网技术架构,以及在这个技术架构里面,消息队列所发挥的作用。在物联网的场景里面,对消息技术的要求和面向服务端应用的消息技术有什么区别?学习 RocketMQ 5.0 的子产品 MQTT,是如何解决这些物联网技术难题的。
90753 3
|
3月前
|
存储 安全 数据管理
构建智慧家庭的未来:物联网平台与智能家居系统的开发
在数字化时代,物联网平台和智能家居系统的开发日益受到关注。本文将探讨物联网平台和智能家居系统的定义、优势以及开发过程中的挑战与解决方案。通过对智能家居系统的构建和物联网平台的应用,我们可以实现更加智能、高效和安全的生活环境。
|
5月前
|
安全 物联网 物联网安全
物联网安全IoT攻击向量威胁
物联网主要有两种感染途径:暴力破解弱密码和利用网络服务中的漏洞。
101 0
|
5月前
|
边缘计算 供应链 安全
|
6月前
|
边缘计算 安全 物联网
开源在物联网(IoT)中的应用
开源在物联网(IoT)中的应用
135 0
|
7月前
|
传感器 安全 物联网
一个非常优秀的跨平台物联网开发常用的网络请求库libcurl
一个非常优秀的跨平台物联网开发常用的网络请求库libcurl
173 1

相关产品

  • 物联网平台