一种同步数据异常处理方法及系统
摘要:
本发明实施例提供一种同步数据异常处理方法,包括以下步骤:步骤一:将从源端oracle的数据队列读取的数据同步推送至Kafka集群;步骤二:当MongoDB出现异常时,将所有异常数据的主键保存至第一MongoDB集群具有日期字段的临时表中;步骤三:对所述具有日期字段的临时表的异常数据进行聚合统计,得到异常数据总量;步骤四:对所述第一MongoDB集群的所有异常数据进行修复;本发明实施例便于记录所有异常数据,用于后续分析且提高了处理异常数据的效率。
0/0