实时事件
定义
实时事件是指需要在事件发生的瞬间或毫秒级到秒级内完成处理和反馈的业务事件。
应用场景
- 支付和交易风控
- 实时监测大额支付、跨境交易等异常行为。
- 拦截可疑交易，例如盗刷或洗钱交易。
- 欺诈检测
- 用户登录后的异常操作（如多地同时登录、敏感数据篡改）。
- 快速识别并阻断被盗账户的资金转移。
- 金融市场交易
- 股票、外汇等金融产品的价格波动监测，实时提供交易指令执行。
- 实时通知
- 实时短信或APP通知，如账户扣款、转账成功提醒。
准实时事件
定义
准实时事件是指数据从产生到处理和反馈之间允许一定的延迟，通常为秒级到分钟级。
特点
- 延迟容忍度较高：处理时间可以在几秒至几分钟之间，无需瞬时响应。
- 批量处理：经常以小时间窗口（如 1 分钟）进行批量处理。
- 面向趋势和分析：更关注事件数据的整体趋势，而非单一事件的即时响应。
应用场景
- 交易后审核
- 分析过去几分钟内的交易数据，检测潜在的异常模式（如高频小额转账）。
- 对大额转账或非实时处理的支票交易进行人工干预或审计。
- 营销分析
- 基于近几分钟的用户行为（如支付成功或失败）触发营销活动（如发放优惠券）。
- 用户行为分析
- 统计用户最近的操作行为数据，用于调整账户风险等级或推荐个性化产品。
- 数据聚合与报表生成
- 生成过去 5 分钟或 10 分钟内的资金流动报表，供业务人员参考。
批式事件
定义
批式事件是指以固定时间间隔（如每日、每小时）处理和分析一批积累的事件数据。批处理对时效性的要求较低，更多用于离线分析、数据聚合或报表生成。
应用场景
- 清算与对账
- 每日批量处理所有交易数据，生成对账单，核对内部和外部系统数据的一致性。
- 资金清算和跨行结算（如通过银联或SWIFT进行跨境交易清算）。
- 风险建模与策略优化
- 基于历史交易数据，批量重新训练反欺诈模型。
- 分析大规模信贷数据，优化信用评分系统的参数。
- 报表生成与监管报送
- 生成每日、每周或每月的资金流动报表、贷款余额报表等。
- 向监管机构提交大额交易报告（如反洗钱报告）。
- 数据归档与审计
- 批量归档过期账户数据或历史交易记录，便于审计和数据合规性检查。
- 审核某段时间内的系统日志以排查潜在问题。
- 营销分析
- 根据过去一个月的客户行为，批量分析用户群体特征，为下一步的营销活动制定策略。
实时、准实时与批式事件的对比
| 维度 | 实时事件 | 准实时事件 | 批式事件 |
|---|---|---|---|
| 触发方式 | 事件驱动（实时触发） | 时间窗口触发（小延迟） | 定时触发（如每日、每小时） |
| 响应时间 | 毫秒级到秒级 | 秒级到分钟级 | 分钟级到小时级甚至更长 |
| 处理模式 | 流式处理 | 微批处理 | 批量处理 |
| 适用场景 | 高优先级、实时性强的核心业务 | 延迟可接受的次优先级业务 | 离线计算、历史数据分析与归档 |
| 数据规模 | 小批量、单条数据 | 小窗口数据 | 大批量、海量数据 |
| 技术难点 | 需支持高并发和低延迟 | 需平衡延迟和吞吐量 | 需处理复杂计算和存储 |
| 典型场景 | 风控拦截、实时交易、通知推送 | 用户行为分析（比如凌晨短时间多次小额转账）、个性化推荐、趋势监控 | 对账清算、报表生成、历史数据分析 |