数据流快速入门案例

变更记录

概要

受众：了解集成管理，但是对数据流完全不了解的开发/实施人员。

目标：通过案例快速了解数据流基本特性和配置流程。

场景：将当前环境中指定创建时间以后的数据从基础资料demo1同步到基础资料demo2。

注：该入门案例不具备实际业务意义，只作为学习参考使用。

流式处理示意图

案例

1 创建资源目录

在数据流资源左树的连接器下创建资源目录，该目录必须创建三层，通常为行业、系统、模块，用来存放和特定系统相关的数据流资源。

在数据流资源左树的数据流方案下创建资源目录，该目录必须创建两层，通常为集成场景概述、集成场景详细说明，用来存放和业务场景相关的数据流资源。

2 创建数据流资源

创建流程如下

注：准备工作仅第一次创建需要配置，如果已经存在集成对象和资源目录等资源可以无需创建。

数据流资源关系如下

1、创建数据模型：在数据流资源列表左树选中演示数据后点击‘集成对象导入’，搜索并导入基础资料demo1和基础资料demo2。

注：如果没有基础资料demo1和基础资料demo2，请参考集成对象介绍进行同步。

2、创建数据查询组件：点击‘新增’，选择数据查询，并选择刚才创建的基础资料demo1。

点击‘查询条件参数’，选择预置的时间范围参数作为入参结构，参考下图配置过滤条件，并点击‘自动填充’。

3、创建人工启动事件模型：选择刚才创建的数据查询组件作为数据提供者，创建事件模型。

4、创建字段映射组件：源和目标数据模型分