实时计算Flink版_Flink_实时计算_流计算_实时分析 - 阿里云

实时计算Flink版
播放视频
实时计算Flink版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。

产品规格

产品功能

实时数仓协助企业建立数字化运营体系,实时统计各项关键业务指标,直观呈现企业生产经营情况,为经营决策提供实时数据支持
实时ETL内置集成数十种连接器,覆盖数据库、消息队列、OLAP引擎等系统。自助编写SQL使用全托管服务对数据进行实时流转集成,帮助企业构建数据中台
实时反作弊从海量数据中实时识别刷单作弊、恶意爬虫等业务风险,避免企业出现巨大的经济损失,还可借助CEP(复杂事件处理)直接在流式处理作业中执行异常情况检测
实时监测实时计算Flink版高效的状态管理、丰富的窗口支持等特点可以帮助企业简化规则告警配置流程、提高告警效果,降低监测平台维护成本
实时推荐实时分析用户行为、结合 AI 技术建立更加精准的用户画像,及时推荐给用户更适合的新闻、视频和商品
实时IoT数据分析实时捕捉、分析IoT设备产生的巨量数据,帮助用户实时分析和诊断设备的运行状况,实时检测运行故障,实时预测制品良率等

产品优势

全托管Flink服务
开箱即用
开发运维全周期
计费灵活
丰富的企业级能力
流批一体的一站式开发运维平台
Flink CDC实时入湖入仓
动态CEP助力实时风控/营销
作业自动调优
支持文字链
性能强劲
内核引擎优化:CPU每秒数十万记录处理能力
Nexmark 测试性能较开源提升200%
状态存储后端优化
100%兼容开源
100% 兼容Apache Flink
支持开源 Flink 平滑迁移上云
无缝对接主流开源大数据生态
支持文字链
开放被集成能力强
自定义连接器、UXF能力扩展
Open API帮助用户集成自身系统
用户开发能力扩展与沉淀复用
用户自身系统集成
业界认可
中国信通院权威认证
中国唯一进入 Forrester 象限的实时流计算产品
金融实时数仓方案入围工信部信创典型目录

功能对比

类型
性能与成本
特色能力
开发效率
运维管理
企业安全
功能
弹性扩缩容
付费类型
核心性能提升
数据实时入湖入仓
实时风控场景能力
上下游数据连接(Connector)
流批一体的数据工程
作业开发
代码调试
监控告警
问题分析与诊断
高可用保障
状态管理
空间隔离
访问控制
安全审计
描述
用户可以根据业务负载进行弹性扩缩容
可智能调优,无人值守自动监控并调整作业资源分配
可在指定时间段应用对应的资源计划,削峰填谷,节省成本
可进行细粒度资源,支持算子级别的精细化资源配置
大规模作业资源利用率提升100%
用户可根据自身业务特点,选择包年包月或者按量付费
Nexmark 流计算标准测试性能是开源 Flink 的 2-3 倍
支持整库同步、分库分表同步
支持表结构改变同步、全量读从库增量读主一体化
不间断生产级能力:企业级 CEP 支持作业不停的动态可配置规则
可与阿里云主流数据产品无缝集成
支持特有数据模拟connector贴近业务含义的测试数据
Connector 易用性和稳定性提升
可按需自定义注册Connector对接各种外部存储系统
支持 Flink 批作业生命周期管理,实现和 DLF 的元数据集成
一站式开发管理平台,包括SQL/Java/Scala/Python 语言
支持主流 Flink 版本,包括多版本作业代码比较和回滚
内置统一元数据管理,并可无缝对接外部元数据系统
内置多个领域函数库,并可按需自定义函数
提供20多个Flink SQL常见通用场景的模版
支持线上采样和模拟测试数据管理
基于Session集群实现作业秒级启停
支持中间结果展示,提高复杂SQL的调试效率
开发生产隔离:开发调试过程不影响生产作业和数据
丰富的指标监控和维度聚合
通过钉钉、邮件、短信、电话、及时告警
可对接企业内部统一监控告警系统(prometheus)
动态修改作业的配置,无需启停即可对配置进行在线调整
提供数据血缘、元数据管理
对常见问题提供智能化诊断和快速日志定位分析
常见问题给出调优或者修改建议
并连动自动调优能力帮助用户定位问题
原厂运维服务兜底,SLA 99.9% 保证
全链路自动容错能力,支持 JobManager 容错
提供单点快速容错能力,灵活平衡数据一致性和可用性
提供完整的系统检查点和作业快照生命周期管理
提供状态兼容性检查和状态数据迁移
支持租户级和项目级的资源与代码隔离
与阿里云账号体系打通
支持OIDC身份认证标准协议
常见问题给出调优或者修改建议
全面的操作审计记录所有生产变更
实时计算Flink版 (开箱即用)
首月 ¥99
¥2061/首月
开源 Apache Flink

行业解决方案

电商行业
游戏行业
金融行业
广告行业
互联网交易
伴随着国内电商行业的飞速发展,原有的“大范围”,“广撒网”的运营方式已经不能满足业务需求。通过实时计算快速挖掘用户特征,分析需求喜好,帮助电商企业完成数字化、 精细化、个性化运营的方向转型。
能够提供
实时用户画像
针对不同类型客户制定实时高效个性化推荐,提高成单转化率
实时关联推荐
通过客户购买信息后建立实时关联分析,提高二次购买概率
推荐搭配使用
游戏行业
游戏作为新兴崛起的娱乐产业,其吸金能力和趣味性吸引了更多企业与人才投入其中。伴随应用商店和社交网络的兴起,游戏市场规模空前扩大,大数据和人工智能对于游戏运营特别是在延长游戏寿命方面所起到的积极作用越发明显。
能够提供
论坛数据追踪
根据对玩家论坛交流管控,获取当下玩家核心关注信息和游戏BUG检测,保障游戏的公平性
运营数据管控
通过实时计算技术,针对游戏运营活动进行实时分析,获得最有效的用户转化渠道,提高运营推广效果
行为数据分析
针对玩家实时行为数据分析建立玩家用户画像,个性化定制不同的游戏福利模式,提高玩家留存率和转化率
推荐搭配使用
金融行业
近年来, 随着互联网金融行业的飞速发展, 传统金融机构(如交易所、 证券公司、 银行等)的各类业务与互联网的结合也越来越紧密。针对银行业务的需求链路、风控、信用评估、欺诈风险、数据质量等需求提供整体解决方案。以金融机构为例,通过实时计算Flink 版构建实时数仓,反欺诈系统,助力金融机构快速构建实时风控体系。
能够提供
欺诈检测
针对用户账号、交易行为进行实时监控和区别,快速识别交易信息,减少用户损失;
实时风控
通过实时计算Flink版优化传统风控系统,转型智能风控,提高整体识别效率应用多个场景;
信用评估
快速识别虚假资料、信息伪冒等恶意欺诈行为,识别高危人群,通过智能方式缩短审核流程;
推荐搭配使用
广告行业
移动互联网的发展使得获取资讯服务的门槛和成本在逐步降低,也使得用户的资讯消费行为更频繁和多元化。移动网络新闻行业市场整体增速较快,发展潜能巨大,伴随着移动流量大幅度的增长,移动新闻资讯用户增多,差异化显著,精细化运营将会是未来的主旋律。
能够提供
海量数据处理
运用强大的数据处理能力应对日益增长的数据量(平台的用户数、日均UV/PV等核心指标),提高业务效率。
复杂场景标准化
主流媒体如新闻类、短视频类、直播类等输出方式,建立标准化通用化场景,业务管控更快捷。
业务实时输出快
针对内容分享平台业务个性化需求,通过实时计算进行业务精细化运营,增加用户粘性和消费欲望。

行业价值

互联网娱乐类企业
通过实时计算Flink版进行实时内容热点分析,实时用户行为分析,用户增长和活跃度实时监控分析,文章视频实时推荐,实时广告投放,实时流量运营等。
在线教育类企业
通过使用阿里云实时计算Flink版,可以有效解决续报、复课、直播课视频质量监控等在线教育关键场景下面临的计算实时性/准确性问题。通过产品提供的完整流式SQL能力可以极大的降低业务接入和开发成本,同时可以借助产品的自动弹性扩缩容能力有效应对流量高峰,更好的满足复杂多变的场景需求。
在线交易类企业
通过使用阿里云实时计算Flink版产品,用户可实现整个实时推荐系统的搭建,提高留存率和转化率 ;同时大量的标签、客户画像的落地,也使得运营团队能更准确的对客户进行定向推广,明显提升推广内容的转化率。
金融类企业
采用实时计算Flink版构建实时数仓、 实时反欺诈系统, 助力金融机构快速构建实时风控体系。主要业务场景包括实时反欺诈、实时大屏、实时精准推送等。

客户案例

钱大妈
钱大妈风控业务架构,主要由事件接入,风险应对,风险感知,风险回溯四个部分构成,阿里云实时计算Flink版产品在线ETL加工实时用户画像标签和销售事实指标,为钱大妈实时规则引擎的事件接入提供了重要的数据源支持。该风控技术方案已应用于钱大妈集团业务中,准确识别营销活动风险点,为用户利益保驾护航。
易仓科技
易仓科技致力于构建智能协同的跨境网络,目前租户分布全球,数据来自各大洲,汇集国外各大电商平台各个站点销售数据。面对这种数据体量大,跨全球各区域的复杂场景易仓大数据团队使用实时计算Flink版的高并发pipeline处理数据的能力,实现数据准确毫秒级别同步入仓。
江铃汽车
江铃汽车股份有限公司作为中国TOP 20汽车制造厂商、《财富》中国企业500强, 在大数据建设方面选择与阿里云强强合作,通过阿里云实时计算平台为公司构建统一的实时计算中心,服务于车辆中心、智慧车队、实时大屏三大业务线的多个实时场景,实现了实时业务的秒级响应,并成功帮助业务部门提高决策效率。
畅捷通
畅捷通的“易代账”作为业财税一体化的代账工具,管理员需要实时查询所管辖企业报税及凭证结转等统计汇总信息。使用实时计算Flink版产品之后,每一次报税、结转都在内存中完成预先计算,查询结果得以实时展现在用户面前,响应速度大幅提升的同时极大地提升了用户体验。
二维火
二维火专注于云计算餐饮软件系统研发和应用。其大数据团队通过阿里云实时计算Flink+Hologres实现百亿级数据高并发、秒级分析处理,并向客户提供80多种不同类型的报表,包括:营业、订单、菜品、会员等报表,为店铺发展提供多维度分析透视和业务探索。
微淼
通过实时计算Flink版产品,微淼构建了完善的实时数仓存储体系,支持如直播指标实时监控、到课率提升、落地页访问实时监控等业务,有效提升到课率10.5%、续费率1.5%,稳定支撑业务需求。

产品动态

2016-11-15 新功能
流计算支持日志服务读写功能
查看详情
2016-12-15 新功能
流计算支持RDS维表功能上线
查看详情
2016-12-15 新功能
流计算支持作业维度CPU、MEM维度的性能和资源指标展示
查看详情
2016-12-15 新功能
流计算新增提供多项底层组件运行指标展现
查看详情
2016-12-15 新功能
流计算支持云监控告警
查看详情
2016-12-15 新功能
流计算支持DRDS作为维表和结果表
查看详情
2016-12-15 新功能
流计算底层支持更多系统内置函数功能
查看详情
2017-02-28 新功能
流计算增加MQ类型的数据源支持
查看详情
2017-02-28 新功能
流计算支持多种运维指标上线
查看详情
2017-04-19 新功能
支持MaxCompute作为输入维表
查看详情
2017-04-20 新功能
流计算支持Redis作为写出插件
查看详情
2018-03-31 新产品
阿里云流计算-商业化发布
查看详情
2018-05-05 价格调整
阿里云流计算包年折扣
查看详情
2018-05-10 新版本/新规格
阿里云流计算在线降配
查看详情
2018-05-25 新版本/新规格
流计算起售调整为2CU
查看详情
2018-06-07 新版本/新规格
流计算独享模式邀测
查看详情
2018-06-28 新功能
阿里云流计算支持更多数据存储
查看详情
2018-07-05 新功能
流计算CEP功能上线
查看详情
2018-08-08 体验优化
查看详情
2019-01-31 新地域/可用区
上线马来西亚,香港
查看详情
2019-09-30 新地域/可用区
实时计算2019.2 新加坡开服
查看详情
2020-08-20 新版本/新规格
Flink全托管支持按量付费模式
查看详情
2020-08-21 新版本/新规格
Flink全托管2.2.0版本正式发布
查看详情
2020-09-15 新功能
Flink全托管版本商业化发布
查看详情
2020-09-22 新功能
实时计算Flink全托管版本支持CDC功能
查看详情
2021-01-11 新功能
实时计算Flink版支持智能诊断
查看详情
2021-03-16 新功能
实时计算Flink版开发控制台界面全新升级
查看详情
2021-04-19 新版本/新规格
实时计算Flink 2.4.1版本发布
查看详情
2021-08-04 新功能
实时计算Flink版SQL作业支持配置细粒度资源
查看详情
2021-08-04 新版本/新规格
实时计算Flink2.5.7版本发布
查看详情
2021-12-16 新版本/新规格
实时计算Flink版 2.8.0版本发布
查看详情
2022-03-04 新版本/新规格
实时计算Flink新版本发布
查看详情
2022-04-20 新功能
支持Lindorm 维表和结果表
查看详情
2022-05-16 新版本/新规格
4.0.13版本发布
查看详情
2022-05-16 新功能
新增支持Kafka Catalog
查看详情
2022-05-16 新功能
CDAS新增分库同步能力
查看详情
2022-05-16 新功能
Hologres Connector支持全增量一体源表消费
查看详情
2022-05-16 新功能
Redis结果表支持Key TTL
查看详情
2022-05-16 新功能
MaxCompute Connector支持Stream Tunnel
查看详情
2022-05-16 新功能
Hologres Connector支持Datastream API
查看详情
2022-05-16 新功能
Elasticsearch Connector支持retry_on_confilict参数
查看详情
2022-05-16 新功能
MySQL CDC 相关升级
查看详情
2022-05-16 新功能
Session集群增强停止能力
查看详情
2022-05-16 新功能
JM异常智能分析
查看详情
2022-05-16 新功能
内置阿里云文档
查看详情
2022-08-18 新功能
提供文件系统结果表能力
查看详情
2022-08-18 体验优化
优化MaxCompute写入性能
查看详情
2022-09-19 新功能
状态集管理
查看详情
2022-09-19 新功能
定时调优
查看详情
2022-09-19 新功能
作业健康分
查看详情
2022-09-19 新功能
新功能OpenAPI上线
查看详情
2022-09-19 新功能
成员授权优化
查看详情
2022-09-19 新功能
支持动态复杂事件处理(CEP)
查看详情
2022-09-19 新功能
静态CEP SQL增强
查看详情
2022-09-19 新功能
提供作业失败切换时的快速恢复能力
查看详情
2022-09-19 新功能
整库同步支持将数据同步至云Kafka
查看详情
2022-09-19 新功能
Hologres结果表DDL定义分区表
查看详情
2022-09-19 新功能
Hologres维表支持异步请求的超时时间设置
查看详情
2022-09-19 新功能
Hologres Catalog支持创建表时进行表属性设置
查看详情
2022-09-19 新功能
MaxCompute Sink Connector支持Binary类型
查看详情
2022-09-19 新功能
表格存储OTS Source Connector发布
查看详情
2022-09-19 新功能
Hive Catalog支持更多Hive版本
查看详情
2022-09-19 新功能
JDBC Connector发布
查看详情
2022-09-19 新功能
RocketMQ源表支持并发数大于Topic分区数
查看详情
2022-09-19 新功能
RocketMQ结果表支持Message Key的设置
查看详情
2022-09-19 新功能
支持阿里云ADB MySQL Catalog
查看详情
2022-10-19 新版本/新规格
企业级引擎VVR 6.0.2版发布|企业级重要能力全方位云上优化
查看详情
查看全部日志

帮助文档