变更记录

概要

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

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

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

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

流式处理示意图

案例

1 创建资源目录

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

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

2 创建数据流资源

创建流程如下

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

数据流资源关系如下

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

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

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

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

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

4、创建字段映射组件：源和目标数据模型分别选择基础资料demo1和基础资料demo2，并点击‘自动映射’。

5、创建数据加载组件：选择基础资料demo2作为目标实体，点击‘字段填充’，选择之前创建的映射组件自动将映射的目标字段作为加载字段。

3 创建数据流图

点击‘新增’选择数据流图。

填写数据流图的属性信息，并新增一个当前账套的外部系统声明。

参考下图配置数据流图的事件节点、转换节点、加载节点，并为每个节点绑定当前账套的连接器。

在数据流图中可以将数据模型理解成上下游传递数据的变量，他起到传递上下游数据的作用。

4 创建启动方案

在【运行管理】->【启动方案】中点击‘新增’，选择刚才创建的数据流，为其填充好入参，并绑定连接器。

注：连接器创建可参考连接器介绍

5、执行启动方案

执行启动方案后的运行逻辑如下，基础资料demo1的数据会源源不断的流向工作区，工作区中数据的行数总是不超过工作区大小300，后台任务引擎不断的为工作区中的数据分配线程运行（1条数据分配1个线程，不超过最大线程数3）。