用于监控数据处理的方法和装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113760628A(43)申请公布日2021.12.07(21)申请号202010504966.4(22)申请日2020.06.05(71)申请人北京沃东天骏信息技术有限公司地址100176北京市大兴区经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东尚科信息技术有限公司(72)发明人李政邹德柱王丹丹戚依楠(74)专利代理机构北京英赛嘉华知识产权代理有限责任公司11204代理人王达佐马晓亚(51)Int.Cl.G06F11/30(2006.01)G06F11/32(2006.01)权利要求书2页说明书9页附图5页(54)发明名称用于监控数据处理的方法和装置(57)摘要本公开的实施例公开了用于监控数据处理的方法和装置。该方法的一具体实施方式包括：获取预先配置的监控点信息，其中，监控点信息包括检查时间、联系方式、业务系统接口；响应于接收到状态同步消息，在数据同步状态表中记录数据的最新生产时间；响应于检测到当前时刻到达检查时间，检查最新生产时间是否与当前时间一致；若不一致，则根据联系方式发送报警信息，并通过业务系统接口通知业务系统进行故障处理。该实施方式从业务角度出发对数据的及时性进行监控报警和自动处理，当发生特定数据无法及时同步的情况时，向各业务系统负责人报警，同时通知相关的业务系统，使业务系统能够自动执行自定义的故障应对预案，将业务损失降到最低限度。CN113760628ACN113760628A权利要求书1/2页1.一种用于监控数据处理的方法，包括：获取预先配置的监控点信息，其中，所述监控点信息包括检查时间、联系方式、业务系统接口；响应于接收到状态同步消息，在数据同步状态表中记录数据的最新生产时间；响应于检测到当前时刻到达所述检查时间，检查所述最新生产时间是否与当前时间一致；若不一致，则根据所述联系方式发送报警信息，并通过所述业务系统接口通知业务系统进行故障处理。2.根据权利要求1所述的方法，其中，所述监控点信息还包括：重新检查时间间隔；以及所述方法还包括：若不一致，按照所述重新检查时间间隔，重新检查所述数据同步状态表中的最新生产时间是否与当前时间一致。3.根据权利要求2所述的方法，所述方法还包括：若重新检查结果为一致，则根据所述联系方式发送已同步信息，并通过所述业务系统接口通知业务系统进行恢复处理。4.根据权利要求1所述的方法，所述监控点信息还包括以下至少一项：数据重要等级、同步失败影响范围、同步失败处理预案；以及所述根据所述联系方式发送报警信息包括：根据以下至少一项生成报警信息：数据重要等级、同步失败影响范围、同步失败处理预案；根据所述联系方式发送生成的报警信息。5.根据权利要求1-4中任一项所述的方法，其中，所述检查时间为周期性时间。6.根据权利要求1-4中任一项所述的方法，其中，所述故障处理以下至少一项：数据展示降级、功能降级、发布数据缺失公告。7.一种用于监控数据处理的装置，包括：获取单元，被配置成获取预先配置的监控点信息，其中，所述监控点信息包括检查时间、联系方式、业务系统接口；记录单元，被配置成响应于接收到状态同步消息，在数据同步状态表中记录数据的最新生产时间；检查单元，被配置成响应于检测到当前时刻到达所述检查时间，检查所述最新生产时间是否与当前时间一致；通知单元，被配置成若不一致，则根据所述联系方式发送报警信息，并通过所述业务系统接口通知业务系统进行故障处理。8.根据权利要求7所述的装置，其中，所述监控点信息还包括：重新检查时间间隔；以及所述检查单元进一步被配置成：若不一致，按照所述重新检查时间间隔，重新检查所述数据同步状态表中的最新生产时间是否与当前时间一致。9.一种用于监控数据处理的电子设备，包括：一个或多个处理器；2CN113760628A权利要求书2/2页存储装置，其上存储有一个或多个程序，当所述一个或多个程序被所述一个或多个处理器执行，使得所述一个或多个处理器实现如权利要求1-6中任一所述的方法。10.一种计算机可读介质，其上存储有计算机程序，其中，所述程序被处理器执行时实现如权利要求1-6中任一所述的方法。3CN113760628A说明书1/9页用于监控数据处理的方法和装置技术领域[0001]本公开的实施例涉及计算机技术领域，具体涉及用于监控数据处理的方法和装置。背景技术[0002]对于数据决策类、数据看板类或者依赖底层大数据的执行类应用，其依赖的业务数据全部由后端大数据平台进行离线计算后同步给前台应用，所以数据能否按照时间约定及时同步对这些应用至关重要。[0003]当前对业务数据及时性的监控主要由后端的大数据计算平台处理，在大数据计算平台中对特定数据计算任务脚本的执行时长进行监控，当时长超过限定时间后，