(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210636538.6 (22)申请日 2022.06.07 (71)申请人 蚂蚁区块链科技 （上海） 有限公司 地址 200010 上海市黄浦区外马路618号8 层803室 (72)发明人 吉力　李云领　李萌萌　 (74)专利代理 机构 北京国昊天诚知识产权代理 有限公司 1 1315 专利代理师 朱文杰 (51)Int.Cl. G06F 9/445(2018.01) G06F 9/54(2006.01) (54)发明名称 业务的冷启动方法、 装置及设备 (57)摘要 本说明书实施例提供了一种业务的冷启动 方法、 装置及设备， 其中方法包括： 根据获取到的 目标冷启动任务的处理请求， 确定目标冷启动任 务的元信息； 其中， 元信息包括多个回溯节点中 每个回溯节点在Kafka消息队列中对应的分区； 根据处理请求获取目标冷启动任务对应的第一 业务的目标历史日志数据； 将目标历史日志数据 均衡保存至各分区中； 其中， 每个分区中的目标 历史日志数据用于分区对应的回溯节 点， 确定与 第一业务具有依赖关系的第二业务的累积指标 的指标数据； 根据该指标数据对第二业务进行冷 启动处理。 权利要求书4页 说明书19页 附图5页 CN 115016860 A 2022.09.06 CN 115016860 A 1.一种业 务的冷启动方法， 包括： 根据获取到的目标冷启动任务的处理请求， 确定所述目标冷启动任务的元信 息； 其中， 所述元信息包括多个回溯节点中每 个回溯节点在Kafka消息队列中对应的分区； 根据所述处 理请求获取 所述目标冷启动任务对应的第一 业务的目标历史日志数据； 将所述目标历史日志数据均衡保存至各所述分区中； 其中， 每个所述分区中的目标历 史日志数据用于所述分区对应的所述回溯节点， 确定与所述第一业务具有依赖 关系的第二 业务的累积指标的指标 数据； 根据所述指标 数据对所述第二 业务进行冷启动处 理。 2.根据权利要求1所述的方法， 其特征在于， 所述确定所述目标冷启动任务的元信息， 包括： 根据所述 回溯节点的总数量和预设的并发配置参数， 为所述目标冷启动任务创建第 一 数量的主题， 并将所述回溯节 点划分为所述第一数量的回溯节点组； 其中， 所述回溯节点组 与所述主题一 一对应； 在所述Kafka消息队列中为每个所述主题分配第二数量的分区； 其中， 所述第二数量不 小于所述回溯节点组中回溯节点的第三数量； 对每个所述主题的所述分区进行分配处理， 得到所述主题对应的所述 回溯节点组中每 个回溯节点所对应的至少一个分区； 根据所述目标冷启动任务的任务标识、 所述第一数量的主题、 所述第一数量的回溯节 点组以及每 个所述回溯节点对应的分区， 生成所述目标冷启动任务的元信息 。 3.根据权利要求2所述的方法， 其特征在于， 所述根据所述处理请求获取所述目标冷启 动任务对应的第一 业务的目标历史日志数据， 包括： 从所述处 理请求中获取筛 选参数； 若确定所述第一业务的历史日志数据中与所述筛选参数相匹配的目标历史日志数据 符合预设的分次获取条件， 则依次从所述目标历史日志数据中获取部分目标历史日志数 据； 所述将所述目标历史日志数据均衡保存至各 所述分区中， 包括： 根据所述元信 息和预设的均衡规则， 确定各所述分区中用于保存当前次获取的所述部 分目标历史日志数据的第一目标分区； 将当前次获取的所述部分目标历史日志数据保存至所述第一目标分区中。 4.根据权利要求3所述的方法， 所述根据所述元信 息和预设的均衡规则， 确定各所述分 区中用于保存当前次获取的所述部分目标历史日志数据的第一目标分区， 包括： 根据所述目标冷启动任务的任务标识， 查询所述目标冷启动任务的所述元信息； 从所述元信息中获取 所述第一数量的主题； 根据预设的均衡规则， 确定所述第一数量的主题中待分配日志数据的第一目标主题； 从所述元信息中获取 所述第一目标主题对应的所述第二数量的候选分区； 根据所述均衡规则， 确定所述 候选分区中待配分日志数据的第一目标分区； 将所述第一目标分区确定为用于保存当前次获取的所述部分目标历史日志数据的第 一目标分区。 5.根据权利要求1所述的方法， 所述根据所述指标数据对所述第二业务进行冷启动处权　利　要　求　书 1/4 页 2 CN 115016860 A 2理， 包括： 将所述指标数据保存至指定的存储位置， 以使所述第 二业务的业务系统从所述存储位 置中获取所述指标数据， 并根据获取 的所述指标数据对所述第二业务进行冷启动处理； 或 者， 将所述指标数据 上传至所述第 二业务的业务系统中， 以使所述业务系统根据 上传的所 述指标数据对所述第二 业务进行冷启动处 理。 6.根据权利要求2所述的方法， 所述方法还 包括： 接收每个所述回溯节点发送的当前位移参数； 其中， 所述当前位移参数表征所述回溯 节点当前已处 理的最后一个目标历史日志数据， 在所述回溯节点对应的分区中的位置； 根据所述当前位移参数， 更新所述元信息 。 7.根据权利要求6所述的方法， 所述元信 息中包括所述 回溯节点的节点标识、 所述 回溯 节点对应的分区的分区标识以及所述当前位移参数的关联关系， 所述方法还 包括： 若确定存在预设时长 内处于宕机状态的第 一目标回溯节点， 则将所述第 一目标回溯节 点所在的目标回溯节点组所对应的主题的确定为第二目标主题； 重新对所述第 二目标主题的分区进行分配处理， 得到所述目标回溯节点组中每个剩余 回溯节点对应的至少一个新的分区； 根据所述 新的分区的分区标识从所述元信息中获取关联的所述当前位移参数； 根据所述新的分区的分区标识和所述新的分区关联的所述当前位移参数， 向所述新的 分区对应的剩余回溯节点发送分区更新消息； 其中， 所述分区更新消息用于所述剩余回溯 节点在所述分区标识对应的新的分区中， 将所述当前位移参数所对应的目标日志数据之后 的目标日志数据确定为待处 理数据， 并根据所述待处 理数据确定所述指标 数据。 8.根据权利要求7 所述的方法， 所述方法还 包括： 接收各回溯节点发送的心跳数据， 并记录每个回溯节点当前最后 一个心跳数据的发送 时间； 以及， 将记录的所述发送时间确定为所述预设时长的起始时间点， 确定所述预设时长内是否 存在未发送所述心跳数据的第一目标回溯节点； 若是， 则将所述第一目标回溯节点确定为处于宕机状态的第一目标回溯节点。 9.根据权利要求6所述的方法， 所述元信 息中包括所述 回溯节点的节点标识、 所述 回溯 节点对应的分区的分区标识以及所述当前位移参数的关联关系， 所述方法还 包括： 若确定存在宕机后重启的第 二目标回溯节点， 则确定所述第 二目标回溯节点对应的第 二目标分区； 根据所述第二目标分区的分区标识从所述元信息中获取关联的所述当前位移参数； 根据所述第 二目标分区的分区标识和所述第 二目标分区关联的所述当前位移参数， 向 所述第二目标回溯节 点发送数据处理消息； 所述数据处理消息用于所述第二目标回溯节点 在所述分区标识对应的所述第二目标分区中， 将所述当前位移 参数所对应的目标日志数据 之后的目标日志数据确定为待处 理数据， 根据所述待处 理数据确定所述指标 数据。 10.根据权利要求2所述的方法， 获取到所述目标冷启动任务的处理请求之后， 所述方 法还包括： 根据确定的所述目标冷启动任务的任务标识， 向每个所述回溯节点发送线程启动消权　利　要　求　书 2/4 页 3 CN 115016860 A 3