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到demo2和3”的数据流。
图 8 –数据流图
该数据流中,依次选择上述配置的组件模型:数据查询>字段映射>数据加载,一对多的情况下,需要配置如图多条映射和加载流程 。
步骤5:建立并执行启动方案
注:此步骤即建立该数据流的执行方案。
于“运行管理>启动方案“处点击<新增>,并选择上述配置的数据流。填写完成相关参数和连接器后,即可执行该启动方案。
图 9 – 数据流启动方案
执行结束后可以点击<数据流实例>,查看执行情况以及详细日志。
图 10 – 数据流实例
方案价值
通过数据流可以很简单地实现1-N的数据同步配置,并且数据流图中的资源以后都可以复用于其他数据流配置。
相关链接
数据流快速入门案例:https://vip.kingdee.com/link/s/lgCQd
本方案的详细步骤:https://vip.kingdee.com/article/535141678323909120
划重点
利用“集成服务云>数据流”方案,可轻松实现1对N的数据同步,方案步骤如下:
1、准备工作: 包括创建连接配置和连接器,同步集成对象,以及创建连接器目录和数据流方案目录。
2、创建资源: 通过集成对象导入,创建源和目标对象数据模型;创建数据查询、字段映射、数据加载等组件。
#往期推荐#
更多精彩内容,“码”上了解!↓
1对N数据同步,就是这么简单!
本文2024-09-23 00:53:23发表“云苍穹知识”栏目。
本文链接:https://wenku.my7c.com/article/kingdee-cangqiong-142396.html