概述

您可以使用规则引擎将数据转到DataHub上，再由DataHub将数据流转至实时计算、MaxCompute等服务中，以实现更多计算场景。本文主要演示通过规则引擎将消息流转到DataHub，并通过Dataconnector 将消费流转到MaxCompute的表。

Step By Step

物联网平台创建产品和设备

参考链接：产品及设备准备部分。

创建DataHub Project 和 Topic

1、创建Datahub Project

2、创建Topic

规则引擎配置

1、创建规则引擎、配置处理数据

参考链接 规则引擎配置配置部分。

2、配置转发数据

3、启动设备端SDK，消息流转

4、流转日志查询

创建Dataconnector

1、maxcompute创建表

CREATE TABLE datahubforiot (

<span class="hljs-string">`devicename`</span> string,
<span class="hljs-string">`humidity`</span> string,
<span class="hljs-string">`temperature`</span> string,
<span class="hljs-string">`time`</span> string

)
PARTITIONED BY (ds string,hh string,mm string)
LIFECYCLE 100;

2、创建Dataconnector

3、Dataworks SQL任务查询

参考链接

数据转发到DataHub