(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211267579.9 (22)申请日 2022.10.17 (71)申请人 北京京东拓先 科技有限公司 地址 100176 北京市北京经济技 术开发区 科创十一 街18号院1号楼7层701室 (72)发明人 李治　 (74)专利代理 机构 中原信达知识产权代理有限 责任公司 1 1219 专利代理师 李娜　张效荣 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/23(2019.01) G06F 16/2455(2019.01) G06F 16/28(2019.01) G16H 10/60(2018.01)G16H 50/70(2018.01) (54)发明名称 一种数据处 理的方法和装置 (57)摘要 本发明公开了一种数据处理的方法和装置， 涉及互联网医疗技术领域。 该方法的一具体实施 方式包括： 向多个集群发送第一数据的数据存储 请求， 接收多个集群返回的执行结果； 在接收到 指示存储失败的第一执行结果的情况下， 触发数 据补偿规则； 基于数据补偿规则， 向多个集群中 与第一执行结果对应的第一集群发送第一数据 的数据存储请求， 以对第一集群进行数据补偿。 该实施方式通过接收多个集群 返回的执行结果， 在存在指示存储失败的第一执行结果的情况下 触发数据补偿规则， 对第一集群进行数据补偿， 保证了多个集群 之间的数据一致性， 保证了数据 存储的健壮性， 提升了多个集群高可用异地灾备 能力。 权利要求书2页 说明书10页 附图6页 CN 115495455 A 2022.12.20 CN 115495455 A 1.一种数据处 理的方法， 其特 征在于， 包括： 向多个集群发送第一数据的数据存 储请求， 接收所述多个集群返回的执 行结果； 在接收到指示存 储失败的第一执 行结果的情况 下， 触发数据补偿规则； 基于所述数据补偿规则， 向所述多个集群中与 所述第一执行结果对应的第 一集群发送 所述第一数据的数据存 储请求， 以对所述第一 集群进行 数据补偿。 2.根据权利要求1所述的方法， 其特征在于， 所述触发数据补偿规则包括： 向消息中间 件发送失败消息， 所述 失败消息包括所述第一集群的标识和与所述数据存储请求对应的操 作标识和与所述第一数据对应的数据标识； 基于所述数据补偿规则， 向所述多个集群中与 所述第一执行结果对应的第 一集群发送 所述第一数据的数据存 储请求， 包括： 从所述消息 中间件中获取所述失败消息， 根据所述数据标识从数据源获取所述第 一数 据， 根据所述操作标识向所述第一 集群重新发送所述第一数据的数据存 储请求。 3.根据权利要求2所述的方法， 其特征在于， 所述触发数据补偿规则还包括： 根据所述 操作标识向所述第一集群重新发送所述第一数据的数据存储请求之后， 获取重试失败次 数， 在所述重试失败次数超过第一预设阈值的情况下， 将所述失败消息存储至第一存储位 置。 4.根据权利要求3所述的方法， 其特征在于， 所述触发数据补偿规则还包括： 在所述第 一存储位置中的数据量满足预设条件的情况下， 启动第二存储位置， 将所述第二存储位置 作为所述失败消息的存 储位置。 5.根据权利要求3所述的方法， 其特征在于， 基于所述数据补偿规则， 向所述多个集群 中与所述第一执 行结果对应的第一 集群发送所述第一数据的数据存 储请求， 还 包括： 定时从所述第一存 储位置获取 所述失败信息； 在所述操作 标识指示更新或插入操作的情况下， 从指示存储成功的第 二执行结果对应 的第二集群中获取与所述数据标识对应的第二数据， 根据所述操作标识向所述第一集群发 送所述第二数据的数据存 储请求。 6.根据权利要求5所述的方法， 其特征在于， 所述失败消息还包括缓存时间戳， 定时从 所述第一存 储位置获取 所述失败信息之后， 还 包括： 在所述操作 标识指示删除操作的情况下， 从所述第 一集群中获取与 所述第一数据标识 对应的第三数据以及与所述第三数据对应的操作时间戳； 在所述操作时间戳小于所述缓存时间戳的情况下， 将所述第 三数据从所述第 一集群中 删除。 7.根据权利要求1所述的方法， 其特征在于， 所述方法还包括： 在接收到指示存储失败 的第一执 行结果的情况 下， 记录所述第一 集群的失败次数； 在失败次数大于第二预设阈值的情况下， 将所述第一集群的状态标记为不可用状态， 并关闭与所述第一 集群对应的路由策略； 其中， 与所述第一 集群对应的路由策略为向所述第一 集群发送数据存 储请求的策略。 8.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 监控所述第一 集群的查询失败次数； 在所述查询失败次数大于第 三预设阈值的情况下， 将所述第 一集群的状态标记为不可权　利　要　求　书 1/2 页 2 CN 115495455 A 2用状态， 并关闭与所述第一 集群对应的路由策略； 其中， 与所述第一 集群对应的路由策略为向所述第一 集群发送数据查询请求的策略。 9.根据权利要求8所述的方法， 其特征在于， 所述方法还包括： 将所述第一集群的状态 标记为不可用状态之后， 定时向所述第一集群发送查询指令， 并接 收与所述查询指令对应 的查询结果， 在所述查询结果指示所述第一集群的服务已恢复的情况下， 将所述第一集群 的状态标记为可用状态， 并开启与所述第一 集群对应的路由策略。 10.一种数据处 理的装置， 其特 征在于， 包括： 获取模块， 向多个集群发送第一数据的数据存储请求， 接收所述多个集群返回的执行 结果； 确定模块， 在接收到指示存 储失败的第一执 行结果的情况 下， 触发数据补偿规则； 执行模块， 基于所述数据补偿规则， 向所述多个集群中与所述第一执行结果对应的第 一集群发送所述第一数据的数据存 储请求， 以对所述第一 集群进行 数据补偿。 11.一种电子设备， 其特 征在于， 包括： 一个或多个处 理器； 存储装置， 用于存 储一个或多个程序， 当所述一个或多个程序被所述一个或多个处理器执行， 使得所述一个或多个处理器实 现如权利要求1 ‑9中任一所述的方法。 12.一种计算机可读介质， 其上存储有计算机程序， 其特征在于， 所述程序被处理器执 行时实现如权利要求1 ‑9中任一所述的方法。权　利　要　求　书 2/2 页 3 CN 115495455 A 3