一種基于流計算實現(xiàn)快速提取號碼熱度的方法

基本信息

申請?zhí)?/td> CN201611175911.3 申請日 -
公開（公告）號 CN106844450A 公開（公告）日 2017-06-13
申請公布號 CN106844450A 申請公布日 2017-06-13
分類號 G06F17/30(2006.01)I 分類 計算；推算；計數(shù);
發(fā)明人 雷俊智;鄭珍珍;余良波;梁勝利;潘琳;馬鈺璐;洪玉;劉逸;劉彥;陶曉軍;陳益輝 申請（專利權(quán)）人 號百信息服務(wù)有限公司
代理機構(gòu) 上海中優(yōu)律師事務(wù)所 代理人 王翔
地址 200085 上海市虹口區(qū)四川北路61號13-19樓
法律狀態(tài) -

摘要

摘要 本發(fā)明涉及一種基于流計算實現(xiàn)快速提取號碼熱度的方法，步驟是：基于分布式日志收集系統(tǒng)Flume，用于將海量日志或數(shù)據(jù)實時的收集，達到實時高效可靠得處理各種數(shù)據(jù)源；基于分布式消息隊列Kafka集群用于將數(shù)據(jù)源的數(shù)據(jù)通過消息隊列送達到實時處理平臺上，能夠?qū)崿F(xiàn)高吞吐和線性擴展；基于分布式流式計算集群用于消費消息隊列的數(shù)據(jù)，在內(nèi)存里進行迭代運算，實現(xiàn)秒級出運算結(jié)果；基于key?value庫Redis集群，用于將結(jié)果存于內(nèi)存，實現(xiàn)毫秒級數(shù)據(jù)查詢服務(wù)。本發(fā)明通過建立一套標(biāo)準(zhǔn)流式計算模型，實時處理海量數(shù)據(jù)，實現(xiàn)快速提取號碼熱度，給業(yè)務(wù)和市場人員快速直接的反應(yīng)，為決策做更好的支撐；并不斷實時更新壯大號碼庫。