基于数据回放与时序追赶技术下的实时银行流计算业务系统

摘要

本发明公开了一种基于数据回放与时序追赶技术下的实时银行流计算业务系统。本发明针对在银行流计算业务根据用户消费行为和特征数据做相关指标计算时，为适应市场节奏和用户银行消费服务需求对有关指标做变更，导致已完成数据需要重新回放在流处理引擎做计算的场景，通过充分利用庞大的存储空间弥补流计算的缺陷，利用流处理实时性特点使回放处理指标在短时间实现与常规指标进度同步，且在数据定义和转换层面保证回放数据流不影响正常数据流的处理，从而设计一个实时银行流计算业务系统，使得银行流计算业务活动更好地适应于银行计算环境和用户需要，提高银行流计算业务策略竞争力。