一種基于大數(shù)據(jù)的流處理預(yù)警的方法

基本信息

申請?zhí)?/td> CN201911174899.8 申請日 -
公開（公告）號 CN110890983A 公開（公告）日 2020-03-17
申請公布號 CN110890983A 申請公布日 2020-03-17
分類號 H04L12/24;H04L29/08 分類 電通信技術(shù);
發(fā)明人 張國偉;焦東輝 申請（專利權(quán)）人 北京杰思安全科技有限公司
代理機(jī)構(gòu) 北京酷愛智慧知識產(chǎn)權(quán)代理有限公司 代理人 北京杰思安全科技有限公司
地址 100011 北京市海淀區(qū)學(xué)院路5號768創(chuàng)意產(chǎn)業(yè)園區(qū)B座10門1091
法律狀態(tài) -

摘要

摘要 本發(fā)明提出一種基于大數(shù)據(jù)的流處理預(yù)警的方法，構(gòu)建Storm分布式集群作為數(shù)據(jù)處理模塊，數(shù)據(jù)處理模塊從數(shù)據(jù)收集端口接收待處理數(shù)據(jù)，通過Drool構(gòu)建規(guī)則引擎，數(shù)據(jù)處理模塊和規(guī)則引擎共同將待處理數(shù)據(jù)處理為待預(yù)警數(shù)據(jù)，預(yù)警模塊根據(jù)待預(yù)警數(shù)據(jù)發(fā)出警報，將規(guī)則引擎與Storm分布式集群結(jié)合，規(guī)則引擎拉取分布式集群中的待處理數(shù)據(jù)進(jìn)行數(shù)據(jù)關(guān)聯(lián)分析得到待預(yù)警數(shù)據(jù)后進(jìn)行預(yù)警，提升了海量數(shù)據(jù)實時分析處理能力，并且能夠及時獲取危險預(yù)警信息并及時發(fā)出預(yù)警。