概述
您可以使用规则引擎将数据转到 DataHub 上, 再由 DataHub 将数据流转至实时计算, MaxCompute 等服务中, 以实现更多计算场景. 本文主要演示通过规则引擎将消息流转到 DataHub, 并通过 DataHub SDK 消费流转的消息.
Step By Step
物联网平台创建产品和设备
参考链接: 产品及设备准备部分.
创建 DataHub Project 和 Topic
1, 创建 Datahub Project
2, 创建 Topic
规则引擎配置
1, 创建规则引擎, 配置处理数据
参考链接 规则引擎配置配置部分.
2, 配置转发数据
3, 启动设备端 SDK, 消息流转
4, 流转日志查询
创建 Dataconnector
1,maxcompute 创建表
- CREATE TABLE `datahubforiot` (
- `devicename` string,
- `humidity` string,
- `temperature` string,
- `time` string
- )
- PARTITIONED BY (ds string,hh string,mm string)
- LIFECYCLE 100;
2, 创建 Dataconnector
3,Dataworks SQL 任务查询
参考链接
数据转发到 DataHub
来源: https://yq.aliyun.com/articles/743985