网易游戏实时 HTAP 计费风控平台建设
💡
原文中文，约8400字，阅读约需20分钟。
📝
内容提要
网易互娱以Flink为计算引擎构建了一套实时风控平台，实现了零侵入、跨数据源、实时、低代码的实时关联分析，使用Session Window实现属性会话窗口，解决了线上系统无法为所有数据打上统一ID埋点的痛点。Flink提供了Interval Join算子，可以实现基准数据和补充数据的关联，并且Flink 1.17版本中支持延迟数据的补回，最终实现HTAP风控平台建设。
🎯
关键要点
- 网易互娱构建了基于Flink的实时风控平台，实现零侵入、跨数据源、实时、低代码的关联分析。
- 实时风控业务会话是通过用户行为引发的多个系统协作完成的全过程。
- 业务会话的还原需要解决多服务、多请求产生的异构结果难以直接关联的问题。
- Flink的Session Window用于实现属性会话窗口，适合用户触发的会话计算。
- 使用Flink的Interval Join算子可以关联基准数据和补充数据，解决没有统一ID的问题。
- HTAP风控平台Luna支持微观排障和宏观统计，用户可自助配置分析模板。
- TiDB作为存储层，支持灵活的字段配置和频繁的更新操作，满足业务需求。
- 通过数据打宽和可视化展示，提高风控结果的数据效能。
- 未来希望实时风控平台支持更多功能，如即席查询和风控模型修正。
➡️
