基于流式处理技术Storm的配电生产设备的在线监控方法

摘要

本发明公开了一种基于流式处理技术Storm的配电生产设备的在线监控方法，通过配电生产系统的设备实时数据有更新则将数据发送到消息响应系统，根据设备类型分发为不同的消息主题，流式处理系统storm根据不同设备类型实时向消息相应系统获取相对应主题消息，进行在线处理并判断当前状态是否异常，若异常则将设备信息发送至报警系统；对处理后的设备状态值存入离线数据库，结合外部气象局数据与存入处理结果的离线数据库进行预警分析，本发明除了能够实时监控外，还能够结合历史数据，通过内部分析模型并判断是否准确，通过分析模型分析出的预警信息，比传统监控系统中内置固定的专家意见和人工判断要更加准确，用数据说话也更科学、更严谨。

主权项

一种基于流式处理技术Storm的配电生产设备的在线监控方法，其特征在于：该方法包括以下步骤，步骤1：配电生产系统的设备实时数据有更新则将数据发送到消息响应系统，根据设备类型分发为不同的消息主题；在设备信息产生时，消息响应系统有一个程序去一直监控数据的产生，产生一行就通过一个传输系统发给消息响应系统，然后在消息响应系统内部按照设备类型、设备id分别存于不同的主题，通过广播的方式发布出去，每条数据从获取到分组发布完成，可以在毫秒级别完成；步骤2：流式处理系统storm根据不同设备类型实时向消息相应系统获取相对应主题消息，进行在线处理；步骤3：根据步骤2的处理结果判断当前状态是否异常，若异常则将设备信息发送至报警系统；在设备信息产生时，消息响应系统有一个程序去一直监控数据的产生，产生一行就通过一个传输系统发给流式计算系统，然后流式计算系统直接处理，根据处理结果立即判断是需要发动报警还是存入离线数据库，每条数据从产生到处理完成，在集群数为4台以上可以在毫秒级别完成；步骤4：对步骤2处理后的设备状态值存入离线数据库；步骤5：结合外部气象局数据与步骤4存入处理结果的离线数据库进行预警分析。