一种运行记录清理方法、系统、设备及可读存储介质与流程

本发明涉及数据同步，特别涉及一种运行记录清理方法、系统、设备及可读存储介质。

背景技术：

1、在云算力平台的中心—边缘架构中，边缘机房（region）负责裸金属实例的运行态管理，持续产生运行记录数据（bmi_run_record表）。这些运行记录通过异步数据同步通道（datasyncroom）向中心侧推送，供中心侧进行汇总查询、审计追溯和计费核算。随着实例的持续运行和停止，region本地的运行记录表会不断膨胀，需要定期清理以回收存储空间。通用资源清理方案依赖于被清理对象自身的本地时间属性（如文件创建时间是否在用户预设的时间段内）。如果仅依赖这类本地属性执行清理，可能误删中心侧尚未同步的数据。

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、可见，本发明通过边缘端在裸金属实例运行过程中生成运行记录，并将运行记录写入运行记录表，通过异步数据同步通道将运行记录推送至中心端；其中，运行记录包括添加时间、结束时间和数据变更时间；中心端接收并持久化边缘端推送的运行记录，并在完成持久化后，更新与运行记录表对应的消费确认水位；其中，消费确认水位用于表征中心端对运行记录表的同步消费确认进度；边缘端响应于针对运行记录表中目标数据的清理任务，针对每个目标数据，获取与目标数据所属运行记录表对应的目标消费确认水位；边缘端基于目标数据的结束时间、添加时间、数据变更时间和目标消费确认水位确定候选清理记录；其中，候选清理记录的添加时间早于基于当前时间和预设保留周期确定的保留时间，并且候选清理记录的数据变更时间早于目标消费确认水位；边缘端基于候选清理记录对运行记录进行清理。

38、本发明的有益效果在于：和当前仅依据本地时间属性清理运行记录相比，本发明可以利用中心端同步消费确认水位（即时间）、添加时间和结束时间约束边缘端的清理范围，使得未被中心端确认消费的数据不被清理，以及只有满足设定结束时间条件和添加时间条件的数据才会被清理，从而提高运行记录清理的准确性。

39、此外，本发明还提供了一种运行记录清理系统、设备及可读存储介质，同样具有上述有益效果。