公开(公告)号：CN107070890A

公开(公告)日：2017-08-18

申请号：CN201710142542.6

申请日：2017-03-10

Applicant: 北京市天元网络技术股份有限公司

Inventor： 徐炯 ,  李智

IPC: H04L29/06 ,  H04L29/08 ,  H04L12/24 ,  H04W24/02 ,  H04W84/08

CPC classification number: H04W24/02 ,  H04L41/044 ,  H04L41/0823 ,  H04L65/40 ,  H04L67/1078 ,  H04L67/1097 ,  H04W84/08

Abstract: 本发明提供了一种通信网优系统中的流数据处理装置及通信网优系统，流数据处理装置包括：流式数据生成模块，用于将不同数据源得到的文件数据加载为流式数据并推送至Kafka处理模块中；Kafka处理模块，用于将流式数据均匀地加载至Kafka集群中，以供Storm处理模块进行调用；Storm处理模块，包括Spout节点和Bolt节点，Spout节点用于从Kafka集群中读取数据并推送至Bolt节点，Bolt节点用于将Spout节点推送的数据根据预先配置的应用场景进行相应计算并将计算结果进行实时汇总，以及定期将汇总结果存储至Redis集群中；Redis存储模块，用于将汇总的数据缓存在内存中；数据输出模块，用于将流式处理结果以标准的接口提供给第三方数据者。本发明使网优系统能够提供用户级别的实时感知分析功能。