(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210753380.0 (22)申请日 2022.06.29 (71)申请人 中国联合网络通信集团有限公司 地址 100033 北京市西城区金融大街21号 (72)发明人 何平　任龙飞　原林　李秀林　 张涛　赵莹　邢长虹　 (74)专利代理 机构 北京同立钧成知识产权代理 有限公司 1 1205 专利代理师 李亚丽　刘芳 (51)Int.Cl. G06F 16/25(2019.01) G06F 16/21(2019.01) G06F 9/54(2006.01) (54)发明名称 数据稽核方法、 装置、 设备及存 储介质 (57)摘要 本申请提供了一种数据稽核方法、 装置、 设 备及存储介质， 涉及数据处理技术领域。 该方法 包括： 获取用户针对同一目标业务在目标页面上 输入的数据源的配置信息和稽核流程的配置信 息； 所述数据源的配置信息包括数据源的类型信 息； 基于所述稽核流程的配置信息， 按照不同处 理模式对不同类型信息的数据源的数据进行处 理， 得到与所述目标业务对应的稽核结果。 上述 方式能够实现稽核结果可随时变化的同时， 提高 了数据稽核的效率。 权利要求书2页 说明书9页 附图5页 CN 115062080 A 2022.09.16 CN 115062080 A 1.一种数据稽核方法， 其特 征在于， 包括： 获取用户针对同一目标业务在目标页面上输入的数据源的配置信息和稽核流程的配 置信息； 所述数据源的配置信息包括数据源的类型信息； 基于所述稽核流程的配置信 息， 按照不同处理模式对不同类型信 息的数据源的数据进 行处理， 得到与所述目标业 务对应的稽核结果。 2.根据权利要求1所述的数据稽核方法， 其特征在于， 所述稽核流程的配置信 息包括字 段映射关系和比对规则； 所述基于所述稽核流程的配置信息， 按照不同处理模式对不同类 型信息的数据源的数据进行处 理， 得到与所述目标业 务对应的稽核结果， 包括： 生成第一Fl ink作业； 根据所述数据源的类型信息确定所述第一Flink作业的处理模式， 并基于所述字段映 射关系， 按照所述处 理模式执 行所述第一Fl ink作业， 获得第一原 始数据和第二原 始数据； 基于所述比对规则、 所述第一原始数据和所述第二原始数据， 确定与所述目标业务对 应的稽核结果。 3.根据权利要求2所述的数据稽核方法， 其特征在于， 所述根据 所述数据源的类型信 息 确定所述第一Fl ink作业的处 理模式， 包括： 当所述数据源的类型信息为消息队列类型时， 将流处理模式确定为所述第一Flink作 业的处理模式； 当所述数据源的类型信息为系统类型时， 将批处理模式确定为所述第一Flink作业的 处理模式。 4.根据权利要求2所述的数据稽核方法， 其特征在于， 所述基于所述字段映射关系， 按 照所述处 理模式执 行所述第一Fl ink作业， 获得第一原 始数据和第二原 始数据， 包括： 在所述处理模式下， 按照所述字段映射关系， 从所述数据源中获得第一原始数据和第 二原始数据； 其中， 所述第一原 始数据和所述第二原 始数据之间存在所述字段映射关系。 5.根据权利要求2所述的数据稽核方法， 其特征在于， 所述基于所述比对规则、 所述第 一原始数据和所述第二原 始数据， 确定与所述目标业 务对应的稽核结果， 包括： 对所述第一原始数据和所述第 二原始数据分别进行清洗处理， 得到第 一待稽核数据和 第二待稽核数据； 基于所述比对规则， 将所述第一待稽核数据和所述第二待稽核数据进行比对， 得到与 所述目标业 务对应的稽核结果。 6.根据权利要求2所述的数据稽核方法， 其特 征在于， 所述 生成第一Fl ink作业， 包括： 读取所述数据源的配置信息和所述稽核流 程的配置信息； 确定配置集合满足预设的配置条件时， 根据所述配置集合生成第一Flink作业； 其中， 所述配置集 合由所述数据源的配置信息和所述稽核流 程的配置信息构成。 7.根据权利要求2所述的数据稽核方法， 其特征在于， 所述稽核流程的配置信 息还包括 目标数据源的配置信息， 所述 目标数据源的配置信息包括 目标数据源的类型信息， 在所述 基于所述比对规则、 所述第一原始数据和所述第二原始数据， 确定与所述 目标业务对应的 稽核结果之后， 还 包括： 当所述目标数据源的类型信 息为写入类型时， 将所述稽核结果以数据的形式写入到所 述目标数据源中；权　利　要　求　书 1/2 页 2 CN 115062080 A 2当所述目标数据源的类型信 息为转换类型时， 将所述稽核结果以文件的形式存储到所 述目标数据源中。 8.根据权利要求7所述的数据稽核方法， 其特征在于， 所述稽核流程的配置信 息还包括 稽核报表配置信息， 所述 目标数据源的配置信息还包括 目标数据源的名称， 在将所述稽核 结果写入到所述目标 数据源中之后， 还 包括： 读取所述稽核报表配置信息， 生成第二Fl ink作业； 在执行所述第二Flink作业的过程中， 读取所述稽核结果， 并将所述稽核结果注册到 Flink表中； 根据所述稽核报表配置信息对注册到Flink表中的所述稽核结果进行数据处理， 得到 处理后的稽核结果； 基于所述目标数据源的名称和预设的索引库名称， 将所述处理后的稽核结果分配到目 标搜索引擎中， 以使所述目标搜索引擎将所述稽核结果以报表的形式展示。 9.一种数据稽核装置， 其特 征在于， 包括： 获取模块， 用于获取用户针对同一目标业务在目标页面上输入的数据源的配置信 息和 稽核流程的配置信息； 所述数据源的配置信息包括数据源的类型信息； 处理模块， 用于基于稽核流程的配置信息， 按照不同处理模式对不同类型信息的数据 源的数据进行处 理， 得到与所述目标业 务对应的稽核结果。 10.一种数据稽核设备， 其特 征在于， 包括： 至少一个处 理器和存 储器； 所述存储器存储计算机执 行指令； 所述至少一个处理器执行所述存储器存储的计算机执行指令， 使得所述至少一个处理 器执行如权利要求1至8任一项所述的数据稽核方法。 11.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质中存储有计算机 执行指令， 所述计算机执行指 令被处理器执行时用于实现如权利要求 1至8任一项 所述的数 据稽核方法。权　利　要　求　书 2/2 页 3 CN 115062080 A 3