基于storm面向用户个性化预警机制大数据计算方法

摘要

本发明公开一种基于storm面向用户个性化预警机制大数据计算方法，具体步骤是：用户通过界面按照自身设备设置报警逻辑，设置成功后，系统将会按照约定的数据结构存储报警逻辑；数据缓存模块定时读取存储的数据结构，storm报警模块结合报警逻辑与服务器网关从终端读取发来的实时数据进行逻辑判断；若是报警数据，将进一步判断redis中是否已经存在报警历史，若存在则更新相应记录，若不存在则插入一条报警记录；若不是，判断redis中的报警历史，若存在,表示报警已经解除，则删除这条记录。本发明处理速度快，支持海量数据处理，在处理逻辑上使用了用户个性化预警方案，用户可根据自己设备的实际情况，定义报警方案。