一种同步数据清理的方法和系统

摘要

本发明公开了一种同步数据清理的方法和系统，方法包括步骤：中心节点发送同步消息给边缘节点，进行数据同步；中心节点收到边缘节点返回的同步响应消息后，判断是否同步成功，如果成功则判断返回的同步消息对应的数据表类型，如果是扩展表，则进一步判断所述扩展表是否同时是基表，如果所述扩展表同时是基表，则累加该基表对应的成功表个数；如果所述扩展表不是基表，则修改任务驱动表的时间戳，并删除扩展表中需要清理的数据；判断基表对应的扩展表是否全部同步成功，如果全部更新成功，则修改基表对应同步任务驱动表的时间戳，删除基表中需要清理的数据并记录基表同步成功。本发明可以比较好的解决同步数据清理的问题。

主权项

一种同步数据清理的方法，其特征在于，包括步骤：中心节点发送同步消息给边缘节点，进行数据同步；中心节点收到边缘节点返回的同步响应消息后，判断是否同步成功，如果成功则判断返回的同步消息对应的数据表类型，如果是扩展表，则进一步判断所述扩展表是否同时是基表，如果所述扩展表同时是基表，则累加该基表对应的成功表个数；如果所述扩展表不是基表，则修改任务驱动表的时间戳，并删除扩展表中需要清理的数据；判断基表对应的扩展表是否全部同步成功，如果全部更新成功，则修改基表对应同步任务驱动表的时间戳，删除基表中需要清理的数据并记录基表同步成功。