(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210979808.3 (22)申请日 2022.08.16 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 张康洁　 (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 吕俊刚　安然 (51)Int.Cl. G06F 9/48(2006.01) G06F 16/906(2019.01) G06Q 40/02(2012.01) (54)发明名称 批量处理实现方法及装置 (57)摘要 本发明公开了一种批量处理实现方法及装 置， 应用于 大数据技术领域， 其中该方法包括： 识 别批量处理需求中的数据来源； 根据所述的数据 来源， 确定批量公共机制类型； 根据批量处理需 求中的数据量确定所述数据量需要批量处理的 作业时间， 将数据量需要批量处理的作业时间的 窗口与整体批量处理匹配， 所述整体批量为批量 处理需求中的数据量与先前已存在的批量数据 的总和； 根据匹配后的数据量需要批量处理的作 业时间， 启动批量处理， 生成批量公共机制类型 对应的批量处理模板。 本发明能够在保证批量架 构稳定性的基础上， 实现批量开发的智 能设计， 同时有助于系统批量机制的标准 化建设。 权利要求书3页 说明书6页 附图4页 CN 115309529 A 2022.11.08 CN 115309529 A 1.一种批量处 理实现方法， 其特 征在于， 包括： 识别批量处 理需求中的数据来源； 根据所述的数据来源， 确定 批量公共机制类型； 根据批量处理需求中的数据量确定所述数据量需要批量处理的作业 时间， 将数据量需 要批量处理的作业时间的窗口与整体批量处理匹配， 所述整体批量为批量处理需求中的数 据量与先 前已存在的批量数据的总和； 根据匹配后的数据量需要批量处理的作业时间， 启动批量处理， 生成批量公共机制类 型对应的批量处 理模板。 2.如权利要求1所述的方法， 其特征在于， 根据所述的数据来源， 确定批量公共机制类 型， 包括： 根据数据来源， 确定 批量处理的数据的数据分类； 根据所述数据分类， 确定 批量公共机制类型。 3.如权利要求2所述的方法， 其特征在于， 根据数据来源， 确定批量处理的数据的数据 分类， 包括： 当数据来源为系统内部时， 确定数据分类为实体类数据， 且包括账户主体、 客户信 息和 票据的其中一种或任意组合； 当数据来源为系统内部时， 确定数据分类为交易明细类数据， 且包括联机产生的签约 信息、 交易 流水中的其中一种或任意组合； 当数据来源为系统外部时， 确定数据分类为实体类数据， 且包括外围相关账户、 客户信 息的其中一种或任意组合； 当数据来源为系统外部时， 确定数据分类为交易明细类数据， 且包括外围系统入账明 细、 交易流水中的其中一种或任意组合。 4.如权利要求2所述的方法， 其特征在于， 根据 所述数据分类， 确定批量公共机制类型， 包括： 在对批量联机的交易明细类数据进行批量处理时， 确定批量公共机制类型为联机批量 公共机制； 在对夜间模式下的交易明细类数据进行批量处理时， 确定批量公共机制类型为夜间批 量公共机制； 在对日间联机模式下的交易明细类数据进行批量处理时， 确定批量公共机制类型为日 间批量公共机制； 在对业务 时效性不高的实体类数据进行批量处理时， 确定批量公共机制类型为P2筛选 P1批量公共机制； 在对无数据修改的实体类数据进行批量处理时， 确定批量公共机制类型为数据采集公 共机制。 5.如权利要求1所述的方法， 其特征在于， 将数据量需要批量处理 的作业时间的窗口与 整体批量处 理匹配， 包括： 将数据量需要批量处理中的A作业完成之后， 至B作业开始之前的时间段， 确定为匹配 后的数据量需要批量处 理的作业时间。 6.如权利要求1所述的方法， 其特征在于， 在生成批量公共机制类型对应的批量处理模权　利　要　求　书 1/3 页 2 CN 115309529 A 2板之后， 还 包括： 将批量处理模板存放在模板库中， 模板库中的批量处理模板用于自动执行实现批量处 理。 7.一种批量处 理实现装置， 其特 征在于， 包括： 识别模块， 用于识别批量处 理需求中的数据来源； 公共机制分类模块， 用于根据所述的数据来源， 确定 批量公共机制类型； 作业时间窗口确定模块， 用于根据批量处理需求中的数据量确定所述数据量需要批量 处理的作业时间， 将数据量需要批量处理的作业时间的窗口与整体批量处理匹配， 所述整 体批量为批量处 理需求中的数据量与先 前已存在的批量数据的总和； 构建模板模块， 用于根据匹配后的数据量需要批量处理的作业时间， 启动批量处理， 生 成批量公共机制类型对应的批量处 理模板。 8.如权利要求7 所述的装置， 其特 征在于， 公共机制分类模块， 具体用于： 根据数据来源， 确定 批量处理的数据的数据分类； 根据所述数据分类， 确定 批量公共机制类型。 9.如权利要求8所述的装置， 其特 征在于， 公共机制分类模块， 具体用于： 当数据来源为系统内部时， 确定数据分类为实体类数据， 且包括账户主体、 客户信 息和 票据的其中一种或任意组合； 当数据来源为系统内部时， 确定数据分类为交易明细类数据， 且包括联机产生的签约 信息、 交易 流水中的其中一种或任意组合； 当数据来源为系统外部时， 确定数据分类为实体类数据， 且包括外围相关账户、 客户信 息的其中一种或任意组合； 当数据来源为系统外部时， 确定数据分类为交易明细类数据， 且包括外围系统入账明 细、 交易流水中的其中一种或任意组合。 10.如权利要求8所述的装置， 其特 征在于， 公共机制分类模块， 具体用于： 在对批量联机的交易明细类数据进行批量处理时， 确定批量公共机制类型为联机批量 公共机制； 在对夜间模式下的交易明细类数据进行批量处理时， 确定批量公共机制类型为夜间批 量公共机制； 在对日间联机模式下的交易明细类数据进行批量处理时， 确定批量公共机制类型为日 间批量公共机制； 在对业务 时效性不高的实体类数据进行批量处理时， 确定批量公共机制类型为P2筛选 P1批量公共机制； 在对无数据修改的实体类数据进行批量处理时， 确定批量公共机制类型为数据采集公 共机制。 11.如权利要求7 所述的装置， 其特 征在于， 作业时间窗口确定模块， 具体用于： 将数据量需要批量处理中的A作业完成之后， 至B作业开始之前的时间段， 确定为匹配 后的数据量需要批量处 理的作业时间。 12.如权利要求7 所述的装置， 其特 征在于， 构建模板模块， 还用于： 将批量处理模板存放在模板库中， 模板库中的批量处理模板用于自动执行实现批量处权　利　要　求　书 2/3 页 3 CN 115309529 A 3