logo好方法网

一种数据库对账方法、系统、服务器和存储介质


技术摘要:
本发明提供了一种数据库对账方法,包括:对账系统获取数仓中的业务数据;判断所述业务数据是否发生变更;若发生变更,则获取所述业务数据中的变更信息;基于所述变更信息向数据组织系统发送数据补偿指令,以使所述数据组织系统基于所述数据补偿指令获取所述数仓中的上  全部
背景技术:
分布式系统是由一组通过网络进行通信、为了完成共同的任务而协调工作的计算 机节点组成的系统。分布式系统能够用普通的机器完成单个计算机无法完成的计算、存储 任务,实现对更多的机器的利用,处理更多的数据。 现有技术的对账系统使用多个服务器分别与上报中心对接,多点接生成对账数 据,造成重复工作量,同时因为涉及端点太多,导致系统维护困难。
技术实现要素:
本发明提供了一种数据库对账方法、系统、服务器和存储介质,通过数仓将业务数 据和上报数据库合并对比,通过单个上报中心实现跨业务系统数据上报,简化了系统复杂 度。 第一方面,本发明提供了一种数据库对账方法,包括: 对账系统获取数仓中的业务数据; 判断所述业务数据是否发生变更; 若发生变更,则获取所述业务数据中的变更信息; 基于所述变更信息向数据组织系统发送数据补偿指令,以使所述数据组织系统基 于所述数据补偿指令获取所述数仓中的上报数据并进行更新。 进一步地,所述判断所述业务数据是否发生变更,包括: 判断所述业务数据中是否有预设的更新标识; 若有所述预设的更新标识,则所述业务数据发生变更。 进一步地,所述获取所述业务数据中的变更信息,包括: 基于所述更新标识,读取所述业务数据中的所述变更信息对应的关键字; 判断上报数据对应位置是否有对应的所述关键字; 若没有,则获取所述更新标识对应的变更信息。 进一步地,所述对账系统采用Hive工具获取所述数仓中的所述业务数据。 进一步地,所述更新标识为修改时间字段。 进一步地,在所述对账系统获取数仓中的业务数据之前,还包括: 每隔预设时间间隔,判断是否接收到所述数仓发送的业务数据更新信息; 若接收到,则获取所述数仓中的业务数据。 第二方面,本发明提供一种数据库对账系统,包括: 第一获取模块,用于获取数仓中的业务数据; 对账模块,用于判断所述业务数据是否发生变更; 3 CN 111581225 A 说 明 书 2/7 页 第二获取模块,用于若发生变更,则获取所述业务数据中的变更信息; 指令发送模块,用于基于所述变更信息向数据组织系统发送数据补偿指令,以使 所述数据组织系统基于所述数据补偿指令获取所述数仓中的上报数据并进行更新。 进一步地,所述对账模块包括: 判断单元,用于判断所述业务数据中是否有预设的更新标识; 若有所述预设的更新标识,则所述业务数据发生变更。 第三方面,本发明提供一种服务器,包括存储器、处理器及存储在存储器上并可在 处理器上运行的程序,所述处理器执行所述程序时实现如上述任一所述的数据库对账方 法。 第四方面,本发明提供一种终端可读存储介质,其上存储有程序,所述程序被处理 器执行时能够实现如上述任一所述的数据库对账方法。 本发明通过数仓将业务数据和上报数据库合并对比,通过单个上报中心实现跨业 务系统数据上报,简化了系统复杂度。 附图说明 图1为实施例一的数据库对账方法流程图。 图2为实施例二的数据库对账方法流程图。 图3为实施例三的数据库对账系统模块图。 图4为实施例三替代实施例的数据库对账系统模块图。 图5为实施例四服务器模块图。
分享到:
收藏