变更记录

产品版本	更新内容	更新日期
V6.0.1	初始版本	2024年03月21日

1 业务场景

当存在1个数据源需要向多个目标同步数据时，可以利用数据流进行流式编排处理，实现1对N的数据同步。

该场景中以查询当前环境基础资料demo1的数据为例，同步到基础资料demo2和基础资料demo3中，模拟1对N的数据同步案例。

利用数据流的数据查询模型来进行基础资料demo1的数据抽取，并分别建立两个从demo1到demo2/3的数据映射模型和数据写入模型，并通过数据流图并行连接起来，实现最终的同步执行。

前提条件：对数据流已经有基本认识，学习过数据流入门案例。

- 步骤1：建立数据查询模型，于连接器分类目录最末级处新增数据查询模型。

注：此步骤即从源系统中将源数据读取出来，存放于“基础资料demo1查询”这一组件中。

选择“基础资料demo1（苍穹）”查询对象，并配置好查询条件参数和其他所需字段。根据业务需要选择过滤条件以及填充需要取数的字段：

- 步骤2：建立数据映射模型，于数据流方案目录最末级分类下分别新增基础资料demo1到基础资料demo2、基础资料demo1到基础资料demo3的数据映射模型。

注：此步骤即建立“基础资料demo1”和“基础资料demo2/3”中字段的映射关系，在数据流运行的过程中“基础资料demo1”中的数据将会通过该组件赋值到“基础资料demo2/3”中，以供下游使用。

分别选择源数据和目标数据，并配置好映射字段：

- 步骤3：建立数据加载的实体操作模型，于连接器分类目录最末级处新增实体操作模型。

注：此步骤即建立目标对象的数据写入操作，定义好输出的结果。

如图选择目标实体后，定义好操作和写入字段：

- 步骤4：建立数据流。

注：此步骤即数据流图的形式，将上述定义好的组件模型连接起来，实现整体的上下游关系。

如图于数据流方案目录最末级分类下新增“基础资料1到demo2和3”的数据流：

该数据流依次选择上述配置的组件模型：数据查询>字段映射>数据加载，一对多的情况下，需要配置如图多条映射和加载流程。

- 步骤5：建立并执行启动方案。

注：此步骤即建立该数据流的执行方案。

于【运行管理】-【启动方案】处点击新增，并选择上述配置的数据流。填写完成相关参数和连接器后，即可执行该启动方案：

执行结束后可以点击“数据流实例”，查看执行情况以及详细日志：