异构数据库同步的数据容错处理方法、装置、设备及介质与流程

本发明涉及数据库，尤其涉及一种异构数据库同步的数据容错处理方法、装置、设备及介质。

背景技术：

1、随着企业数字化转型的深入与it架构的演进，数据同步技术已成为支撑数据流动、业务连续性、混合云部署及实时数据分析的核心基础设施。其应用场景广泛，包括但不限于：数据库迁移与升级、业务系统解耦与数据分发、构建实时数据仓库与数据湖、实现多活与灾备架构等。在此背景下，异构数据库逻辑同步的需求日益凸显。企业常同时使用多种数据库，以实现不同的业务目标。然而，异构环境带来了显著的兼容性挑战。其中，数据定义语言操作和数据控制语言操作在不同数据库厂商的实现中存在大量私有语法、扩展功能及行为差异，这些差异导致在异构数据库逻辑同步过程中，极易引发同步中断，严重影响了数据的一致性。因此，在异构数据库同步过程中，如何提高数据的一致性，成为亟须解决的问题。

技术实现思路

1、本发明提供一种异构数据库同步的数据容错处理方法、装置、设备及介质，以解决在异构数据库同步过程中，数据一致性差的问题。

2、第一方面，提供了一种异构数据库同步的数据容错处理方法，所述数据容错处理方法包括：

3、在捕获到源数据库预设的操作事件后，进行当前同步处理，若进行当前同步处理的过程中触发异常，则对所述异常进行分类，得到异常分类结果，所述当前同步处理为将操作事件的操作对象同步至目标异构数据库；

4、根据所述异常分类结果，确定与所述异常分类结果匹配的熔断处理决策，基于所述熔断处理决策，确定对应的当前熔断对象；

5、根据所述异常分类结果，确定所述当前熔断对象对应的容错动作，并执行所述容错动作。

6、第二方面，提供了一种异构数据库同步的数据容错处理装置，所述数据容错处理装置包括：

7、分类模块，用于在捕获到源数据库预设的操作事件后，进行当前同步处理，若进行当前同步处理的过程中触发异常，则对所述异常进行分类，得到异常分类结果，所述当前同步处理为将操作事件的操作对象同步至目标异构数据库；

8、匹配模块，用于根据所述异常分类结果，确定与所述异常分类结果匹配的熔断处理决策，基于所述熔断处理决策，确定对应的当前熔断对象；

9、确定模块，用于根据所述异常分类结果，确定所述当前熔断对象对应的容错动作，并执行所述容错动作。

10、第三方面，提供了一种计算机设备，包括存储器、处理器以及存储在存储器中并可在处理器上运行的计算机程序，处理器执行计算机程序时实现上述数据容错处理方法的步骤。

11、第四方面，提供了一种计算机可读存储介质，计算机可读存储介质存储有计算机程序，计算机程序被处理器执行时实现上述数据容错处理方法的步骤。

12、本申请与现有技术相比存在的有益效果是：

13、本申请在捕获到源数据库预设的操作事件后，进行当前同步处理，若进行当前同步处理的过程中触发异常，则对异常进行分类，通过对同步异常进行分类处理，能够精准匹配对应熔断决策与容错动作，对触发异常的对应对象进行熔断处理，不会影响其他正常数据的同步流程，在保证异常有效处理的同时最大程度保留了数据同步的处理能力，提升了整体同步效率。同时通过分类异常匹配对应容错动作，可以针对性完成异常修复，提升了异常处理的准确性与及时性，避免异常累积导致源端和目标端的数据出现偏差，从而保障了源数据库与目标异构数据库之间数据同步的一致性。

1.一种异构数据库同步的数据容错处理方法，其特征在于，所述数据容错处理方法包括：

2.如权利要求1所述的数据容错处理方法，其特征在于，所述对所述异常进行分类，得到异常分类结果，包括：

3.如权利要求1所述的数据容错处理方法，其特征在于，所述异常分类结果包括可预测错误与不可预测错误，所述熔断处理决策包括与所述可预测错误匹配的可预测错误处理决策，以及与所述不可预测错误匹配的不可预测错误处理决策。

4.如权利要求3所述的数据容错处理方法，其特征在于，所述基于所述熔断处理决策，确定对应的当前熔断对象，包括：

5.如权利要求3所述的数据容错处理方法，其特征在于，所述基于所述熔断处理决策，确定对应的当前熔断对象，还包括：

6.如权利要求1所述的数据容错处理方法，其特征在于，所述执行所述容错动作之后，还包括：

7.一种异构数据库同步的数据容错处理装置，其特征在于，所述数据容错处理装置包括：

8.如权利要求7所述的数据容错处理装置，其特征在于，所述数据容错处理装置还包括：

9.一种计算机设备，其特征在于，所述计算机设备包括处理器、存储器以及存储在所述存储器中并可在所述处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现如权利要求1至6任一项所述的数据容错处理方法。

10.一种计算机可读存储介质，所述计算机可读存储介质存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现如权利要求1至6任一项所述的数据容错处理方法。