一种基于流计算实现快速提取号码热度的方法
基本信息
申请号 | CN201611175911.3 | 申请日 | - |
公开(公告)号 | CN106844450A | 公开(公告)日 | 2017-06-13 |
申请公布号 | CN106844450A | 申请公布日 | 2017-06-13 |
分类号 | G06F17/30(2006.01)I | 分类 | 计算;推算;计数; |
发明人 | 雷俊智;郑珍珍;余良波;梁胜利;潘琳;马钰璐;洪玉;刘逸;刘彦;陶晓军;陈益辉 | 申请(专利权)人 | 号百信息服务有限公司 |
代理机构 | 上海中优律师事务所 | 代理人 | 王翔 |
地址 | 200085 上海市虹口区四川北路61号13-19楼 | ||
法律状态 | - |
摘要
摘要 | 本发明涉及一种基于流计算实现快速提取号码热度的方法,步骤是:基于分布式日志收集系统Flume,用于将海量日志或数据实时的收集,达到实时高效可靠得处理各种数据源;基于分布式消息队列Kafka集群用于将数据源的数据通过消息队列送达到实时处理平台上,能够实现高吞吐和线性扩展;基于分布式流式计算集群用于消费消息队列的数据,在内存里进行迭代运算,实现秒级出运算结果;基于key‑value库Redis集群,用于将结果存于内存,实现毫秒级数据查询服务。本发明通过建立一套标准流式计算模型,实时处理海量数据,实现快速提取号码热度,给业务和市场人员快速直接的反应,为决策做更好的支撑;并不断实时更新壮大号码库。 |
