实时计算Flink版

播放视频
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,具备实时应用的作业开发、数据调试、运行与监控、自动调优、智能诊断等全生命周期能力。内核引擎100%兼容Apache Flink,2倍性能提升,拥有FlinkCDC、动态CEP等企业级增值功能,内置丰富上下游连接器,助力企业构建高效、稳定和强大的实时数据应用。
实时计算 Flink 版
提供全托管版 Flink 集群和引擎,提高作业开发运维效率。
询价中
实时计算 Flink 版
3月以上85折 以10CU为例
询价中
Hologres+Flink实时湖仓组合
构建一体化实时湖仓平台,极大提高数据开发及应用效率
询价中

产品优势

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

产品功能

实时数仓协助企业建立数字化运营体系,实时统计各项关键业务指标,直观呈现企业生产经营情况,为经营决策提供实时数据支持。了解详情>
实时ETL内置集成数十种连接器,覆盖数据库、消息队列、OLAP引擎等系统。自助编写SQL使用全托管服务对数据进行实时流转集成,帮助企业构建数据中台。
实时风控从海量数据中实时识别刷单作弊、恶意爬虫等业务风险,避免企业出现巨大的经济损失,还可借助CEP(复杂事件处理)直接在流式处理作业中执行异常情况检测。了解详情>
实时监测实时计算Flink版高效的状态管理、丰富的窗口支持等特点可以帮助企业简化规则告警配置流程、提高告警效果,降低监测平台维护成本。了解详情>
实时推荐实时分析用户行为、结合 AI 技术建立更加精准的用户画像,及时推荐给用户更适合的新闻、视频和商品。
实时IoT数据分析实时捕捉、分析IoT设备产生的巨量数据,帮助用户实时分析和诊断设备的运行状况,实时检测运行故障,实时预测制品良率等。
类型
性能与成本
特色能力
开发效率
运维管理
企业安全
功能
弹性扩缩容
付费类型
核心性能提升
数据实时入湖入仓
实时风控场景能力
上下游数据连接(Connector)
作业开发
代码调试
监控告警
问题分析与诊断
高可用保障
状态管理
空间隔离
访问控制
描述
用户可以根据业务负载进行弹性扩缩容
可智能调优,无人值守自动监控并调整作业资源分配
可在指定时间段应用对应的资源计划,削峰填谷,节省成本
可进行细粒度资源,支持算子级别的精细化资源配置
大规模作业资源利用率提升100%
用户可根据自身业务特点,选择包年包月或者按量付费
Nexmark 流计算标准测试性能是开源 Flink 的 2-3 倍
支持整库同步、分库分表同步
支持表结构改变同步、全量读从库增量读主一体化
不间断生产级能力:企业级 CEP 支持作业不停的动态可配置规则
可与阿里云主流数据产品无缝集成
支持特有数据模拟connector贴近业务含义的测试数据
Connector 易用性和稳定性提升
可按需自定义注册Connector对接各种外部存储系统
一站式开发管理平台,包括SQL/Java/Scala/Python 语言
支持主流 Flink 版本,包括多版本作业代码比较和回滚
内置统一元数据管理,并可无缝对接外部元数据系统
内置多个领域函数库,并可按需自定义函数
提供20多个Flink SQL常见通用场景的模版
支持线上采样和模拟测试数据管理
基于Session集群实现作业秒级启停
支持中间结果展示,提高复杂SQL的调试效率
开发生产隔离:开发调试过程不影响生产作业和数据
丰富的指标监控和维度聚合
通过钉钉、邮件、短信、电话、及时告警
可对接企业内部统一监控告警系统(prometheus)
动态修改作业的配置,无需启停即可对配置进行在线调整
提供元数据管理
对常见问题提供智能化诊断和快速日志定位分析
常见问题给出调优或者修改建议
连动自动调优能力帮助用户定位问题
原厂运维服务兜底,SLA 99.9% 保证
全链路自动容错能力,支持 JobManager 容错
提供单点快速容错能力,灵活平衡数据一致性和可用性
提供完整的系统检查点和作业快照生命周期管理
提供状态兼容性检查和状态数据迁移
支持租户级和项目级的资源和代码隔离,满足跨团队协作需求
与阿里云账号体系打通,支持多角色的访问控制
实时计算Flink版 (开箱即用)
新用户首购 0¥
开源 Apache Flink

行业解决方案

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

行业价值

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

客户案例

钱大妈
钱大妈风控业务架构,主要由事件接入,风险应对,风险感知,风险回溯四个部分构成,阿里云实时计算Flink版产品在线ETL加工实时用户画像标签和销售事实指标,为钱大妈实时规则引擎的事件接入提供了重要的数据源支持。该风控技术方案已应用于钱大妈集团业务中,准确识别营销活动风险点,为用户利益保驾护航。
易仓科技
易仓科技致力于构建智能协同的跨境网络,目前租户分布全球,数据来自各大洲,汇集国外各大电商平台各个站点销售数据。面对这种数据体量大,跨全球各区域的复杂场景易仓大数据团队使用实时计算Flink版的高并发pipeline处理数据的能力,实现数据准确毫秒级别同步入仓。
江铃汽车
江铃汽车股份有限公司作为中国TOP 20汽车制造厂商、《财富》中国企业500强, 在大数据建设方面选择与阿里云强强合作,通过阿里云实时计算平台为公司构建统一的实时计算中心,服务于车辆中心、智慧车队、实时大屏三大业务线的多个实时场景,实现了实时业务的秒级响应,并成功帮助业务部门提高决策效率。
畅捷通
用友旗下畅捷通信息技术股份有限公司在面临数据库性能瓶颈及实时数据处理需求,通过引入Flink技术逐步解决了数据同步、链路稳定性和表结构差异等问题,并计划在未来进一步优化链路稳定性、探索湖仓一体架构以及结合AI技术推进数据资源高效利用。
二维火
二维火专注于云计算餐饮软件系统研发和应用。其大数据团队通过阿里云实时计算Flink+Hologres实现百亿级数据高并发、秒级分析处理,并向客户提供80多种不同类型的报表,包括:营业、订单、菜品、会员等报表,为店铺发展提供多维度分析透视和业务探索。
微财
微财在新版的实时风控系统架构中基于Flink构建实时变量池,彻底解决了老版架构中3个核心问题:1、数据库耦合度高、QPS 上限低的问题;2、提升开发效率,优化开发流程;3、高效存储实时变量。该风控技术方案已应用于微财的生产业务中,提升了金融风控场景的时效性和准确性。
掌阅科技
掌阅科技专注于数字阅读,是全球领先的数字阅读平台之一。基于数字阅读平台的海量用户,掌阅通过阿里云实时计算Flink版等大数据计算和分析服务,搭建商业化、用户增长、推荐服务等数据基建平台,实现商业化增值与用户阅读体验的结合。
飞鹤
飞鹤是中国最早的奶粉企业之一,以极具前瞻性的眼光布局专属产业集群,把控奶粉生产全过程。飞鹤借助实时计算Flink等产品,构建数字化运营管理体系,建立实时预警机制,提前窥探风险,为供应链等业务决策提效。
微淼
通过实时计算Flink版产品,微淼构建了完善的实时数仓存储体系,支持如直播指标实时监控、到课率提升、落地页访问实时监控等业务,有效提升到课率10.5%、续费率1.5%,稳定支撑业务需求。

产品动态

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版发布|企业级重要能力全方位云上优化
查看详情
2022-12-26 新功能/规格
全托管VVR 6.0.4版本发布|提供云上Apache Flink 1.15.2能力
查看详情
2023-02-20 新功能/规格
VVR 6.0.5版本发布|多功能发布更有StarRocks连接器新增
查看详情
2023-04-13 新功能/规格
Flink引擎VVR 6.0.6版本发布以及平台改版、连接器更新、性能优化
查看详情
2023-04-13 新功能/规格
首发Apache Paimon及Flink Machine Learning预览型功能|全网分步灰度发布平台新版本
查看详情
2023-06-21 新功能/规格
VVR 6.0.7版本发布,加强了数据管控功能
查看详情
2023-08-21 新功能/规格
MongoDB CDC连接器开始公测
查看详情
2023-08-21 新功能/规格
CDAS支持新增表后的有状态重启
查看详情
2023-08-21 新功能/规格
双流Join支持不同流的State TTL分别设置
查看详情
2023-08-21 新功能/规格
新增OceanBase连接器
查看详情
2023-08-21 新功能/规格
SLS连接器支持查询下推
查看详情
2023-08-21 新功能/规格
SLS Catalog支持结果表
查看详情
2023-08-21 新功能/规格
ADB PostgreSQL连接器支持ADB PostgreSQL 7.0版本
查看详情
2023-08-21 新功能/规格
Tair连接器支持更多的数据类型写入
查看详情
2023-08-21 其他
修复MySQL源表读取PolarDB MySQL时出现的问题
查看详情
2023-10-23 新功能/规格
优化自动调优能力
查看详情
2023-10-23 新功能/规格
支持SQL数据血缘能力
查看详情
2023-10-23 新功能/规格
资源动态更新
查看详情
2023-10-23 新功能/规格
支持RAM角色、资源目录成员、云SSO用户登录鉴权
查看详情
2023-10-23 功能优化
MaxCompute连接器优化
查看详情
2023-10-23 功能优化
MySQL Catalog支持优化
查看详情
2023-10-23 功能优化
StarRocks连接器功能增强
查看详情
2023-10-23 功能优化
Hologres结果表支持使用Date类型做分区键
查看详情
2023-10-23 功能优化
RocketMQ连接器功能增强
查看详情
2023-11-27 功能优化
MySQL Catalog功能增强
查看详情
2023-12-07 新功能/规格
新增管理资源队列
查看详情
2023-12-07 新功能/规格
任务编排(公测)
查看详情
2023-12-07 新功能/规格
查询脚本支持Call和DDL、DQL、DML语法。
查看详情
2024-01-04 功能优化
优化MySQL CDC
查看详情
2024-01-04 功能优化
MongoDB连接器功能优化
查看详情
2024-01-04 新功能/规格
支持MongoDB Catalog
查看详情
2024-01-04 功能优化
Hologres连接器增强
查看详情
2024-03-13 新功能/规格
同城高可用
查看详情
2024-03-13 新功能/规格
免费监控服务
查看详情
2024-04-01 功能优化
Paimon支持能力提升
查看详情
2024-05-06 新功能/规格
支持配置并使用作业变量
查看详情
2024-05-06 功能优化
ARMS监控告警功能优化
查看详情
2024-05-06 新功能/规格
使用UI创建SLS和StarRocks Catal
查看详情
2024-05-29 新功能/规格
全托管VVR 8.0.7版本发布
查看详情
2024-05-29 功能优化
权限管理功能优化
查看详情
2024-05-29 功能优化
SQL作业有状态启动时状态兼容性检测行为优化
查看详情
2024-05-29 新功能/规格
支持算子粒度的TTL设置
查看详情
2024-05-29 功能优化
MySQL CDC连接器能力增强
查看详情
2024-07-22 新功能/规格
全托管存储公测发布
查看详情
2024-07-22 新功能/规格
发布VVR 8.0.8引擎
查看详情
2024-09-11 新功能/规格
基于 Flink CDC 3.0 的数据摄入模块
查看详情
2024-09-11 新功能/规格
对接DLF 2.0
查看详情
2024-11-21 新功能/规格
实时计算Flink支持混合计费模式
查看详情
2024-11-21 新功能/规格
支持SelectDB连接器
查看详情
2024-12-20 新功能/规格
物化表
查看详情
查看全部日志

帮助文档