网易游戏实时计费风控体系建设

林佳-⺴易游戏-资深开发⼯程师 DataFunSummit#2023 目录CONTENT 03实时风控平台的建设 01支付环境上的风控挑战 04发展历程与展望未来 02借助Flink从T+1走向实时风控 01支付环境上的风控挑战 DataFunSummit#2023 支付环境上的风控挑战 一次应用内购行为…… 打开商城选择道具付款收到道具 支付环境上的风控挑战 支付环境上的风控挑战 支付环境上的风控挑战 渠道支付 支付环境上的风控挑战 支付环境上的风控挑战 渠道支付 验证支付凭证 支付环境上的风控挑战 用户在手机客户端的一次点击 服务端多个系统的协同工作 跨请求、异构的中间结果、复杂的调用链路、不一致的时间标准…… 支付环境上的风控挑战 风控业务会话 由一次用户行为所引发的，需要多个系统协作完成、同时触发多个请求、产生跨越多个服务提供方调用的全过程。 支付环境上的风控挑战 支付环境上的风控挑战 业务会话级的问题定位，极度依赖人工处理和个人经验，重复工作多，容易错判 支付环境上的风控挑战 数据持续而大量产生数据与数据间存在会话关联关系 ELK体系持续采集T+1全量离线分析 数据来源的异构数据结构的异构数据时间步调的不一致 网盘同步/rsync/接口推送/……多以业务特制脚本处理各种数据的ETLT+1 Spark离线处理 支付环境上的风控挑战 支付环境上的风控挑战 实时化以提升能效 支付环境上的风控挑战 支付环境上的风控挑战 支付环境上的风控挑战 用更少的资源算更多的数据能更早地交付 支付环境上的风控挑战 更高效的成本使用更实时的计算结果更及时的决策响应 支付环境上的风控挑战 02 借助Flink从T+1走向实时风控 DataFunSummit#2023 借助Flink从T+1走向实时风控 Apache Flink is a framework and distributed processing engine forstatefulcomputationsoverunbounded and boundeddata streams. Flink has been designed to run inall common clusterenvironments, perform computations atin-memory speedand atany scale. ◇可靠的有状态计算 -可靠语义保证：At Least Once、Exactly Once-故障恢复-避免与外部系统的复杂交互逻辑-TTL 借助Flink从T+1走向实时风控 Apache Flink is a framework and distributed processing engine forstatefulcomputationsoverunbounded and boundeddata streams. Flink has been designed to run inall common clusterenvironments, perform computations atin-memory speedand atany scale. ◇流批一体化 -统一的计算引擎，统一的API 借助Flink从T+1走向实时风控 -自然的计算逻辑表达-可靠的计算语义-高性能分布式计算 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 基准 需要关注的核心风控数据点一旦出现就认定存在一个包含它的业务会话有一个请求ID跟踪整个业务会话 补充 非关键的、辅助判断的风控数据点依附到相应的基准风控数据中，不单独开启业务会话有至少一个ID可以和基准数据进行关联 簇 由同一种数据来源的基准和补充所关联得到的一个雪花状数据结构 借助Flink从T+1走向实时风控 基准 需要关注的核心风控数据点一旦出现就认定存在一个包含它的业务会话 借助Flink从T+1走向实时风控 补充 非关键的、辅助判断的风控数据点依附到相应的基准风控数据中，不单独开启业务会话有至少一个ID可以和基准数据进行关联 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 补充风控点的数据源和基准可能不同 需要用不一样的字段与基准风控结果簇做关联 水位线推进速度不一致、甚至存在局部的同步延迟 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 借助Flink从T+1走向实时风控 03实时风控平台的建设 DataFunSummit#2023 实时风控平台的建设 业务会话级数据能效挖掘与提升 实时宏观业务环境统计与风控 实时微观业务会话检索与查错 实时风控平台的建设 原始数据 微观业务会话还原 统计/Labeler+Flink实时统计 宏观业务环境统计 风控策略配置+Flink计算任务 实时风控结果 实时风控平台的建设 实时风控平台的建设 实时风控平台的建设 实时风控平台的建设 实时风控平台的建设 实时风控平台的建设 HTAP！SQLJoin! 实时风控平台的建设 实时风控平台的建设 04发展历程与展望未来 DataFunSummit#2023 发展历程与展望未来 发展历程与展望未来 发展历程与展望未来 发展历程与展望未来 发展历程与展望未来 发展历程与展望未来 用户反馈驱动的风控模型修正 结合AIGC挖掘更深层次数据价值 Flink-SQL即席查询风控结果 感谢观看