(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211151444.6 (22)申请日 2022.09.20 (71)申请人 中国建设银行股份有限公司 地址 100033 北京市西城区金融大街25号 申请人 建信金融科技有限责任公司 (72)发明人 李洋　 (74)专利代理 机构 中原信达知识产权代理有限 责任公司 1 1219 专利代理师 李雪楠　王志远 (51)Int.Cl. G06F 16/27(2019.01) G06F 9/445(2018.01) G06F 21/60(2013.01) G06F 21/62(2013.01) G06F 11/30(2006.01) (54)发明名称 一种数据的同步方法、 装置、 电子 设备、 介质 和程序产品 (57)摘要 本发明公开了一种数据 的同步方法、 装置、 电子设备、 介质和程序产品， 涉及数据处理技术 领域。 该方法的具体实施方式包括： 接收源头数 据库的数据同步请求， 向安插于源头数据库中的 采集插件发送采集指令， 以使采集插件采集源头 数据库的源数据； 其中， 数据同步请求包括目的 数据库； 对源数据进行校验， 筛选符合同步插件 要求的同步数据格式的目标数据； 利用安插于目 的数据库中的写入插件， 将目标数据写入目的数 据库。 该实施方式能够利用同步插件获取不同类 型分散数据库的业务数据， 并同步至目的数据 库， 一次开发即可多次利用， 用户使用便捷易上 手， 灵活性较高， 通用性和扩展 性极强， 大大节省 了数据同步的人力、 物力和时间成本， 简化后期 维护。 权利要求书4页 说明书16页 附图9页 CN 115544160 A 2022.12.30 CN 115544160 A 1.一种数据的同步方法， 其特 征在于， 所述方法应用于同步插 件， 包括： 接收源头数据库的数据同步请求， 向安插于所述源头数据库中的采集插件发送采集指 令， 以使所述采集插件采集所述源头数据库的源数据； 其中， 所述数据同步请求包括目的数 据库； 对所述源数据进行 校验， 筛选符合所述同步插 件要求的同步数据格式的目标 数据； 向安插于所述目的数据库中的写入插件发送写入指令， 以使所述写入插件将所述目标 数据写入所述目的数据库。 2.根据权利要求1所述的方法， 其特征在于， 所述以使所述采集插件采集所述源头数据 库的源数据， 包括： 接收所述采集插 件发送的第一密钥获取请求； 随机生成对称密钥； 响应于所述第一密钥获取请求， 将所述对称密钥发送给所述采集插件， 使得所述采集 插件根据所述对称密钥采集所述源数据。 3.根据权利要求2所述的方法， 其特征在于， 所述对所述源数据进行校验， 筛选符合所 述同步插 件要求的同步数据格式的目标 数据， 包括： 利用所述对称密钥对所述源数据进行解密， 得到解密后的元 数据和特 征数据； 分别判断所述元数据、 所述特征数据是否符合所述同步数据格式中元数据格式、 特征 数据格式的要求； 将符合所述同步数据格式要求的源数据作为目标 数据。 4.根据权利要求2所述的方法， 其特征在于， 在所述接收所述采集插件发送的第 一密钥 获取请求之前， 还 包括： 向所述采集插件下发第 一连接测试指令， 使得所述采集插件根据 所述第一连接测试指 令与所述源头数据库连接； 接收所述采集插件返回的第 一连接测试结果， 在所述第 一连接测试结果为所述采集插 件与所述源头数据库连接测试失败的情况 下， 拒绝所述数据同步请求。 5.根据权利要求1所述的方法， 其特征在于， 所述利用安插于所述目的数据库 上的写入 插件， 将所述目标 数据写入所述目的数据库， 包括： 接收所述写入 插件发送的第二密钥获取请求； 响应于所述第 二密钥获取请求， 将与所述数据同步请求对应的所述采集插件的对称密 钥发送给 所述写入 插件， 使得所述写入 插件根据所述对称密钥写入所述目标 数据。 6.根据权利要求2所述的方法， 其特征在于， 在所述接收所述写入插件发送的第 二密钥 获取请求之前， 还 包括： 向所述写入插件下发第 二连接测试指令， 使得所述写入插件根据 所述第二连接测试指 令与所述目的数据库连接； 接收所述写入插件返回的第 二连接测试结果， 在所述第 二连接测试结果为所述写入插 件与所述目的数据库连接测试失败的情况 下， 拒绝所述数据同步请求。 7.根据权利要求1所述的方法， 其特征在于， 在所述源头数据库和/或所述目的数据库 为多个数据库的情况下， 多个所述源头数据库和/或多个所述 目的数据库的数据库类型相 同或者不同。权　利　要　求　书 1/4 页 2 CN 115544160 A 28.根据权利要求1所述的方法， 其特 征在于， 还 包括： 对所述采集插件和/或所述写入插件进行监控， 定位所述传输故障的所述采集插件和/ 或所述写入 插件并发出警示 提醒。 9.根据权利要求1所述的方法， 其特 征在于， 还 包括： 记录所述采集插件响应于所述数据同步请求的采集 时间、 源头数据库的数据库 标识和 源数据， 生成所述采集插 件的采集日志； 和/或， 记录所述写入插件响应于所述数据同步请求的写入时间、 目的数据库的数据库 标识和 目标数据， 生成所述写入 插件的写入日志。 10.一种数据的同步方法， 其特征在于， 所述方法应用于安插于源头数据库的采集插 件， 包括： 接收同步插 件发送的采集指令； 响应于所述采集指令， 采集所述源头数据库的源数据； 将所述源数据发送给 所述同步插 件。 11.根据权利要求10所述的方法， 其特征在于， 所述采集所述源头数据库的源数据， 包 括： 获取所述源头数据库的原 始数据； 按照同步数据格式， 提取 所述原始数据中的元 数据和特 征数据； 对所述元 数据和所述特 征数据进行对称加密， 得到对称加密后的所述源数据。 12.根据权利要求11所述的方法， 其特征在于， 所述同步数据格式包括特征数据格 式和 元数据格式， 所述元数据格式包括签名字段和其它字段； 所述按照同步数据格式， 提取所述 原始数据中的元 数据和特 征数据， 包括： 根据所述特征数据格式和所述元数据格式的其它字段， 提取所述原始数据的特征数据 和元数据的其它字段 数据； 生成所述特 征数据的数字摘要， 确定所述数字摘要为所述元 数据的签名字段 数据； 将所述其它字段 数据和所述签名字段 数据组合 为所述原 始数据的元 数据。 13.根据权利要求11所述的方法， 其特征在于， 在所述对所述元数据和所述特征数据进 行对称加密之前， 还 包括： 向所述同步插 件发送第一密钥获取请求； 接收所述同步插件返回的随机生成的对称密钥， 利用所述对称密钥对所述元数据和所 述特征数据进行对称加密。 14.根据权利要求13所述的方法， 其特征在于， 在所述按照同步数据格式， 提取所述原 始数据中的元 数据和特 征数据之前， 还 包括： 接收所述同步插 件下发的第一连接测试指令； 响应于所述第一连接测试指令， 与所述源头数据库进行连接， 确定与所述源头数据库 的第一连接测试 结果； 将所述第一连接测试 结果发送给 所述同步组件。 15.根据权利要求10所述的方法， 其特 征在于， 还 包括： 接收所述同步插 件下发的采集结束指令；权　利　要　求　书 2/4 页 3 CN 115544160 A 3