(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211118254.4 (22)申请日 2022.09.14 (71)申请人 中国工商银行股份有限公司 地址 100140 北京市西城区复兴门内大街 55号 (72)发明人 赖俊朝　陈月珠　曾现元　高冶　 (74)专利代理 机构 中科专利商标代理有限责任 公司 11021 专利代理师 张琛 (51)Int.Cl. G06F 8/656(2018.01) G06F 9/50(2006.01) G06F 9/54(2006.01) G06F 9/455(2006.01) (54)发明名称 基于消息队列的批量物理灰度方法及装置 (57)摘要 本公开提供了一种基于消息队列的批量物 理灰度方法， 涉及云计算技术领域， 可 以应用于 金融科技领域。 该方法包括： 响应于批量执行器 程序的更新指令， 根据灰度参数对批量数据进行 灰度染色； 按照负载均衡策略对 所述批量数据进 行容器预分配， 其中， 所述容器设置有灰白标识， 所述容器包括白版容器和灰度容器， 所述白版容 器装载旧版本批量执行器程序， 所述灰度容器装 载新版本批量执行器程序； 根据所述批量数据的 灰度染色标识将所述批量数据发送至消息队列 对应的主题分区中； 消费所述主题分区的批量数 据并将处理结果写入数据库。 本公开还提供了一 种基于消息队列的批量物理灰度装置、 设备、 存 储介质和程序 产品。 权利要求书2页 说明书12页 附图6页 CN 115469914 A 2022.12.13 CN 115469914 A 1.一种基于消息队列的批量物理灰度方法， 其特 征在于， 所述方法包括： 响应于批量执行器程序的更新指令， 根据灰度参数对批量数据进行 灰度染色； 按照负载均衡策略对所述批量数据进行容器预分配， 其中， 所述容器设置有灰白标识， 所述容器包括白版容器和灰度容器， 所述白版容器装载旧版本批量执行器程序， 所述灰度 容器装载新版本 批量执行器程序； 根据所述批量数据的灰度染色标识将所述批量数据发送至消息队列对应的主题分区 中； 以及 消费所述主题分区的批量数据并将处 理结果写入数据库。 2.根据权利要求1所述的方法， 其特征在于， 所述按照负载均衡策略对所述批量数据进 行容器预分配包括： 获取容器资源信息， 所述 容器资源信息包括 容器CPU和容器内存； 根据所述容器CPU和所述容器内存确定每一容器的最大容量值， 所述最大容量值为所 述容器能够处 理的批量数据的最大 条数； 以及 根据容器编号、 容器的灰白标识和所述最大容量值确定所述批量数据的执行容器编 号。 3.根据权利要求1所述的方法， 其特征在于， 所述根据灰度参数对批量数据进行灰度染 色包括： 根据所述灰度参数确定染色策略； 根据所述染色策略确定待染色的批量数据； 在所述待染色的批量数据的头 部加入灰度染色标识， 以完成灰度染色。 4.根据权利要求1中所述的方法， 其特征在于， 所述消费所述主题分区的批量数据包 括： 从分区组中通过组偏移变量读取批量数据的头部数据， 以确定所述批量数据的执行容 器编号； 若确定所述执行容器编号和当前容器编号相同， 则由当前容器直接处理该条批量数 据； 若确定所述执行容器编 号和当前容器编 号不同， 则根据当前容器的执行权值变量处理 该条批量数据。 5.根据权利要求4所述的方法， 其特征在于， 所述根据当前容器的执行权值变量处理该 条批量数据包括： 将所述执 行权值变量减去1； 若确定所述执 行权值变量 等于预设阈值， 则处 理该条批量数据， 并重 置执行权值变量； 若确定所述执行权值变量大于预设阈值， 则将消息状态设为未处理， 并重置分区组偏 移回到原来的位置 。 6.根据权利要求1至5中任一项所述的方法， 其特征在于， 所述主题分区包括灰度主题 分区和非灰度主题分区， 所述灰度主题分区的批量数据由灰度容器消费， 所述非灰度主题 分区的批量数据由白版容器消费。 7.一种基于消息队列的批量物理灰度装置， 其特 征在于， 所述装置包括： 灰度染色模块， 用于响应于批量执行器程序的更新指令， 根据灰度参数对批量数据进权　利　要　求　书 1/2 页 2 CN 115469914 A 2行灰度染色； 容器预分配模块， 用于按照负载均衡策略对所述批量数据进行容器预分配， 其中， 所述 容器设置有灰白标识， 所述容器包括白版容器和灰度容器， 所述白版容器装载旧版本批量 执行器程序， 所述灰度容器装载新版本 批量执行器程序； 发送模块， 用于根据 所述批量数据的灰度染色标识将所述批量数据发送至消息队列对 应的主题分区中； 以及 数据处理模块， 用于消费所述主题分区的批量数据并将处 理结果写入数据库。 8.一种电子设备， 包括： 一个或多个处 理器； 存储装置， 用于存 储一个或多个程序， 其中， 当所述一个或多个程序被所述一个或多个处理器执行时， 使得所述一个或多个 处理器执行根据权利要求1～6中任一项所述的基于消息队列的批量物理灰度方法。 9.一种计算机可读存储介质， 其上存储有可执行指令， 该指令被处理器执行时使处理 器执行根据权利要求1～6中任一项所述的基于消息队列的批量物理灰度方法。 10.一种计算机程序产品， 包括计算机程序， 所述计算机程序被处理器执行时实现根据 权利要求1～6中任一项所述的基于消息队列的批量物理灰度方法。权　利　要　求　书 2/2 页 3 CN 115469914 A 3