您的位置:首页 > 互联网

DorisDB在中移物联网PGW实时会话业务领域的应用

发布时间:2021-03-18 00:00:00  来源:互联网     背景:

  自从2021年1月份推出免费的DorisDB标准版产品后,我们的客户量出现了爆发式的增长。到目前为止,已经有数十家客户在生产环境正式上线了DorisDB,并且有数百家客户正在进行真实业务场景的测试。我们邀请了部分已上线的客户,分享他们的数据分析经验。这个系列的文章涉及多个行业,将在未来持续输出,敬请关注。

  作者:宁彦辉——中移物联网大数据开发工程师,主要从事流计算开发、物联网机器学习数据挖掘以及OLAP查询引擎数据开发

  中移物联网作为中国移动通信集团有限公司出资成立的全资子公司。公司按照中国移动整体战略布局,围绕“物联网业务服务的支撑者、专用模组和芯片的提供者、物联网专用产品的推动者”的战略定位,专业化运营物联网专用网络,设计生产物联网专用模组和芯片,打造车联网、智能家居、智能穿戴等特色产品,开发运营物联网连接管理平台OneLink和物联网开放平台OneNET,推广物联网解决方案,形成了五大方向业务布局和物联网“云-网-边-端”全方位的体系架构。

  本文主要讨论了中移物联网在PGW实时会话业务数据分析与建模方面,利用SparkStreaming和DorisDB进行的探索与实践。并希望我们在实时数仓建模领域的应用实践,能给大家一些启发,也欢迎大家多多交流,给我们提出宝贵的建议。

  PGW实时会话业务背景介绍

  中移物联网作为物联网业务领域的支撑者,目前在线物联卡用户达到6.7亿。中移物联网智能连接部大数据团队作为物联卡用户与物联卡之间的数据分析纽带,主要依托物联卡的基础属性数据和使用行为数据通过数仓建模、大数据挖掘等其他手段为用户提供高效的数据服务。

  PGW实时会话业务主要指的是,通过PGW网元设备实时收集从全球各地传送回来、符合Radius协议的GGSN报文数据,然后通过大数据分析等手段,进行数据建模、数据挖掘等其他子项目。例如为集团客户提供每张物联卡的实时位置和分布情况;通过风险防控模型,对比实时收集的报文数据,为客户提供每张物联卡的风险等级等项目。

  业务痛点及实时技术的挑战

  目前该业务在具体落地过程中,以及应用业务对实时数据需求方面,主要存在以下问题和技术难点:

  1.流式数据join。目前PGW实时会话业务,峰值每秒数据达到35万/s,针对不同的业务需求,往往在数据清洗阶段,需要对流式数据进行字段关联,然后以宽表形式写入;

  2.存量数据排序、实时分析。一方面因为各地区网元设备的不稳定等其他因素,往往实时传送过来的数据存在乱序问题,另一方面因为单条会话长期在线(最长超过14天),对于单条会话的实时分析往往需要对存量数据进行排序;

  3.统一的实时OLAP数据平台构建。我们的用户包括:内部售后团队、运营、产品等内部人员外,还有外部政企平台客户。不同的用户往往关系的数据粒度、时间频率、维度等各不相同。但是我们希望能建立一套统一的实时OLAP数据平台,并提供一套灵活、安全可靠的实时数据服务。

  目前整个业务的数据规模和业务如下:

  技术框架的调研与演进

  1.原有技术框架

  原有技术框架以及整个PGW实时会话业务的处理流程如上。实时数据通过流处理组件处理后,针对不同需求和业务方,数据存储和展示借助多技术组件。并且大多情况下为满足一个业务需求往往需要多技术组件配合使用。如PGW明细会话查询,往往是借助Redis或ES作为索引组件再去查询Hbase,一方面Hbase只能进行简单的模糊查询,无法做到联邦查询、聚合统计查询,另一方面若统计查询借助Impala+Hive时效性往往很难保证。

  2.MPP技术框架的调研

  为解决实时分析的时效性,同时又能保证数据快速写入,并且能够对外提供一个较为统一和简单的OLAP数据平台。我们先后调研了ClickHouse、DorisDB、Kudu。并针对我们的业务分析和业务痛点做了以下测试。

  ClickHouse:虽然具备较好的OLAP分析性能,但因其底层的架构设计,集群模式下数据写入需开发人员手动指定写入节点以及数据存储目录以保证集群数据平衡。同时集群扩容后很难做到数据自平衡,对运维人员提出较高要求,另一方面由于该数据库不支持事务特性,在数据更新时容易出现数据重复,且不易解决此问题。

  DorisDB:查询分析性能强悍,多表关联速度比其他产品快很多。与Clickhouse类似,DorisDB目前不支持字段级别的数据更新,同时查询性能与表的设计和集群性能密切相关。原则上集群性能随数据节点线性增长。另外,简便的运维管理也是DorisDB的一大亮点。目前DorisDB开发版本迭代快,需要及时跟进官方的版本进展。

  Kudu:支持快速数据更新、快速数据分析与即席查询,但是数据量不宜过大,单表数据量不宜超过15亿。

  性能方面,批量写入性能Clickhouse略优于其他系统,相同资源条件下明细查询性能ClickHouse和DorisDB比Impala+Kudu更快,DorisDB有比较方便的物化视图(Rollup)可以满足统计查询的需求,另外DorisDB在关联查询方面性能有比较明显的优势。

  综上所述,实时数仓方案,采用Kudu+DorisDB相结合,实现现有PGW实时会话业务。DorisDB作为主要技术组件,Kudu辅助实现字段级别更新业务场景。

  3.现有技术框架

  3.1现有技术框架整体介绍

  为解决现有的业务痛点,同时平衡在实时数据处理技术实现上的难点。我们摒弃了部分技术组件,采用新的技术组件搭建整个实时数仓用于满足PGW实时会话业务。其中DorisDB可以满足大多场景的需求。

  PGW会话业务中流式Join问题,一部分我们通过在DorisDB中星型建模的方案的解决,另一部分我们借助关系型内存数据库VoltDB+Google Guava Cache,流式组件处理过程中代码实现。

  存量数据的排序、实时分析问题。我们借助DorisDB range分区以及高效的OLAP性能初步缓解。

  最后统一OLAP分析平台,我们完全借助DorisDB实现。

  3.2 DorisDB解决的痛点和挑战

  1.充分利用DorisDB在多表join方面的性能优化,如Colocate Join、内存表等特性。将原来的流式join方案改为通过星型建模方案,在数据服务层进行多表join的联邦查询;

  2.通过DorisDB动态分区特性对存量数据进行分区,然后利用Bitmap数据类型进行精确去重,然后再在各分区内完成排序。排序的结果进一步汇总到一张数据表中,和实时到来的数据放在一起排序,可以有效地解决数据乱序问题,并且保证数据分析的效率。

  3.DorisDB可作为数据服务层的统一对外引擎,一方面保证查询性能,另一方面避免了原来多技术组件带来的冗余问题,极大降低了系统的管理成本。

  4.技术实现方面:替代Hbase部分业务,缓解了Hbase分区分裂带来的性能问题;通过ES外表引擎,解决ES表不能进行join、语法特殊等技术问题。

  DorisDB在具体项目上的应用及优化

  目前DorisDB集群总共25台BE,4台FE,存储采用支持采用NVME协议的SSD硬盘。

  1.PGW用户实时位置轨迹

  1.1方案介绍

  实时收集到的GGSN报文,通过DorisDB的聚合模型,将发生位置变更轨迹的明细数据实时沉淀下来。并对不同的区域维度生成Rollup表。最细粒度到基站级别,然后生成省、地市级别的Rollup表以供不同业务查询。

  GGSN报文量35万/s,通过SparkStreaming处理解析后,每1分钟StreamLoad一次入DorisDB。

  1.2方案优化

  最开始因为Rollup表建了省、地市、区县、乡镇,导致在写入时IO负担过大,写入速度跟不上数据推送,SparkStreaming出现挤压,后期通过性能测试Rollup表只建立了省、地市维度。同时新增一张乡镇base表,并在其基础上建立区县Rollup表。

  同时为保证查询的时效性,base表Rollup表前缀索引在字段类型和选择上按照官方建议,避免使用Varchar类型。

  2区域会话明细模型

  2.1项目背景

  数据服务层需对外提供每张物联卡,统一会话发生位置变更后在不同区域的套餐使用情况,会话时常等信息。进而统计物联卡各区域的漫入漫出情况。

  2.2项目方案

  实时收集到的GGSN报文,通过DorisDB的聚合模型,将发生位置变更时的套餐记录,变更时间沉淀下来。然后通过定时任务,从聚合模型明细数据中计算出套餐使用情况,会话时长,生成新的DWD表。DorisDB目前的物化视图很有用,但还不是很灵活,比如,只支持明细数据表模型,并且支持单表创建物化视图,不支持多表Join构建物化视图。

  DorisDB在中移物联网PGW实时会话业务领域的展望

  一方面我们目前了解到,DorisDB开发团队,目前正在解决DorisDB字段级别无法支持更新的短板。在未来DorisDB升级过程中,我们可能会摒弃掉Kudu,完全借助DorisDB实现实时数仓技术架构。

  另一方面,我们期待DorisDB物化视图的灵活性更高,可以支持Join级别的物化视图和不同表引擎的物化视图。除此之外,在接下来的项目开发过程中我们也计划进一步使用bitmap索引、Colocation Join等更丰富的功能提高我们的查询速度。

  除此之外,为了完善实时数仓的分层结构,我们计划在未来使用Flink来对接DorisDB,保证数仓的分层结构,同时进一步完善统一的OLAP数据分析平台。

特别提醒:本网内容转载自其他媒体,目的在于传递更多信息,并不代表本网赞同其观点。其原创性以及文中陈述文字和内容未经本站证实,对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺,并请自行核实相关内容。本站不承担此类作品侵权行为的直接责任及连带责任。如若本网有任何内容侵犯您的权益,请及时联系我们,本站将会在24小时内处理完毕。


返回网站首页

本文评论
擎朗智能全国驰援送餐机器人 获150多家重量级媒体关注
连日来,新型冠状病毒感染的肺炎疫情,牵动着全国人民的心。疫情爆发以来,室内无人配送机器人头部......
日期:02-19
影驰推出新款星耀RGB内存条:16GB DDR4-3600,599元
1月20日消息 不久前,影驰推出了星曜品牌的内存,采用了钻石切割RGB导光罩,铝合金散热器,8GB DDR4......
日期:01-20
面对职业维权人,看看大家都是怎么说的
近年来,随着消费者维权意识的普遍提升,越来越多的人在面对商家的不公正对待时,选择拿起法律武器......
日期:06-25
国美11.11返场优惠不停 这些3C数码爆品持续击穿底价
墨镜一戴,谁也不爱,进入11.11模式的数码潮人们,眼睛就像是无所不能的扫描仪,什么定金翻倍、转盘......
日期:11-13
2019云栖大会 | 室内无人配送机器人规模化普及时机已到
9月25-27日,以“数·智”为主题的2019杭州云栖大会在云栖小镇开幕。来自全球1000......
日期:09-27
立足数据,助力AI——Testin将亮相第六届世界互联网大会
全球瞩目的第六届世界互联网大会将于2019年10月20日至22日在中国乌镇召开,大会以“互联网之光......
日期:10-18
VideoPro云会议系统助力企业随时随地无忧举行年终会
2021年如期而至,疫情并未离我们而去,但生活得继续,个人和企业都要正常运转。...
日期:02-03
微信回应升级 iOS 13.2 被“杀”进程:紧急修复中 部分网友:已恢复正常
近日,有少量网友发现更新 iOS 13.2 后,微信进程被“杀”。除了微信,包括美团外卖、微......
日期:11-02
3I模型和经济三要素告诉你,为什么李彦宏说智能经济正在来临?
“如果说过去十年,我们中国经济有一个非常亮眼的标签的话,我觉得这个标签可能应该叫做&lsquo......
日期:12-22
同时成为两大电影节座上宾!ALPD究竟为何如此抢手?
继全国上线安装量突破2万套之后,又有好消息传来:2020年12月6日开幕的第三届海南岛国际电影节和12......
日期:12-16
用Shark鲨客蒸汽拖把杀菌除螨,轻松体验家居清洁乐趣
很早就被各大博主种草了各式各样的蒸汽拖把,一直担心拖地有水渍、拖不干净、质感太廉价等等,直到这......
日期:06-18
功能实用,科大讯飞智能录音笔为你开启高效智能办公
纸质记录费时费力,全英文演讲听着吃力,如何才能做好会议记录呢?想必不少职场人士都遇到过这样的问......
日期:05-27
AI部署前路坎坷,50%项目半路夭折
尽管许多公司都在努力,但人工智能的部署仍然是个难题。最近International Data Corporation的一份......
日期:07-10
私人生活“被直播” 平台岂能“装无辜”
议论风生 “直播”用户居家日常,已经触碰到公众权益的边界,何为隐私权,何为......
日期:09-26
《我的年代照》H5再刷屏 来腾讯微视让这波“回忆杀”动起来
日前,由腾讯×人民网联合打造、为庆祝新中国成立70周年重磅推出的《我的年代照》H5刷屏朋友......
日期:10-03
湖南90后夫妻返乡当“寨主”走红火山小视频 帮助家乡人民脱贫致富
如今,在这个快节奏的时代,有越来越多的人开始不满足于充斥着压力和竞争的现代生活,渴望回归田园......
日期:09-27
首批教育App备案名单公布:新东方、百词斩、网易有道词典在列
12月17日消息 昨日据国内媒体报道称,75岁的柳传志预计本周正式卸任联想控股董事长。早前曾共同发起......
日期:12-17
与热爱同行、云逛王府井,京东618邀你打卡“北京消费季”
如果你此刻身在王府井,目之所及的地方,都会有“热爱”的红。...
日期:06-06
日回收量达第二名3倍,爱回收C2B是如何做到的?
3月8日消息,继2021年春节以来,订单和GMV大幅增长后,爱回收的手机C2B业务再创新高,C2B回收业务交易规......
日期:03-08
深信服云数据中心安全解决方案全新升级
云上面向租户/业务提供的安全能力多样,难以管理? 云内流量复杂、攻击隐蔽性强,安全风险难以定位? 云上安全运营工作...
日期:08-07