数据核对方法、装置、系统及电子设备.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115080805A(43)申请公布日2022.09.20(21)申请号202210678827.2(22)申请日2022.06.16(71)申请人平安付科技服务有限公司地址518031广东省深圳市福田区福田街道福华路319号兆邦基金融大厦26层2605单元(72)发明人宋鲁生江金莲(74)专利代理机构北京中强智尚知识产权代理有限公司11448专利代理师宋然然(51)Int.Cl.G06F16/903(2019.01)G06F9/54(2006.01)权利要求书2页说明书10页附图5页(54)发明名称数据核对方法、装置、系统及电子设备(57)摘要本申请公开了一种数据核对方法、装置、系统及电子设备，其方法包括：接收并解析核对任务，以获取核对任务的配置信息，核对任务是所述核对管理平台响应于核对任务建立指令，发布至云服务平台的；根据配置信息建立核对任务的核对流应用，核对流应用至少包括拉取组件、至少一个处理组件、汇聚组件；调用拉取组件，根据配置信息从至少一个目标数据源拉取第一数据；调用处理组件，从对应的业务系统拉取第二数据，并根据配置信息，对第一数据与所述第二数据进行核对；调用汇聚组件，对核对获得的结果进行汇总，得到数据核对结果。本申请实现了数据的跨系统核对；且可以支持在线配置，一键部署，实现了数据核查的灵活配置以及变更的快速迭代。CN115080805ACN115080805A权利要求书1/2页1.一种数据核对方法，其特征在于，所述方法是通过数据核对系统实现的，所述核对系统系统包括通信连接的核对管理平台和云服务平台；所述方法应用于所述云服务平台，所述方法包括：接收并解析核对任务，以获取所述核对任务的配置信息，所述核对任务是所述核对管理平台响应于核对任务建立指令，发布至所述云服务平台的；根据所述配置信息建立核对任务的核对流应用，所述核对流应用至少包括拉取组件、至少一个处理组件、汇聚组件；调用所述拉取组件，根据所述配置信息从至少一个目标数据源拉取第一数据；调用所述处理组件，从对应的业务系统拉取第二数据，并根据所述配置信息，对所述第一数据与所述第二数据进行核对；调用所述汇聚组件，对核对获得的结果进行汇总，得到数据核对结果。2.根据权利要求1所述的方法，其特征在于，所述核对系统系统还包括：可视化观测平台，所述可视化观测平台连接所述云服务器平台；所述方法还包括：将所述数据核对结果发送至所述可视化观测平台，以使所述可视化观测平台展示所述数据核对结果；和/或，通过指定通信方式，将所述数据核对结果中的异常结果发送至指定终端。3.根据权利要求1所述的方法，其特征在于，所述根据所述配置信息建立核对任务的核对流应用，包括：提供资源调度接口，响应于所述核对任务对应的接口调用指令，在所述云服务平台，建立所述核对任务的核对流应用。4.根据权利要求1所述的方法，其特征在于，所述配置信息包括至少一个目标数据源和核对规则；所述调用所述拉取组件，根据所述配置信息从至少一个目标数据源拉取第一数据，包括：建立与所述目标数据源的通信连接；基于所述通信连接，从所述目标数据源拉取第一数据；所述对所述第一数据与所述第二数据进行核对，包括：将所述第一数据与所述第二数据，按照所述核对规则进行运算，确认所述第一数据和/或所述第二数据是否存在异。5.根据权利要求4所述的方法，其特征在于，所述处理组件为多个，每个处理组件对应一个业务系统，多个处理组件根据对应业务的依赖关系连接；所述调用所述处理组件，从对应的业务系统拉取第二数据，并根据所述配置信息，对所述第一数据与所述第二数据进行核对，还包括：在前处理组件将第一数据、对应业务的第二数据以及自身的核对结果中的至少一项传递至在后处理组件，以使所述在后处理组件进行数据核对。6.一种数据核对方法，其特征在于，所述方法是通过数据核对系统实现的，所述核对系统系统包括通信连接的核对管理平台和云服务平台；2CN115080805A权利要求书2/2页所述方法应用于所述核对管理平台，所述方法包括：提供配置界面，所述配置界面包括核对任务配置控件，所述核对任务配置控件包括数据源配置子控件和核对规则配置子控件；通过所述配置界面获取核对任务的配置信息；根据所述配置信息生成核对任务，并将所述核对任务发布至所述云服务平台。7.根据权利要求6所述的方法，其特征在于，所述将所述核对任务发布至所述云服务平台，包括：调用所述云服务平台提供的资源调度接口，向所述云服务平台发送核对任务的接口调用指令，以实现所述核对任务的发布。8.一种数据核对装置，其特征在于，所述数据核对装置可实现如权利要求1～5中任一项或权利要求6～7中任一项所述的方法。9.一种数据核对系统，其特征在于，所述数据核对系统包括通信连接的核对管理平台和云服