(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210872009.6 (22)申请日 2022.07.19 (71)申请人 平安壹钱包电子商务有限公司 地址 518031 广东省深圳市福田区福田街 道福华路319号兆邦基金融大厦26层 2606单元 (72)发明人 郭湘宇　 (74)专利代理 机构 北京中强智尚知识产权代理 有限公司 1 1448 专利代理师 刘丽颖 (51)Int.Cl. G06F 16/21(2019.01) G06F 16/23(2019.01) G06F 16/28(2019.01) G06F 11/36(2006.01) (54)发明名称 基于异步双写的数据源切换方法、 装置、 设 备及存储介质 (57)摘要 本申请公开了一种基于异步双写的数据源 切换方法、 装置、 设备及存储介质， 涉及互联网技 术领域， 通过数据源配置开关， 在数据操作层进 行链路调整完成数据源的切换， 并不会侵入业务 逻辑， 并且可 以在出现切换异常情况时， 通过调 整数据源配置开关实现回滚目标功能。 所述方法 包括： 创建新链路为目标系统引入新数据源， 执 行异步双 写的前置更新； 基于新链路的数据源配 置开关， 将目标系统切换为第一状态， 并采集双 写数据， 将双写数据发送至预设信息匹配模型进 行匹配验证； 当验证双写数据匹配成功时， 切换 新数据源和原数据源， 以使主线程操作新数据源 的同时， 异步调用原数据源； 在目标系统运行稳 定后， 将目标系统切换为第二状态， 完成数据源 切换。 权利要求书2页 说明书8页 附图5页 CN 115129693 A 2022.09.30 CN 115129693 A 1.一种基于异步双写的数据源切换 方法， 其特 征在于， 包括： 创建新链路为目标系统引入新数据源， 执 行异步双写的前置更新； 基于所述新链路的数据源配置开关， 将所述目标系统切换为第一状态， 并采集双写数 据， 将所述双写数据发送至预设信息匹配模型进行匹配验证， 所述第一状态为主线程操作 原数据源的同时， 异步调用新数据源； 当验证所述双写数据匹配成功时， 切换所述新数据源和所述原数据源， 以使所述主线 程操作所述 新数据源的同时， 异步调用所述原数据源； 在所述目标系统运行稳定后， 将所述目标系统切换为第 二状态， 完成数据源切换， 所述 第二状态为停用异步双写， 所述主 线程操作所述 新数据源。 2.根据权利要求1所述的方法， 其特征在于， 所述创建新链路为目标系统引入新数据 源， 执行异步双写的前置更新， 包括： 确定所述新数据源， 为所述新数据源编写对应的映射文件， 所述映射文件用于增加参 数属性和数据对象， 支持所述目标系统同时对所述 新数据源和所述原数据源进行操作； 创建所述新链路， 在对所述目标系统的数据对象进行操作之前， 为所述新链路增加所 述数据源配置开关， 采用所述数据源配置开关引入所述 新数据源， 完成所述前置更新。 3.根据权利要求1所述的方法， 其特征在于， 所述基于所述新链路的数据源配置开关， 将所述目标系统切换为第一状态之前， 所述方法还 包括： 对所述目标系统进行冒烟测试和原数据源环境下的可用性测试； 在测试通过后， 将所述目标系统切换为第一状态。 4.根据权利要求1所述的方法， 其特征在于， 所述基于所述新链路的数据源配置开关， 将所述目标系统切换为第一状态， 并采集双写数据， 包括： 将所述数据源配置开关的开关值切换为异步双写， 以使所述目标系统处于所述第 一状 态； 发布所述目标系统， 创建数据拦截器， 调用所述数据拦截器获取所述目标系统的双写 数据， 将所述双写数据写入双写信息比对库。 5.根据权利要求4所述的方法， 其特征在于， 所述调用所述数据拦截器获取所述目标系 统的双写数据， 将所述双写数据写入双写信息比对库， 包括： 调用所述数据拦截器判断所述数据源配置开关的开关值； 当检测到所述开关值为异步双写时， 采用所述数据拦截器拦截所述数据操作层产生的 执行过程数据； 采用所述消息中间件， 接收所述执行过程数据作为所述双写数据， 将所述双写数据写 入双写信息比对库中存 储。 6.根据权利要求1所述的方法， 其特征在于， 所述将所述双写数据发送至预设信 息匹配 模型进行匹配验证之后， 所述方法还包括： 当验证所述双写 数据匹配失败时， 生成用于指示 匹配失败的提 示信息， 将所述 提示信息发送至展示终端 进行展示。 7.根据权利要求1所述的方法， 其特征在于， 所述切换所述新数据源和所述原数据源之 后， 所述方法还 包括： 在检测到对数据对象操作过程出现异常时， 回滚所述数据源配置开关； 重新采集双写数据， 并将所述双写数据发送至预设信息匹配模型进行匹配验证， 当验权　利　要　求　书 1/2 页 2 CN 115129693 A 2证所述双写数据匹配成功时， 切换 所述新数据源和所述原数据源。 8.一种基于异步双写的数据源切换装置， 其特 征在于， 包括： 创建模块， 用于创建新链路为目标系统引入新数据源， 执 行异步双写的前置更新； 采集模块， 用于基于所述新链路的数据源配置开关， 将所述目标系统切换为第 一状态， 并采集双写数据， 将所述双写数据发送至预设信息匹配模型进行匹配验证， 所述第一状态 为主线程操作原数据源的同时， 异步调用新数据源； 切换模块， 用于当验证所述双写数据匹配成功时， 切换所述新数据源和所述原数据源， 以使所述主 线程操作所述 新数据源的同时， 异步调用所述原数据源； 停用模块， 用于在所述目标系统运行稳定后， 将所述目标系统切换为第 二状态， 完成数 据源切换， 所述第二状态为停用异步双写， 所述主 线程操作所述 新数据源。 9.一种计算机设备， 包括存储器和处理器， 所述存储器存储有计算机程序， 其特征在 于， 所述处 理器执行所述计算机程序时实现权利要求1至7中任一项所述方法的步骤。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1至7中任一项所述的方法的步骤。权　利　要　求　书 2/2 页 3 CN 115129693 A 3