基于Redis实现窗口实时计算的方法、系统和设备
摘要:
本发明公开了一种基于Redis实现窗口实时计算的方法、系统和设备,该方法以下步骤:接收行为事件数据并进行预处理后写入消息队列;预先加载指标变量,根据指标变量计算方法实现不同的LUA脚本处理逻辑,并将LUA脚本预加载到Redis服务端;消费消息队列中的数据,调用LUA脚本执行数据存储;根据指标变量调用指标服务实时获取对应数据进行计算得到计算结果。本发明的基于Redis实现窗口实时计算的方法、系统和设备,基于Redis实现窗口的实时计算,通过Redis的Hash与Zset存储结构缓存汇总明细,并通过自定义窗口算法实现窗口的滑动或滚动,将多次Redis访问请求包封装为LUA脚本,不仅避免频繁的IO操作,减少网络请求,而且避免了高并发场景下的事物一致性。
0/0