一种边缘节点数据恢复方法、系统、设备及可读存储介质与流程

本发明涉及数据同步，特别涉及一种边缘节点数据恢复方法、系统、设备及可读存储介质。

背景技术：

1、现有云边同步框架在进行中心到边缘同步时，通常只拉取中心配置类数据。其设计目标是让边缘节点获得中心维护的配置、策略和基础资料，而不是把边缘节点曾经上送到中心的业务流水再作为普通配置数据下发回来。因此，当边缘节点本地数据库发生丢失时，仅依靠普通同步框架重置拉取水位，通常只能恢复中心配置类数据，无法恢复该边缘节点自身产生的业务数据。或者进行普通全量同步，使得效率较低

2、可见，如何提高数据恢复的准确性的同时，保证数据恢复的效率，是领域技术人员急需解决的技术问题。

技术实现思路

1、有鉴于此，本发明的目的在于提供一种边缘节点数据恢复方法、系统、设备及可读存储介质，解决现有技术中普通中心到边缘同步不能恢复边缘节点自身产生并已同步至中心节点的业务数据的技术问题。

2、为解决上述技术问题，本发明提供了一种边缘节点数据恢复方法，包括：

3、当恢复开关处于开启状态，且通信组件初始化完成时，边缘节点读取支持恢复的待恢复业务表；其中，所述待恢复业务表为基于设定恢复条件确定的需要执行数据恢复的边缘业务表；

4、所述边缘节点基于所述待恢复业务表和边缘节点标识生成恢复请求，并将所述恢复请求发送至中心节点；

5、所述中心节点根据所述恢复请求中的所述待恢复业务表和所述边缘节点标识，从中心节点已保存的边缘业务数据中确定属于所述边缘节点的可恢复业务数据，并将所述可恢复业务数据返回至所述边缘节点；

6、所述边缘节点分页获取所述可恢复业务数据，并在同步抑制状态下将所述可恢复业务数据写入所述待恢复业务表；

7、当所述待恢复业务表恢复成功时，所述边缘节点基于本次恢复对应的恢复时间参数修正所述待恢复业务表对应的边缘到中心方向同步水位。

8、可选的，在所述边缘节点基于所述待恢复业务表和边缘节点标识生成恢复请求之前，还包括：

9、所述边缘节点判断所述待恢复业务表中的数据是否为空；

10、当所述待恢复业务表中的数据不为空时，所述边缘节点终止本次数据恢复，并记录恢复终止原因；

11、当所述待恢复业务表中的数据为空时，所述边缘节点确定恢复校验通过，并基于所述待恢复业务表和所述边缘节点标识生成所述恢复请求。

12、可选的，所述中心节点根据所述恢复请求中的所述待恢复业务表和所述边缘节点标识，从中心节点已保存的边缘业务数据中确定属于所述边缘节点的可恢复业务数据，包括：

13、所述中心节点将所述边缘节点标识与所述中心节点已保存的边缘业务数据对应的数据归属信息进行匹配，得到归属于所述边缘节点的候选业务数据；

14、所述中心节点根据所述待恢复业务表，从所述候选业务数据中确定存储于所述待恢复业务表的可恢复业务数据；其中，所述边缘节点标识包括节点编码、区域编码、许可证标识、算力资源归属标识、租户标识或设备组标识中的至少一种。

15、可选的，所述中心节点根据所述待恢复业务表，从所述候选业务数据中确定存储于所述待恢复业务表的可恢复业务数据，包括：

16、所述中心节点根据所述待恢复业务表对应的恢复过滤条件，从所述候选业务数据中排除测试数据、临时数据、作废数据、已归档且无需所述边缘节点保留的数据以及处于逻辑删除状态的数据，得到所述可恢复业务数据；

17、当所述待恢复业务表为算力使用记录表时，所述中心节点根据算力使用记录对应的业务状态，保留仍处于使用状态的算力使用记录，并排除已结束使用的算力使用记录，得到所述可恢复业务数据；

18、相应的，所述边缘节点分页获取所述可恢复业务数据，并在同步抑制状态下将所述可恢复业务数据写入所述待恢复业务表，包括：

19、判断所述可恢复业务数据是否处于逻辑删除状态；

20、当存在逻辑删除状态时，从所述可恢复业务数据中删除处于逻辑删除状态的数据，得到目标可恢复业务数据，并在所述同步抑制状态下将所述目标可恢复业务数据写入所述待恢复业务表。

21、可选的，所述边缘节点分页获取所述可恢复业务数据，并在同步抑制状态下将所述可恢复业务数据写入所述待恢复业务表，包括：

22、所述边缘节点在开始写入所述可恢复业务数据之前设置同步抑制标记，并在所述可恢复业务数据写入期间保持所述同步抑制标记有效；其中，所述同步抑制标记为禁止边缘节点向中心节点同步的标记；

23、当写入所述可恢复业务数据产生数据库变更时，所述边缘节点基于所述同步抑制标记，将所述数据库变更确定为数据恢复产生的数据库变更，并跳过针对所述数据库变更执行的边缘到中心方向同步处理。

24、可选的，当所述待恢复业务表为多张存在关联关系的待恢复业务表时，还包括：

25、所述边缘节点在将所述可恢复业务数据写入所述待恢复业务表之前开启恢复事务，并将各所述待恢复业务表对应的可恢复业务数据写入操作纳入所述恢复事务；

26、当各所述待恢复业务表均恢复成功时，所述边缘节点提交所述恢复事务，并基于本次恢复对应的恢复时间参数修正各所述待恢复业务表对应的边缘到中心方向同步水位；

27、当任一所述待恢复业务表恢复失败或者所述中心节点返回异常或者所述可恢复业务数据写入失败时，所述边缘节点回滚所述恢复事务，撤销本次恢复过程中已经写入各所述待恢复业务表的可恢复业务数据。

28、可选的，所述边缘节点分页获取所述可恢复业务数据，并在同步抑制状态下将所述可恢复业务数据写入所述待恢复业务表，包括：

29、所述边缘节点根据数据量、网络带宽和数据库写入能力确定分页大小；

30、所述边缘节点基于所述分页大小，对所述可恢复业务数据进行分页获取，并在同步抑制状态下将所述可恢复业务数据写入所述待恢复业务表。

31、本发明还提供了一种边缘节点数据恢复系统，包括：

32、边缘节点，用于当恢复开关处于开启状态，且通信组件初始化完成时，读取支持恢复的待恢复业务表；其中，所述待恢复业务表为基于设定恢复条件确定的需要执行数据恢复的边缘业务表；基于所述待恢复业务表和边缘节点标识生成恢复请求，并将所述恢复请求发送至所述中心节点；以及分页获取可恢复业务数据，并在同步抑制状态下将所述可恢复业务数据写入所述待恢复业务表；当所述待恢复业务表恢复成功时，所述边缘节点基于本次恢复对应的恢复时间参数修正所述待恢复业务表对应的边缘到中心方向同步水位；

33、中心节点，用于根据所述恢复请求中的所述待恢复业务表和所述边缘节点标识，从中心节点已保存的边缘业务数据中确定属于所述边缘节点的可恢复业务数据，并将所述可恢复业务数据返回至所述边缘节点。

34、本发明还提供了一种边缘节点数据恢复设备，包括存储器和处理器。存储器用于存储计算机程序，处理器用于执行计算机程序时实现上述边缘节点数据恢复方法。

35、本发明还提供了一种可读存储介质（即计算机可读存储介质），可读存储介质上存储有计算机程序，计算机程序被处理器执行时实现上述边缘节点数据恢复方法。

36、可见，本发明当恢复开关处于开启状态，且通信组件初始化完成时，边缘节点读取支持恢复的待恢复业务表；其中，待恢复业务表为基于设定恢复条件确定的需要执行数据恢复的边缘业务表；边缘节点基于待恢复业务表和边缘节点标识生成恢复请求，并将恢复请求发送至中心节点；中心节点根据恢复请求中的待恢复业务表和边缘节点标识，从中心节点已保存的边缘业务数据中确定属于边缘节点的可恢复业务数据，并将可恢复业务数据返回至边缘节点；边缘节点分页获取可恢复业务数据，并在同步抑制状态下将可恢复业务数据写入待恢复业务表；当待恢复业务表恢复成功时，边缘节点基于本次恢复对应的恢复时间参数修正待恢复业务表对应的边缘到中心方向同步水位。和当前仅能同步恢复中心配置数据相比，本发明通过边缘节点标识限定数据归属，并将恢复写入与普通边缘到中心方向同步处理相隔离，使得中心节点保存的边缘自产业务数据能够恢复至原边缘节点，降低跨节点误恢复、重复业务流水和同步回环的风险，从而提高边缘节点数据恢复的准确性和效率。

37、此外，本发明还提供了一种边缘节点数据恢复系统、设备及可读存储介质，同样具有上述有益效果。