首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Apache Flink 在移动实时计算的实践

本篇内容主要分为四个部分: 实时计算平台建设 中移信令业务优化 稳定性实践 未来方向的探索 image.png 中移(苏州)软件技术有限公司是中国移动通信有限公司的全资子公司,公司定位为中国移动设施的构建者...实时计算平台介绍 image.png 实时计算引擎在移动的演进分为几个阶段: 2015 年到 16 年,我们使用的是第一代实时计算引擎 Apache Storm; 17 年我们开始调研 Apache...同时我们研究了流计算比较出名的几篇文章,发现 Apache Flink 已经比较完整地具备了文中提到的一些语义; 19 年 – 20 年,我们开始实现服务,并把实时计算平台上线至公有云和私有;...image.png 目前 Flink 主要用于中移信令数字的处理、实时用户画像和埋点、实时数仓、实时运维监控、实时推荐以及移动的数据管道服务。...image.png 中移的实时计算平台功能分为三大部分。

47020
您找到你想要的搜索结果了吗?
是的
没有找到

游戏业务安全实时计算集群:原生资源优化实践

毛东方,后台开发工程师,负责IEG-业务安全部的后台实时系统Kubernetes相关的开发与运营,目前主要致力于提高集群的资源利用率,减少机器成本。...背景 随着公司业务上的呼声越来越高,越来越多的团队已经完成业务上的进程,K8s 集群在公司整体机器成本中的比重越来越大。...优化方案 基于历史监控的预测值 predicts 替代 requests 对于游戏安全的实时计算业务,其资源使用往往具备明显的周期性,并且周期之间变动不会太大,因此可以基于 Pod 的历史监控数据预测未来的资源使用情况...整体编排主要分为两个步骤: 基于 Pod predicts 计算出资源均衡的部署方案,使用尽可能少的节点满足当前 Pod 的资源需求; 将计算出的部署方案应用到集群; 部署方案计算 部署方案主要需要实现两个目标...扫描二维码 进入腾讯原生技术交流群 和更多小伙伴一起交流原生

1.3K20

什么是实时流式计算

实时流式计算,也就是RealTime,Streaming,Analyse,在不同的领域有不同的定义,这里我们说的是大数据领域的实时流式计算。...实时流式计算,或者是实时计算,流式计算,在大数据领域都是差不多的概念。那么,到底什么是实时流式计算呢?...而实时,流式其实是相对的概念,现在的很多技术更应该说是近实时,微批。但只要能不断的优化这些问题,实时流式的计算的价值就会越来越大。...由于大数据兴起之初,Hadoop并没有给出实时计算解决方案,随后Storm,SparkStreaming,Flink等实时计算框架应运而生,而Kafka,ES的兴起使得实时计算领域的技术越来越完善,而随着物联网...,机器学习等技术的推广,实时流式计算将在这些领域得到充分的应用。

2.6K20

什么是实时流式计算

实时流式计算,也就是RealTime,Streaming,Analyse,在不同的领域有不同的定义,这里我们说的是大数据领域的实时流式计算。...实时流式计算,或者是实时计算,流式计算,在大数据领域都是差不多的概念。那么,到底什么是实时流式计算呢?...而实时,流式其实是相对的概念,现在的很多技术更应该说是近实时,微批。但只要能不断的优化这些问题,实时流式的计算的价值就会越来越大。...由于大数据兴起之初,Hadoop并没有给出实时计算解决方案,随后Storm,SparkStreaming,Flink等实时计算框架应运而生,而Kafka,ES的兴起使得实时计算领域的技术越来越完善,而随着物联网...,机器学习等技术的推广,实时流式计算将在这些领域得到充分的应用。

2.2K40

计算——计算关键技术

作者简介:一名计算网络运维人员、每天分享网络与运维的技术与干货。   ...一.计算关键技术 1.虚拟化技术 虚拟化是一种能够更有效地利用物理计算机硬件的过程,是计算的基础。 虚拟化,将各种IT实体资源抽象,转换成另一种形式的技术都是虚拟化。...计算常用分布式数据存储的技术,将数据存储于不同物理设备中,不仅摆脱物理设备的限制,扩展性更好,满足快速响应用户需求的变化。 ---- (1)计算的分布式存储与传统的存储是不同的。...---- 3.数据中心联网技术 东西向流量增长并行计算业务(如:搜索)需要服务器集群协调运算,产生大量横向交互流量虚拟机的自由部署和动态迁移,虚机间需要实时同步大量的数据。 ​  ...---- (1)计算数据中心的优势 计算数据中心相比传统数据中心的优势在于,计算数据中心更加强调与IT系统协同优化,在满足需求的前提下,实现整个数据中心的最高效率和最低成本。

34930

计算

1:什么是计算计算是一种按量付费的模式!计算的底层是通过虚拟化技术来实现的!...2:计算的服务类型 2.1 IAAS 基础设施即服务(infrastructure as an service) 虚拟机 ecs openstack 2.2 PAAS 平台即服务(platform...service ) php,java docker容器 2.3 SAAS 软件即服务(software as an service ) 企业邮箱服务 cdn服务 rds数据库 开发+运维 3:为什么要用计算...小公司:10台 20w+ idc 5w + 100M 10W, 10台主机,前期投入小,扩展灵活,风险小 大公司:闲置服务器计算资源,虚拟机,出租(超卖) 64G 服务器 64台1G 320台...虚拟化,通过模拟计算机的硬件,来实现在同一台计算机上同时运行多个不同的操作系统的技术。

28.5K32

实时稀疏点分割

首先是将扫描到的点移除平面处理,然后移除平面后一定范围内的点数据分割成不同的对象。该论文的是集中解决了在很小的计算量的条件下,能够在大多数系统上做到高效的分割。...避免了直接对3D点计算,并直接在2.5D 的深度图像上进行操作。此方案能够很好的解决处理稀疏的3D点数据。...使用上述生成的和成图像来处理而不是直接处理计算3D点,可以有效的加速处理速度,对于其他的不提供距离值的扫描仪也可以将3D点投影到圆柱图像上,计算每个像素的欧几里得距离,仍然可以使用该论文提出的方法。...其次,我们避免生成3D点,这使得整体方法的计算速度更快。 在下图中展示了分割的效果 ?...图中的右图示出了从场景的俯视图中在xy平面中的计算。 注意,我们可以计算在范围图像中在行或列方向上相邻的点A和B对的角度β。

2.7K10

spark实时计算性能优化

1、  计算提供两种模式,一种是jar包本地计算、一种是JSF服务。 2、  第一步是引入spark,因与netty、JDQ均有冲突,解决netty冲突后,隔离计算为单独服务。...3、  第二步是召回集扩量,发现当召回集由200扩到500后性能下降过快到70ms,利用多线程多核计算,性能到6ms。...已在预发 5、  第四步召回集在扩量,如性能瓶颈是io,则使用jar包本地计算,但与JDQ冲突。需要将线上上报迁移到统一上报服务,服务已有待联调上线。...需要调整接口服务与素材、特征以及计算服务,通过测试得到IO、线程计算结果合并、多核计算的平衡,需排期配合。    ...第五步已基本和开源分布式搜索引擎计算方式类似,后续会持续调研新的优化方式,并引入到线上。

1.2K90

nfv与计算_计算必学知识

一 .计算 1.Saas软件即服务 SaaS的实例: MicrosoftOfficeOnline(WordOnline,ExcelOnline等)服务,无需在本机安装,打开浏览器,注册账号,可以随时随地通过网络进行软件编辑...基础设施层面 iaas的实例 : VMware 提供成熟的虚拟机及虚拟机管理软件,是业界最大的虚拟化软件提供商 OpenStack提供一个开源的软件解决方案,能够管理KVM VMware等虚拟机 3.计算应用...Google也允许第三方在Google的计算中通过Google App Engine,基于所提供的接口运行大型并行应用程序。 二 ....计算的定义 NIST: 计算是一种能够通过网络随时随地以便利的、按需付费的方式获取计算资源(包括网络、服务器、存储、应用和服务等)并提高其可用性的模式,这些资源来自一个共享的、可配置的资源池,并能够以最省力和无人干预的方式获取和释放...IT业分布式计算技术并未考虑电信业务处理数据包小、高并发特性的特点,用现有的分布式计算,直接用于电信领域不能满足业务要求高性能、高可靠性的要求 分布式计算技术需针对电信领域的场景、业务特征专门优化之后,

20.2K30

Strom-实时计算框架

所谓实时计算,就是近几年由于数据得到广泛应用之后,在数据持久性建模不满足现状的情况下,急需数据流的瞬时建模或者计算处理。...这种实时计算的应用实例有金融服务、网络监控、电信数据管理、 Web 应用、生产制造、传感检测,等等。...但是,这些数据以大量、快速、时变(可能是不可预知)的数据流持续到达,由此产生了一些基础性的新的研究问题——实时计算实时计算的一个重要方向就是实时计算。...Spark Streaming构建在Spark上,一方面是因为Spark的低延迟执行引擎(100ms+),虽然比不上专门的流式数据处理软件,也可以用于实时计算,另一方面相比基于Record的其它处理框架...实时计算处理流程 互联网上海量数据(一般为日志流)的实时计算过程可以划分为 3 个阶段: 数据的产生与收集阶段、传输与分析处理阶段、存储对对外提供服务阶段。 ?

1.6K20

用Spark进行实时计算

项目,一个基于 Spark SQL 的全新流计算引擎 Structured Streaming,让用户像编写批处理程序一样简单地编写高性能的流处理程序。...Structured Streaming是Spark2.0版本提出的新的实时流框架(2.0和2.1是实验版本,从Spark2.2开始为稳定版本) 从Spark-2.X版本后,Spark Streaming...Process time 处理时间: 则是这条日志数据真正到达计算框架中被处理的时间点,简单的说,就是你的Spark程序是什么时候读到这条日志的。 事件时间是嵌入在数据本身中的时间。...基于SparkSQL构建的可扩展和容错的流式数据处理引擎,使得实时流式数据计算可以和离线计算采用相同的处理方式(DataFrame&SQL)。 可以使用与静态数据批处理计算相同的方式来表达流计算。...Structured Streaming将实时数据当做被连续追加的表。流上的每一条数据都类似于将一行新数据添加到表中。 ?

2.3K20

计算离超级计算还有多远?

单就一个行业而言,一直以来我们对于计算所带来好处的认识可能显得过于狭窄了。如果计算是一次真正的革命性变革,那么它就必须能够支持生产和用户体验的模式,而这些都是目前的计算还不能为客户提供的支持项。...也就是说,未来真正的计算必须是我们口中的“超级计算”,它应该是一个具备更好的计算和网络服务的平台,而不仅仅只是更便宜而已。...对于服务供应商来说,超级计算带来的好处可能是双倍的,即为IT公司增加IT资源和附加值。 但是,这里存在着一个大问题:计算供应商们是否能够建设好超级计算?...目前,企业都在他们自己的数据中心中运行应用程序,而计算则主张这些应用程序不仅应当能够以较低的成本在计算中运行,而且也应为计算供应商们创造利润。...计算项目的投资回报率(ROI)在某种意义上已经超越了纯粹的成本节省,任何计算迁移的可预测风险都会迫使买家进一步追求更高的ROI,所有这些都使得计算服务的实施变得更为困难。

13.3K60

计算专题:(一)带你走近计算

要点提示 ① 计算发展背景 ② 什么是计算计算的优势 ④ 计算与大数据 ● 数字经济蓬勃发展下的计算 数字经济为中国产业转型带来了巨大的机遇,我国数字经济规模已达27.2万亿,占当年...计算的最终目标是将计算、服务和应用作为一种公共设施提供给公众,使人们能够像使用水、电、煤气和电话那样使用计算机资源。 02、什么是,什么是主机?...主机:主机整合计算、存储与网络资源的IT基础设施能力租用服务,能提供基于计算模式的按需使用和按需付费能力的服务器租用服务。 03、什么是公有、私有、混合?...计算给政企带给的价值 计算的扩展场景 ● 计算+大数据的服务趋势 什么是大数据? 我们迎来了大数据发展时代,对客观世界的认识更进了一步,所做的决策也不再仅仅依赖主观判断。...大量的在线地图数据和优化算法,最终能帮助UPS实时地调配驾驶员的收货和配送路线。该系统为UPS减少了8500万英里的物流里程,由此节约了840万加仑的汽油。

15.5K10

点量实时渲染革新看车

看车革新:点量实时渲染助力看车随着互联网的发展,5G网络及计算技术越来越成熟,汽车行业的3D解决方案也在不断成熟。...当前实时看车正在成为一种全新的方式,利用流化技术,实现可交互、沉浸式的线上虚拟看车,打破门店看车空间位置限制,突破传统线上看车依赖高配终端设备,消费者在手机、pad等轻量化设备就能看车,同时还可根据个人需求调整车配置...点量依靠多年视频和传输技术的积累,采用自研流化技术可提供优质的解决方案。点量实时渲染的优势:1.即点即用:无需预加载,一键运行。...3.轻量化终端:对终端性能配置无要求,兼容各种终端4.极低延迟点量实时渲染为汽车行业赋能车企使用点量流化XR应用,分享链接给消费者,消费者通过手机、pad、笔记本电脑等多终端设备随时随地体验汽车XR...疫情的影响也变相加速了汽车行业线上看车的革新,消费者也会接受并慢慢依赖看车的体验。

1.5K30

使用审计实时监控腾讯账户

2017年11月26号腾讯推出了审计(CloudAudit)服务,该服务可以记录账户资源操作,提供操作记录查询,并可以将记录文件保存到用户指定的COS存储空间。...假如用户开通了审计服务以后,用户便可以清晰的知道自己的账户中的资源被哪个账号在什么时候从哪个IP发起过什么操作。 上面的描述有点拗口,那到底审计给用户带来了什么呢?...用户(包含子账号)在腾讯上的操作日志可以查询。 审计提供了API可以供用户调用。 审计提供了PHP版本的SDK更加方便用户去查询自己的日志。...审计还提供了腾讯实验室教程,手把手引导用户来查询自己的日志,是不是很贴心。 用户如果很关心自己的账户安全的话,不妨试一试审计,实时监控自己的腾讯账户。当敏感操作发生以后及时告知到自己。...现在怀着一脸懵逼的心情来探索一下,如何实现使用审计实时监控腾讯账户。 首先,审计的日志格式是什么样的? 啥也不说,先上个审计日志的例子,然后再给出每个字段的详细含义。

3.8K140
领券