阿里云物联网平台、DataHub、RDS和DataV集成样例

简介: 本文通过一个DEMO,演示了如何基于阿里云产品和服务实现设备数据在大屏上显示。在设备端模拟两个点位,通过MQTT协议向阿里云物联网平台设备(高级版)发送数据,物联网平台接收到数据后通过规则引擎转发至DataHub,接着在DataHub中通过DataConnector将数据同步到RDS MySQL数据库中,最终使用DataV将RDS MySQL中数据呈现在大屏上。

1.         概述

本文通过一个DEMO,演示了如何基于阿里云产品和服务实现设备数据在大屏上显示。在设备端模拟两个点位,通过MQTT协议向阿里云物联网平台设备(高级版)发送数据,物联网平台接收到数据后通过规则引擎转发至DataHub,接着在DataHub中通过DataConnector将数据同步到RDS MySQL数据库中,最终使用DataVRDS MySQL中数据呈现在大屏上。

物联网平台转发至DataHub是因为DataHub可以将数据同步至MaxComputer,为后续数据计算做准备。

2.         物联网平台

物联网平台主要负责获取设备端数据,并通过规则引擎将数据转发至Table StoreDataHubRDSMessage ServiceMessage QueueHiTSDBFC以及另外一个Topic

2.1.        创建产品

[1]       https://iot.console.aliyun.com/

[2]       【产品管理】-【高级版】-【创建产品】

e21d291673de256303543dfb6057d9fbebc4b03e

 

2.2.        添加设备

[1]       【设备管理】-【添加设备】

d692f51988f6fef323476676efd7c0ebf8f4c204

 

2.3.        创建规则-处理数据

[1]       【规则引擎】-【创建规则】

ac2040f0e7bfb3ba0604436bb5a8b24a4c1a66dc

 

[2]       编写SQL

n  【规则引擎】-【规则列表】-【管理】:规则详情

n  完成【字段】、【Topic】的填写后,自动生成【规则查询语句:】SELECT content, age FROM “/a1aTa12qI93/myiRobot/user/update” WHERE

4da30eb0436c02febac30bbd7d002d599c8cb9a4

2.4.        规则引擎-添加操作

[1]       【添加操作】-【发送数据到DataHub】:如果未创建DataHub,则按第3小节说明创建DataHub

424c7c8117b188c3459e8fddddef7b8c821be3f2

 

2.5.        启动规则引擎

 

9e78ad6f3941edb642312c0aa2360841a864ec24

3.         DataHub

3.1.        创建Topic

[1]       进入阿里云DataHub控制台https://datahub.console.aliyun.com/

[2]       【项目管理】-【华东2(上海)】-【创建Project

[3]       【项目列表】-【查看】-【创建Topic】:添加两个点位,c1c2

 

98a40708a66b9c4482babb4d2990e482dbb0ebc6

 

b9f755397ecac0b52bbb8b1dffa0f9387f37c1cc

3.2.        数据同步

[1]       【项目管理】-【华东2-myirobotdatahub-【查看】-gettwostring-【查看】-DataConnector

[2]       【同步到RDS Mysql: 如果RDS未创建,则按第4小节描述操作

1cab32b692b681b6edea0d7e6335468c28a03e79

4.         RDS Mysql

4.1.        创建实例

[1]       https://rdsnext.console.aliyun.com

[2]       创建实例后,需等候几分钟。

3425bac7309fda8b46d4641f736ff9afbd690783

4.2.        建表

[1]       【云数据库RDS-【管理】-【基本信息】:以下数据需要在DataHub中填写

n  内网地址

n  内网端口

[2]       【云数据库RDS-【管理】-【账号管理】:root和密码

[3]       【云数据库RDS-【管理】-【数据库管理】-【创建数据库】:mydb

[4]       【云数据库RDS-【管理】-【数据库管理】-【数据安全性】:设置成允许任何IP访问, 0.0.0.0/0

[5]       【云数据库RDS-【管理】-【登录数据库】:通过DMS管理数据,新建表mytable,两个字段

8218aed5ef28f573fb81d73060f373bbbf4f29c9

 

4f2e031889d30c60b99bd46272a8a53bc2633f90

5.         DataV

[1]       http://datav.aliyun.com/ 51/

[2]       数据源:【域名】填写RDS内网地址,【名称】可自定义,【用户名】和【密码】和RDS中设置保持一致

[3]       SQL: SELECT c1,c2 FROM mytable

24146eebffe4c5bbb36860799293d76dfdafc039

[4]       【我的可视化】-【新建可视化】:选择列表区域后,右下角【自定义列】

n  标签1

Ø  列字段名c1

Ø  列显示名content

n  标签2

Ø  列字段名c2

Ø  列显示名age

eaf1754af8497d70f5f449ccffa24027f1155806

 

6.         验证

6.1.        运行MQTT客户端

[1]            进入官网:www.aliyun.com

[2]            【文档】-【阿里云物联网平台】> 【设备端开发指南】> SDK使用参考】> JAVA-SDK (MQTT)

[3]            下载iotx-sdk-mqtt-java-20170526.zip

[4]            解压iotx-sdk-mqtt-java-20170526

[5]            导入Eclipse

n  file-import-Maven-Existing Maven Projects

n  编辑SimpleClient4IOT.java文件以下内容

(1)  修改设备三元组

n  public static String deviceName = "myiRobot";

n  public static String productKey = "a1aTa12qI93";

n  public static String secret = "WvHXg4EZqSFkVephkPQ1N1**********";

(2)  修改topic

n  private static String subTopic = "/" + productKey + "/" + deviceName + "/user/get";

n  private static String pubTopic = "/" + productKey + "/" + deviceName + "/user/update";

n  修改content

(3)  运行Java Applicatiion

c8e77e4f6351718abc9497eb95e44b9b14488b27

3f19f25841568ff6a37ee25445d8ada96ce21118

1a09d3ea385d9c760fc17140e3a325d5140663d9

fcc0626e27a6b827c848e26bcdbf2ffc06fea3b1

 


6.2.        DataHub控制台

564783d0e0c95d3cfb1aab1212e55836f6785025

6.3.        RDS

804c3f4cb45efaa3ca906ee85621dbed3b4786a8

 

6.4.        DataV

5741d1d27500a62d8be6edb9b519e8957cdb26db

目录
相关文章
|
12天前
|
存储 JSON Ubuntu
时序数据库 TDengine 支持集成开源的物联网平台 ThingsBoard
本文介绍了如何结合 Thingsboard 和 TDengine 实现设备管理和数据存储。Thingsboard 中的“设备配置”与 TDengine 中的超级表相对应,每个设备对应一个子表。通过创建设备配置和设备,实现数据的自动存储和管理。具体操作包括创建设备配置、添加设备、写入数据,并展示了车辆实时定位追踪和车队维护预警两个应用场景。
36 3
|
16天前
|
存储 边缘计算 物联网
阿里云物联网平台:推动万物互联的智能化解决方案
随着物联网技术的快速发展,阿里云物联网平台为企业提供了一体化的解决方案,包括设备接入、数据管理和智能应用等核心功能。平台支持海量设备接入、实时数据采集与存储、边缘计算,并具备大规模设备管理、高安全性和开放生态等优势。广泛应用于智能制造、智慧城市和智能家居等领域,助力企业实现数字化转型。
89 5
|
3月前
|
存储 C# 关系型数据库
“云端融合:WPF应用无缝对接Azure与AWS——从Blob存储到RDS数据库,全面解析跨平台云服务集成的最佳实践”
【8月更文挑战第31天】本文探讨了如何将Windows Presentation Foundation(WPF)应用与Microsoft Azure和Amazon Web Services(AWS)两大主流云平台无缝集成。通过具体示例代码展示了如何利用Azure Blob Storage存储非结构化数据、Azure Cosmos DB进行分布式数据库操作;同时介绍了如何借助Amazon S3实现大规模数据存储及通过Amazon RDS简化数据库管理。这不仅提升了WPF应用的可扩展性和可用性,还降低了基础设施成本。
73 0
|
4月前
|
存储 运维 监控
阿里云物联网平台的优势
【7月更文挑战第19天】阿里云物联网平台的优势
72 1
|
4月前
|
传感器 供应链 物联网
ERP系统与物联网(IoT)集成:实现智能化业务管理
【7月更文挑战第29天】 ERP系统与物联网(IoT)集成:实现智能化业务管理
290 0
|
5月前
|
传感器 安全 物联网
物联网(IoT)设备的硬件选型与集成技术博文
【6月更文挑战第28天】物联网设备硬件选型与集成聚焦关键要素:功能匹配、性能稳定性、兼容扩展及成本效益。嵌入式系统、通信协议、数据处理和安全性技术确保集成效果,支撑高效、智能的IoT系统,驱动家居、城市与工业自动化变革。
|
6月前
|
物联网 测试技术 持续交付
探索自动化测试在持续集成中的关键作用未来技术纵横谈:区块链、物联网与虚拟现实的融合革新
【5月更文挑战第27天】随着敏捷开发和持续集成(CI)的广泛采用,自动化测试已成为确保软件质量和快速交付的基石。本文将探讨自动化测试在持续集成流程中的核心地位,分析其如何提高测试效率、降低错误率,并支持快速的迭代开发。通过实例和数据支持,我们将深入理解自动化测试对于现代软件开发实践的重要性,并讨论实施自动化测试时面临的挑战及解决策略。
|
6月前
|
SQL 关系型数据库 Java
实时计算 Flink版操作报错之在阿里云DataHub平台上执行SQL查询GitHub新增star仓库Top 3时不显示结果,是什么原因
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
6月前
|
Cloud Native 安全 物联网
【阿里云云原生专栏】云边端一体化:阿里云如何利用云原生技术赋能物联网
【5月更文挑战第22天】阿里云借助云原生技术赋能物联网,实现云边端一体化,提升系统弹性与敏捷性。通过容器化部署,保证高可用性与可靠性。在智能交通等领域,阿里云提供高效解决方案,实现实时数据分析与决策。代码示例展示如何使用阿里云服务处理物联网数据。同时,阿里云重视数据安全,采用加密和访问控制保障数据隐私。丰富的工具和服务支持开发者构建物联网应用,推动技术广泛应用与发展。
351 1
|
6月前
|
消息中间件 存储 JavaScript
阿里云IOC物联网异步处理基础概念
该内容介绍了异步处理基础和消息队列的相关概念。首先,同步处理指任务完成后才能执行其他操作,而异步则允许任务并行执行,不阻塞程序。异步能提高系统并发性和响应性,但也增加复杂性和资源消耗。接着,提到了消息队列,包括生产者、消费者、队列、broker和topic等概念,并指出在IoT中,设备作为生产者发送消息到特定topic,消费者从队列获取数据。最后,简要介绍了AMQP协议,它是用于应用程序间消息传递的开放标准,常用于分布式系统和物联网,如RabbitMQ和Apache Qpid。课程将以Apache Qpid为例接收IoT数据。
219 6
阿里云IOC物联网异步处理基础概念

热门文章

最新文章

相关产品

  • 物联网平台