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

支付环境上的风控挑战

• 一次应用内购行为涉及服务端多个系统协同工作，存在跨请求、异构中间结果、复杂调用链路和时标不一致等问题。
• 风控业务会话由一次用户行为引发，需多系统协作，但传统ELK体系T+1离线分析效率低，数据来源异构，ETL处理依赖业务脚本，难以满足实时性需求。
• 实时化风控能提升能效、降低成本、实现更及时决策。

借助Flink从T+1走向实时风控

• Apache Flink作为流批一体化计算引擎，提供可靠有状态计算、统一API和自然计算逻辑表达，支持实时风控。
• 核心风控数据点触发业务会话，非关键数据点依附关联，形成数据簇，通过ID关联实现跨数据源追踪。
• Flink支持补充风控点数据源和基准的灵活关联，解决水位线推进速度不一致问题。

实时风控平台的建设

• 平台功能包括业务会话级数据能效挖掘、实时宏观业务环境统计、实时微观业务会话检索与查错。
• 架构包含原始数据、微观业务会话还原、统计/Labeler+Flink实时统计、宏观业务环境统计、风控策略配置+Flink计算任务、实时风控结果等模块。
• 采用HTAP和SQL Join技术实现实时数据统计和查询。

发展历程与展望未来

• 未来将结合用户反馈驱动风控模型修正，利用AIGC挖掘更深层次数据价值，通过Flink-SQL实现即席查询风控结果。