(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211186137.1 (22)申请日 2022.09.27 (71)申请人 武汉众邦银行股份有限公司 地址 432200 湖北省武汉市黄陂区盘龙城 经济开发区汉口北大道88号汉口北国 际商品交易中心D2区1-2层、 2 2-23层 (72)发明人 张桃龙　徐晋毅　 (74)专利代理 机构 成都正煜知识产权代理事务 所(普通合伙) 51312 专利代理师 袁宇霞 (51)Int.Cl. G06Q 10/06(2012.01) G06Q 40/02(2012.01) (54)发明名称 一种可动态扩展的风控指标计算方法、 装置 及存储介质 (57)摘要 本发明涉及数据实时处理和离线处理领域， 具体涉及一种可动态扩展的风控指标计算方法、 装置及存储介质。 主旨在于解决数据处理平台的 在处理风控指标时灵活性不足， 无法动态改变风 控指标的计算规则、 新增风控指标的问题。 本发 明主要方案包括对银行的多样的风控指标进行 分类， 针对不同类别的风控指标特点采取不同的 指标计算和存储 方式； 同时为满足风控业务动态 增删改风控指标的需求， 数据处理平台提供统一 的对外指标规则计算接口， 数据处理平台根据指 标规则的变化实时更新处理规则， 无需对应用进 行停服的操作， 最终风控指标统一以数据接口的 方式提供给风控业务方进行调用， 达到时效性和 可扩展性满足风控业 务需求的目的。 权利要求书3页 说明书7页 附图1页 CN 115511303 A 2022.12.23 CN 115511303 A 1.一种基于分类的可动态扩展的风控指标计算方法， 其特 征在于， 包括以下步骤： 步骤1、 新建消息队列， 通过消息队列用来保存来自各个 应用的埋 点对应的行为数据； 步骤2、 Zookeeper的临时节点保存风控指标的计算规则， 实时指标处理程序监听 Zookeeper的指定节 点以获取各个风控指标的计算规则， 并对计算规则进行解析， 将 计算规 则中的指标和事 件标识的对应关系保存到内存状态中； 步骤3、 实时程序消费来自消息队列中的行为数据； 步骤4、 实时程序根据风控指标的计算规则中的分组字段， 将行为数据进行动态的分 组， 得到分组后的行为数据； 步骤5、 实时指标处理程序对分组后的行为数据使用底层的Flink  API逐条消费， 并按 照步骤6到步骤10进行风控指标的计算； 步骤6、 实时指标处理程序在进行指标计算之前， 首先需要根据当前处理的行为数据提 取出事件标识， 然后查询内存状态中事件标识和指标的映射关系， 如果映射关系中没有和 事件标识对应的记录， 则跳过当前 行为数据， 不做后续处 理； 否则进行步骤7； 步骤7、 查看当前事 件对应的指标的类别， 如果类别为 “1‑一个批次内 ”， 则执行步骤7‑1； 如果类别为 “2‑时间段内 ”， 则执行步骤7‑2； 如果类别为 “3‑时间段内、 一个批次内 ”， 则执行步骤7‑3； 步骤7‑1、 查询内存状态中的保存用户是否活跃的状态， 如果用户处于活跃状态， 则执 行步骤8‑1； 否则执 行步骤8‑2； 步骤7‑2、 跳过当前事 件的处理； 步骤7‑3、 记录当前的指标类别， 并跳 到步骤7‑1执行； 步骤8‑1、 循环遍历当前处理的行为数据中事件对应的风控指标， 对每一个风控指标进 行聚合操作， 并将风控指标和风控指标对应的值保存到内存状态中； 如果当前事件是一个批次的结束事件， 且指标类别为 “1‑一个批次内 ”或“3‑时间段内、 一个批次内 ”， 则执行步骤9‑1； 如果当前事件非批次结束事件， 指标类别为 “1‑一个批次内 ”， 为当前事件设定一个定 时器， 定时器的时间为设定的阈值时间， 当定时器 触发时执 行步骤9‑2； 如果当前事件非批次结束事件， 指标类别为 “3‑时间段内、 一个批次内 ”， 则取最小值为 指标规则的时间段的值和设定的阈值的较小值， 并注册定时器为最小值， 定时器处理逻辑 的执行步骤9‑3； 步骤8‑2、 查询缓存Redis中是否有该用户的信息， 如果有， 则执行步骤8 ‑3； 否则更新用 户的活跃状态为活跃， 并跳转到步骤8 ‑1执行； 步骤8‑3、 将缓存Redis中当前用户的状态数据恢复到内存状态中， 并清空缓存Redis中 该用户的信息， 然后跳转到步骤8 ‑1执行； 步骤9‑1、 将内存状态中的所有风控指标及对应的指标值写入到存储库El asticsearch 中， 并发送一条批次结束消息给离线指标应用， 离线指标应用在接 收到批次结束消息后执 行步骤10； 步骤9‑2、 将内存状态中的所有指标及对应的指标值写入到缓存Redis中， 并设定该条 缓存记录的过期时间， 然后更新用户的活跃状态为非活跃；权　利　要　求　书 1/3 页 2 CN 115511303 A 2步骤9‑3、 更新离线指标配置表。 步骤10、 离线指标应用在接收到批次结束消息后， 读取离线指标配置表， 动态拼接DSL 语句， 查询Elasticsearc h计算离线指标， 并将查询的结果保存到指标 结果表中。 2.根据权利要求1所述的一种基于分类的可动态扩展的风控指标计算方法， 其特征在 于， 业务方在配置好各个指标的计算规则以及分组规则后， 写入到Zookeeper的节点， 实时 程序监听指定的节点， 并捕获到计算规则和分组规则的实时变化， 并作用到实际的风控指 标计算过程中。 3.根据权利要求1所述的一种基于分类的可动态扩展的风控指标计算方法， 其特征在 于， 对不同的风控指标进行分类， 根据不同的分类进行不同的指标计算处理， 对于分类 “1‑ 一个批次内 ”的指标采用实时计算的方式， 对于分类 “2‑时间段内 ”的指标采用离线指标计 算的方式， 对于分类 “3‑时间段内、 一个批次内 ”的指标采用实时于 离线相结合的方式。 4.一种基于分类的可动态扩展的风控指标计算装置， 其特 征在于， 包括： 行为数据获取模块、 新建消息队列， 通过消息队列用来保存来自各个应用的埋点对应 的行为数据； 映射关系模块、 Zookeeper的临时节点保存风控指标的计算规则， 实时指标处理程序 监 听Zookeeper的指定节 点以获取各个风控指标的计算规则， 并对计算规则进 行解析， 将计算 规则中的指标和事 件标识的对应关系保存到内存状态中； 行为数据分组模块、 实时程序消费来自消息队列中的行为数据， 实时程序根据风控指 标的计算 规则中的分组字段， 将行为数据进行动态的分组， 得到分组后的行为数据； 风控指标计算模块、 实时指标处理程序对分组后的行为数据使用底层的Flink  API逐 条消费， 并按照步骤A1到步骤A10进行风控指标的计算； 步骤A1、 实时指标处理程序在进行指标计算之前， 首先需要根据当前处理的行为数据 提取出事件标识， 然后查询内存状态中事件标识和指标的映射关系， 如果映射关系中没有 和事件标识对应的记录， 则跳过当前 行为数据， 不做后续处 理； 否则进行步骤A 2； 步骤A2、 查看当前事 件对应的指标的类别， 如果类别为 “1‑一个批次内 ”， 则执行步骤A2‑1； 如果类别为 “2‑时间段内 ”， 则执行步骤A2‑2； 如果类别为 “3‑时间段内、 一个批次内 ”， 则执行步骤A2‑3； 步骤A2‑1、 查询内存状态中的保存用户是否活跃的状态， 如果用户处于活跃状态， 则执 行步骤A2‑1； 否则执 行步骤A2‑2； 步骤A2‑2、 跳过当前事 件的处理； 步骤A2‑3、 记录当前的指标类别， 并跳 到步骤A2‑1执行； 步骤A2‑1、 循环遍历当前处理的行为数据中事件对应的风控指标， 对每一个风控指标 进行聚合操作， 并将风控指标和风控指标对应的值保存到内存状态中； 如果当前事件是一个批次的结束事件， 且指标类别为 “1‑一个批次内 ”或“3‑时间段内、 一个批次内 ”， 则执行步骤A3 ‑1； 如果当前事件非批次结束事件， 指标类别为 “1‑一个批次内 ”， 为当前事件设定一个定 时器， 定时器的时间为设定的阈值时间， 当定时器 触发时执 行步骤A3 ‑2； 如果当前事件非批次结束事件， 指标类别为 “3‑时间段内、 一个批次内 ”， 则取最小值为权　利　要　求　书 2/3 页 3 CN 115511303 A 3