(19)国家知识产权局
(12)发明 专利申请
(10)申请公布号
(43)申请公布日
(21)申请 号 202210858574.7
(22)申请日 2022.07.20
(71)申请人 北京理房通支付科技有限公司
地址 100193 北京市海淀区东北旺西路8号
院4号楼145号
(72)发明人 陈磊
(74)专利代理 机构 北京润平知识产权代理有限
公司 11283
专利代理师 高英英
(51)Int.Cl.
G06F 16/27(2019.01)
G06F 16/23(2019.01)
G06F 16/242(2019.01)
(54)发明名称
数据同步的方法和装置
(57)摘要
本发明实施例提供一种数据 同步的方法和
装置, 属于计算机技术领域。 该方法包括: 接收关
于业务数据的变更消息, 其中, 变更消息用于提
供业务数据中的变更内容和变更动作; 根据是否
为变更内容涉及的业务属性中的至少一个业务
属性设置 预设映射规则, 判断是否对变更消息进
行过滤; 在不对变更消息进行过滤的情况下, 确
定检索库中与至少一个业务属性对应的索引记
录以及根据至少一个业务属性对应的预设映射
规则确定检索库与至少一个业务属性对应的检
索属性以及所确定的检索属性的更新属性值; 以
及将所确定的检索属性的属性值变更为更新属
性值, 以将业务数据同步到检索库。 藉此, 实现了
在检索库中的全量与业务数据保持同步的同时
降低了耗时。
权利要求书1页 说明书8页 附图3页
CN 115129788 A
2022.09.30
CN 115129788 A
1.一种数据同步的方法, 其特 征在于, 该 方法包括:
接收关于所述业务数据的变更消息, 其中, 所述变更消息用于提供所述业务数据中的
变更内容和变更动作, 其中, 所述变更动作包括新增和/或删除和/或更新, 所述变更内容包
括新增的业 务记录和/或删除的业 务记录和/或更新的业 务属性的业 务属性值;
根据是否为所述变更内容涉及的业务属性中的至少一个业务属性设置预设映射规则,
判断是否对所述变更消息进行 过滤;
在不对所述变更消息进行过滤的情况下, 确定检索库中与所述至少一个业务属性对应
的索引记录以及根据所述至少一个业务属 性对应的所述预设 映射规则确定所述检索库中
与所述至少一个业 务属性对应的检索属性以及所确定的检索属性的更新属性 值; 以及
将所确定的检索属性的属性值变更为所述更新属性值, 以将所述业务数据同步到所述
检索库。
2.根据权利要求1所述的方法, 其特征在于, 针对任一所述业务属性, 所述预设映射规
则为以下任一 者: 简单映射、 聚合映射、 嵌套映射、 回调映射和常量映射。
3.根据权利要求1或2所述的方法, 其特 征在于, 所述变更消息为bi nlog消息。
4.一种数据同步的装置, 其特 征在于, 该装置包括:
接收模块, 用于接收关于所述业务数据的变更消息, 其中, 所述变更消息用于提供所述
业务数据中的变更内容和变更动作, 其中, 所述变更动作包括新增和/或删除和/或更新, 所
述变更内容包括新增的业务记录和/或删除的业务记录和/或更新的业务属 性的业务属 性
值;
过滤判断模块, 根据 是否为所述变更内容涉及的业务属性中的至少一个业务属性设置
预设映射 规则, 判断是否对所述变更消息进行 过滤;
确定模块, 用于在不对所述变更消息进行过滤的情况下, 确定检索库中与所述至少一
个业务属 性对应的索引记录以及根据所述至少一个业务属 性对应的所述预设 映射规则确
定所述检索库中与所述至少一个业务属 性对应的检索属 性以及所确定的检索属 性的更新
属性值; 以及
更新模块, 用于将所确定的检索属性的属性值变更为所述更新属性值, 以将所述业务
数据同步到所述检索库。
5.根据权利要求4所述的装置, 其特征在于, 针对任一所述业务属性, 所述预设映射规
则为以下任一 者: 简单映射、 聚合映射、 嵌套映射、 回调映射和常量映射。
6.根据权利要求 4或5所述的装置, 其特 征在于, 所述变更消息为bi nlog消息。
7.一种机器可读存储介质, 其特征在于, 该机器可读存储介质上存储有指令, 该指令用
于使得机器执 行权利要求1 ‑3中任一项所述的方法。
8.一种计算机程序产品, 包括计算机程序/指令, 其特征在于, 该计算机程序/指令被处
理器执行时实现权利要求1 ‑3中任一项所述的方法。
9.一种处理器, 其特征在于, 用于运行程序, 其中, 所述程序被运行时用于执行权利要
求1‑3中任一项所述的方法。权 利 要 求 书 1/1 页
2
CN 115129788 A
2数据同步的方 法和装置
技术领域
[0001]本发明涉及计算机技 术领域, 具体地涉及一种数据同步的方法和装置 。
背景技术
[0002]目前业务系统数据多是关系型的, 某些复杂的检索场景下, 需要将业务数据同步
到检索类型库。 现有同步方案多 是有业务系统同步的, 有许多 无法解决 的缺陷: 1)全量同步
耗时长; 2)检索影响范围难确定, 同步的时效性难保障; 3)跨部门数据 依赖, 资源难协调, 响
应慢; 4)业 务耦合严重, 接入维护检索成本高; 5)不具有通用性, 问题频发且 难排查。
发明内容
[0003]本发明实施例的目的是提供一种数据同步的方法和装置, 其可解决或至少部分解
决上述问题。
[0004]为了实现上述目的, 本发明实施例的一个方面提供一种数据同步的方法, 该方法
包括: 接收关于所述业务数据的变更消息, 其中, 所述变更消息用于提供所述业务数据中的
变更内容和变更动作, 其中, 所述变更动作包括新增和/或删除和/或更新, 所述变更内容包
括新增的业务记录和/或删除的业务记录和/或更新的业务属性的业务属性值; 根据是否为
所述变更内容涉及的业务属性中的至少一个业务属性设置预设映射规则, 判断是否对所述
变更消息进行过滤; 在不对所述变更消息进行过滤 的情况下, 确定检索库中与所述至少一
个业务属 性对应的索引记录以及根据所述至少一个业务属 性对应的所述预设 映射规则确
定所述检索库中与所述至少一个业务属 性对应的检索属 性以及所确定的检索属 性的更新
属性值; 以及将所确定的检索属 性的属性值变更为所述更新属 性值, 以将所述业务数据同
步到所述检索库。
[0005]可选地, 针对任一所述业务属性, 所述预设映射规则为以下任一者: 简单映射、 聚
合映射、 嵌套映射、 回调映射和常量映射。
[0006]可选地, 所述变更消息为bi nlog消息。
[0007]相应地, 本发明实施例的另一方面提供一种数据同步的装置, 该装置包括: 接收模
块, 用于接收关于所述业务数据的变更消息, 其中, 所述变更消息用于提供所述业务数据中
的变更内容和变更动作, 其中, 所述变更动作包括新增和/或删除和/或更新, 所述变更内容
包括新增的业务记录和/或删除的业务记录和/或更新的业务属性的业务属性值; 过滤判断
模块, 根据是否为所述变更内容涉及的业务属性中的至少一个业务属性设置预设映射规
则, 判断是否对所述变更消息进 行过滤; 确定模块, 用于在不对所述变更消息进 行过滤的情
况下, 确定检索库中与所述至少一个业务属性对应的索引记录以及根据所述至少一个业务
属性对应的所述预设 映射规则确定所述检索库中与所述至少一个业务属 性对应的检索属
性以及所确定的检索属 性的更新属 性值; 以及更新模块, 用于将所确定的检索属 性的属性
值变更为所述更新属性 值, 以将所述 业务数据同步到所述检索库。
[0008]可选地, 针对任一所述业务属性, 所述预设映射规则为以下任一者: 简单映射、 聚说 明 书 1/8 页
3
CN 115129788 A
3
专利 数据同步的方法和装置
文档预览
中文文档
13 页
50 下载
1000 浏览
0 评论
0 收藏
3.0分
温馨提示:本文档共13页,可预览 3 页,如浏览全部内容或当前文档出现乱码,可开通会员下载原始文档
本文档由 SC 于 2024-02-07 12:43:13上传分享