(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211122573.2 (22)申请日 2022.09.15 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 徐世泽　陈晓旋　彭雨岚　陈晓霞　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 韩丽波 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/25(2019.01) G06F 16/242(2019.01) (54)发明名称 一种文本 批处理方法及相关装置 (57)摘要 本申请公开一种文本批处理方法及相关装 置， 可应用于金融领域， 在对文本进行分库分表 的批处理时， 可以接收上游系统下传的多个待写 入文本， 调度目标任务， 执行将待写入文本写入 分库分表的任务。 在执行将待写入文本写入分库 分表的任务时， 根据多个待写入文本的属性信息 和配置文件， 确定多个待写入文本对应的分库分 表规则。 基于多个待写入文本对应的分库分表规 则进行步骤拆分， 得到多个步骤的步骤链， 每个 步骤用于将一个待写入文本写入一个数据库中 的一个数据表， 通过步骤链将多个待写入文本中 每个待写入文本写入对应的目标数据库中的目 标数据表。 由此减少资源消耗和重复配置， 降低 维护成本， 无需考虑多个批处理系统间的调度及 结果一致性等复杂问题。 权利要求书2页 说明书9页 附图5页 CN 115455003 A 2022.12.09 CN 115455003 A 1.一种文本 批处理方法， 其特 征在于， 所述方法包括： 接收上游系统下传的多个待 写入文本； 调度目标任务， 执 行将所述待 写入文本写入分库分表的任务； 在执行将所述待写入文本写入分库分表的任务 时， 根据所述多个待写入文本的属性信 息和配置文件， 确定所述多个待 写入文本对应的分库分表规则； 基于所述多个待写入文本对应的分库分表规则进行步骤拆分， 得到步骤链， 所述步骤 链中包括多个步骤， 每 个步骤用于将一个待 写入文本写入一个数据库中的一个数据表； 通过所述步骤链将所述多个待写入文本中每个待写入文本写入对应的目标数据库中 的目标数据表。 2.根据权利要求1所述的方法， 其特征在于， 所述通过所述步骤链将所述多个待写入文 本中每个待写入文本写入 对应的目标 数据库中的目标 数据表， 包括： 基于所述步骤链中每个步骤对应的初始结构化查询语言， 提取所述目标数据库的逻辑 库名和所述目标 数据表的逻辑表名； 基于所述逻辑库名生成物理库名以及基于所述逻辑表名生成物理表名； 基于所述物理库名和所述物理表名生成物理结构化 查询语言； 根据所述物理结构化查询语言， 通过所述步骤链将所述多个待写入文本 中每个待写入 文本写入 对应的目标 数据库中的目标 数据表。 3.根据权利要求1所述的方法， 其特征在于， 所述通过所述步骤链将所述多个待写入文 本中每个待写入文本写入 对应的目标 数据库中的目标 数据表， 包括： 若通过所述步骤链中前k个步骤将对应的待写入文本写入对应的目标数据库中的目标 数据表执行成功， 且通过第k+1个步骤将对应的待写入文本写入对应的目标数据库中的目 标数据表执行失败， 则再次调 度所述目标任务， 执行通过第k +1个步骤将对应的待写入文本 写入对应的目标 数据库中的目标 数据表。 4.根据权利要求1 ‑3任一项所述的方法， 其特征在于， 在根据 所述多个待写入文本的属 性信息和配置文件， 确定所述多个待 写入文本对应的分库分表规则之前， 所述方法还 包括： 加载配置校验器及所述配置文件； 利用所述配置校验器对所述配置文件进行 校验。 5.根据权利要求1 ‑3任一项所述的方法， 其特 征在于， 所述方法还 包括： 获取调度所述目标任务时传递的参数； 检验所述 参数是否存在于所述配置文件的配置项中； 若所述参数存在于所述配置文件的配置项中， 执行将所述待写入文本写入分库分表的 任务。 6.一种文本 批处理装置， 其特 征在于， 所述装置包括： 接收单元， 用于接收上游系统下传的多个待 写入文本； 调度单元， 用于调度目标任务， 执 行将所述待 写入文本写入分库分表的任务； 确定单元， 用于在执行将所述待写入文本写入分库分表的任务时， 根据所述多个待写 入文本的属性信息和配置文件， 确定所述多个待 写入文本对应的分库分表规则； 拆分单元， 用于基于所述多个待写入文本对应的分库分表规则进行步骤拆分， 得到步 骤链， 所述步骤链中包括多个步骤， 每个步骤用于将一个待写入文本写入一个数据库中的权　利　要　求　书 1/2 页 2 CN 115455003 A 2一个数据表； 写入单元， 用于通过所述步骤链将所述多个待写入文本中每个待写入文本写入对应的 目标数据库中的目标 数据表。 7.根据权利要求6所述的装置， 其特 征在于， 所述写入单 元， 具体用于： 基于所述步骤链中每个步骤对应的初始结构化查询语言， 提取所述目标数据库的逻辑 库名和所述目标 数据表的逻辑表名； 基于所述逻辑库名生成物理库名以及基于所述逻辑表名生成物理表名； 基于所述物理库名和所述物理表名生成物理结构化 查询语言； 根据所述物理结构化查询语言， 通过所述步骤链将所述多个待写入文本 中每个待写入 文本写入 对应的目标 数据库中的目标 数据表。 8.根据权利要求7 所述的装置， 其特 征在于， 所述写入单 元， 具体用于： 若通过所述步骤链中前k个步骤将对应的待写入文本写入对应的目标数据库中的目标 数据表执行成功， 且通过第k+1个步骤将对应的待写入文本写入对应的目标数据库中的目 标数据表执行失败， 则再次调 度所述目标任务， 执行通过第k +1个步骤将对应的待写入文本 写入对应的目标 数据库中的目标 数据表。 9.根据权利要求6 ‑8任一项所述的装置， 其特 征在于， 所述装置还 包括： 加载单元， 用于加载配置校验器及所述配置文件； 校验单元， 用于利用所述配置校验器对所述配置文件进行 校验。 10.根据权利要求6 ‑8任一项所述的装置， 其特 征在于， 所述装置还 包括： 获取单元， 用于获取调度所述目标任务时传递的参数； 校验单元， 用于检验所述 参数是否存在于所述配置文件的配置项中； 所述调度单元， 还用于若所述参数存在于所述配置文件的配置项中， 执行将所述待写 入文本写入分库分表的任务。权　利　要　求　书 2/2 页 3 CN 115455003 A 3