阿里云物联网平台、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

目录
相关文章
|
1月前
|
弹性计算 运维 安全
云迁移最佳实践:HyperMotion助中小企业高效上云,阿里云工具集深度集成三方迁移工具
中小企业上云需求强烈,但面临缺乏了解、无合适方案及成本过高等挑战。为解决这些问题,推出“云迁移HyperMotion阿里云集成版”,提供三步上云、自助迁移、自动适配等能力,助力企业高效、低成本完成迁移。
|
6月前
|
消息中间件 关系型数据库 MySQL
基于 Flink CDC YAML 的 MySQL 到 Kafka 流式数据集成
基于 Flink CDC YAML 的 MySQL 到 Kafka 流式数据集成
653 0
|
7月前
|
Java 关系型数据库 MySQL
SpringBoot 通过集成 Flink CDC 来实时追踪 MySql 数据变动
通过详细的步骤和示例代码,您可以在 SpringBoot 项目中成功集成 Flink CDC,并实时追踪 MySQL 数据库的变动。
1799 45
|
7月前
|
消息中间件 关系型数据库 MySQL
基于 Flink CDC YAML 的 MySQL 到 Kafka 流式数据集成
本教程展示如何使用Flink CDC YAML快速构建从MySQL到Kafka的流式数据集成作业,涵盖整库同步和表结构变更同步。无需编写Java/Scala代码或安装IDE,所有操作在Flink CDC CLI中完成。首先准备Flink Standalone集群和Docker环境(包括MySQL、Kafka和Zookeeper),然后通过配置YAML文件提交任务,实现数据同步。教程还介绍了路由变更、写入多个分区、输出格式设置及上游表名到下游Topic的映射等功能,并提供详细的命令和示例。最后,包含环境清理步骤以确保资源释放。
590 2
基于 Flink CDC YAML 的 MySQL 到 Kafka 流式数据集成
|
7月前
|
缓存 运维 监控
Anolis OS深度集成运维利器 阿里云操作系统控制台上线
阿里云在百万服务器运维领域的丰富经验打造。
Anolis OS深度集成运维利器 阿里云操作系统控制台上线
|
6月前
|
关系型数据库 MySQL 数据库
|
6月前
|
关系型数据库 MySQL OLAP
无缝集成 MySQL,解锁秒级 OLAP 分析性能极限,完成任务可领取三合一数据线!
通过 AnalyticDB MySQL 版、DMS、DTS 和 RDS MySQL 版协同工作,解决大规模业务数据统计难题,参与活动完成任务即可领取三合一数据线(限量200个),还有机会抽取蓝牙音箱大奖!
|
7月前
|
机器学习/深度学习 人工智能 自然语言处理
企业级API集成方案:基于阿里云函数计算调用DeepSeek全解析
DeepSeek R1 是一款先进的大规模深度学习模型,专为自然语言处理等复杂任务设计。它具备高效的架构、强大的泛化能力和优化的参数管理,适用于文本生成、智能问答、代码生成和数据分析等领域。阿里云平台提供了高性能计算资源、合规与数据安全、低延迟覆盖和成本效益等优势,支持用户便捷部署和调用 DeepSeek R1 模型,确保快速响应和稳定服务。通过阿里云百炼模型服务,用户可以轻松体验满血版 DeepSeek R1,并享受免费试用和灵活的API调用方式。
486 12
|
6月前
|
安全 持续交付 云计算
课时5:阿里云容器服务:最原生的集成Docker和云服务
阿里云容器服务以服务化形式构建容器基础设施,大幅提升开发效率,简化应用部署流程。通过Docker容器和DevOps工具(如Jenkins),实现自动化部署与迭代,优化企业内部复杂部署问题。该服务支持GPU调度、混合云架构无缝迁移,并与阿里云产品体系无缝集成,提供安全防护、网络负载均衡等多重功能支持。凭借微服务架构,帮助企业突破业务瓶颈,提高资源利用率,轻松应对海量流量。
237 0
课时5:阿里云容器服务:最原生的集成Docker和云服务
|
7月前
|
人工智能 自然语言处理 搜索推荐
阿里云 AI 搜索开放平台集成 DeepSeek 模型
阿里云 AI 搜索开放平台最新上线 DeepSeek -R1系列模型。
381 2

热门文章

最新文章

相关产品

  • 物联网平台
  • 推荐镜像

    更多