1对N数据同步，就是这么简单！
业务场景
在数据集成过程中，将一个源头数据同步到多个目标对象或者将一个数据同时分发到多个目标都是非常常见的场景。例如，基础资料的币别同步场景（集团->分公司1、集团->分公司2、集团->分公司3），就是很常见的1对N的数据同步。
本文将介绍一种简单高效的配置方案，利用数据流进行流式编排处理，实现1对N的数据同步。
方案思路
该方案以查询当前环境基础资料demo1的数据为例，同步到基础资料demo2和基础资料demo3中，模拟1对N的数据同步案例。
整体思路为：采用“集成服务云>数据流方案”，利用数据流的数据查询模型进行基础资料demo1的数据抽取，并分别建立两个数据映射模型（demo1-demo2和demo1-demo3）和数据写入模型（demo2和demo3），最后通过数据流图并行连接起来，实现最终的同步执行。
方案详情
1. 准备工作: 包括创建连接配置和连接器，同步集成对象，以及创建连接器目录和数据流方案目录。
图 1 - 连接配置
图 2 - 连接器
图 3 – 资源列表
图 4 - 资源方案目录
2. 创建资源: 通过集成对象导入，创建源和目标对象数据模型；创建数据查询、字段映射、数据加载等组件。
步骤1：建立数据查询模型
注：此步骤即从源系统中将源数据读取出来，存放于“基础资料demo1查询”这一组件中。
选择“基础资料demo1（苍穹）”查询对象，并配置好查询条件参数和其他所需字段。根据业务需要选择过滤条件以及填充需要取数的字段。
图 5 – 数据查询模型（demo1）
步骤2：建立字段映射模型
创建基础资料demo1到基础资料demo2、基础资料demo1到基础资料demo3的字段映射模型。
注：此步骤即建立“基础资料demo1”、 “基础资料demo2”和“基础资料demo3”中字段的映射关系，在数据流运行的过程中“基础资料demo1”中的数据将会通过该组件赋值到“基础资料demo2/3”中，以供下游使用。
分别选择源数据和目标数据，并配置好映射字段。
图 6 – 字段映射模型（demo1-demo2）
步骤3：建立数据加载的实体操作模型
注：此步骤即建立目标对象的数据写入操作，定义好输出的结果。
如图选择目标实体后，定义好操作和写入字段。
图 7 –数据加载实体操作模型（demo2）
步骤4：建立数据流
注：此步骤即数据流图的形式，将上述定义好的组件模型
1对N数据同步，就是这么简单！
声明：除非特别标注，否则均为本站原创文章，转载时请以链接形式注明文章出处。如若本站内容侵犯了原著者的合法权益，可联系本站删除。
