公开(公告)号：CN106202503A

公开(公告)日：2016-12-07

申请号：CN201610574191.1

申请日：2016-07-19

Applicant: 北京百分点信息科技有限公司

Inventor： 苏萌 ,  苏海波 ,  向延超 ,  汤金源 ,  戚伟杰

IPC: G06F17/30

CPC classification number: G06F16/958 ,  G06F16/9535

Abstract: 本发明实施例提供一种数据处理方法及装置，涉及计算机技术领域。其中，所述方法包括：当监听到有新的网络数据时，将所述新的网络数据存储至数据源；采用流式计算框架storm将所述数据源中的网络数据进行拓扑处理，得到数据拓扑；将所述数据拓扑中的各网络数据发射至storm中对应的数据操作节点bolt中进行处理，得到处理结果；将所述处理结果存入存储介质中。本发明实施例提供的技术方案实现了数据处理的实时性。

公开(公告)号：CN106202503B

公开(公告)日：2019-08-16

申请号：CN201610574191.1

申请日：2016-07-19

Applicant: 北京百分点信息科技有限公司

Inventor： 苏萌 ,  苏海波 ,  向延超 ,  汤金源 ,  戚伟杰

IPC: G06F16/958 ,  G06F16/9535

Abstract: 本发明实施例提供一种数据处理方法及装置，涉及计算机技术领域。其中，所述方法包括：当监听到有新的网络数据时，将所述新的网络数据存储至数据源；采用流式计算框架storm将所述数据源中的网络数据进行拓扑处理，得到数据拓扑；将所述数据拓扑中的各网络数据发射至storm中对应的数据操作节点bolt中进行处理，得到处理结果；将所述处理结果存入存储介质中。本发明实施例提供的技术方案实现了数据处理的实时性。