Real-Time Insight Engine (RTIE) - 基于流批一体架构的实时用户行为监测与反欺诈平台
立项背景: 针对高并发电商或金融场景,传统的离线报表(T+1)无法满足秒级风险控制和实时营销的需求。
核心功能:
秒级实时聚合: 订阅 Kafka 中的流量数据,通过 Flink 实现窗口计算,统计各维度(地区、商品、接口)的实时指标。
动态规则预警: 结合 HBase 存储的用户画像,通过自定义算子实现异常检测(如:同一 IP 短时间内频繁访问接口,触发黑名单逻辑)。
多维画像沉淀: 将聚合后的行为数据异步写入 HBase 宽表,支撑后端管理系统进行实时用户标签查询。
业务流程:
用户行为 -> Kafka -> Flink (清洗/转换/聚合) -> 结果分别写入 HBase (持久化) 和 Redis (预警推送)。
电商
金融