实时研发基本流程概述
以下为数据流向的示意图：订单系统MySQL的数据通过Ververica Flink任务进行实时计算，实时汇总各产品类型的销售数量并写入另一个用于OLAP分析的MySQL数据库。通过BI工具（Quick BI等）读取MySQL中的数据，进行可视化分析。流程指引 使用...
实时研发基本流程概述
以下为数据流向的示意图：订单系统MySQL的数据通过Ververica Flink任务进行实时计算，实时汇总各产品类型的销售数量并写入另一个用于OLAP分析的MySQL数据库。通过BI工具（Quick BI等）读取MySQL中的数据，进行可视化分析。流程指引 使用...
查看及管理实时模板引用
实时模板 引用是指实时任务基于 实时模板进行创建，创建成功的实时任务即为该实时模板的引用。本文为您介绍如何查看及管理实时模板的引用对象。实时模板引用 对象入口 请参见 数据开发入口，进入数据 开发 页面。在数据 开发 页面，按照下...
查看及管理实时模板引用
实时模板 引用是指实时任务基于 实时模板进行创建，创建成功的实时任务即为该实时模板的引用。本文为您介绍如何查看及管理实时模板的引用对象。实时模板引用 对象入口 请参见 数据开发入口，进入数据 开发 页面。在数据 开发 页面，按照下...
功能特性
链路列表 散点图 散点图页面以时间为横轴，耗时指标为纵轴，显示调用链的耗时分布情况。将鼠标悬浮于散点上，可以显示散点对应的调用链的基本信息。单击散点可以查看调用链对应的调用详情。散点图 全链路聚合 调用链分析对查询到的Span可以...
API概览
日志管理 API 标题 API概述 实时日志 实时日志 DeleteRealTimeLogLogstore 删除实时日志推送的Logstore 调用DeleteRealTimeLogLogstore删除实时日志推送的Logstore。CreateRealTimeLogDelivery 创建实时日志投递 调用...
实时大盘
实时大盘实时更新并展示最近一小时或今天App异常（崩溃、ANR）的关键指标数据。实时大盘用于在发布版本、重要活动等关键时间点实时监控App。前提条件 已接入数据。具体操作，请参见 通过Android SDK接入数据 或 通过iOS SDK接入数据。操作...
查看实时同步任务详情
实时同步任务是由实时数据同步时发起的任务，运维监控支持查看...在实时任务列表中，单击目标实时同步任务 操作 列的 详情，查看监控详情，包括当前实例的实例属性和运行日志，接入数据量趋势图的接入数据量、输出数据统计、失败数据统计。
CREATE DATABASE AS（CDAS）语句
CDAS支持整库级别的表结构和数据的实时同步，还支持表结构变更的同步。本文为您介绍CREATE DATABASE AS（CDAS）的使用方法，并提供了多种使用场景下的示例。背景信息 CDAS是 CTAS 语法的一个语法糖，用于实现整库同步、多表同步的功能。...
搭建基础环境
创建成功后应用如下图。步骤二：在RDS中，创建数据库账号和测试数据库 登录RDS控制台。鼠标左键双击RDS实例图标。单击 返回。单击 资源名称。创建数据库账号。在左侧导航栏，单击 账号管理。单击 创建账号。填写账号和密码信息。填写完成后...
卡片分析
单击左侧导航栏中的 实时发布>蚂蚁动态卡片>卡片分析，进入 卡片分析 页。该页面展示了蚂蚁动态卡片的新增用户数以及新增用户趋势图、活跃用户数以及活跃用户趋势图、卡片访问次数以及卡片访问次数趋势图、卡片点击次数以及卡片点击次数...
2023-10-23版本
查看血缘关系 支持资源动态更新 对作业并发度和部分Flink运行参数的修改，不再需要停止作业完成，您可以动态的修改这些参数。动态更新作业参数 提供SQL优化建议 SQL作业进行深度检查时，会返回SQL优化建议功能，自动输出SQL问题风险以及...
概述
动态配置 提供应用运行时动态修改配置的服务，提供动态配置的简便接入方式与集中化管理平台，可在管理平台维护动态配置元数据并推送值，可实时查看接入动态配置的客户端应用节点的内存值。限流熔断 提供对业务系统的限流服务，从而保证业务...
实时计算Blink产品公告（已停止新购）
本文为您介绍实时计算Blink产品的相关动态。公有云实时计算Blink产品进入产品收敛期，请下载查看PDF版 公有云实时计算Blink产品进入产品收敛期，Flink产品详情请参见 产品形态。实时计算Blink文档详情请单击 阿里云实时计算Blink独享模式...
查看作业性能
背景信息 您可以在 实时计算开发控制台，通过火焰图、内存动态与线程动态，查看运行中作业的Job Manager和运行Task Managers的性能，详情请参见下表。类别 详情 火焰图 CPU耗时：通常顶层占据宽度比较大的函数消耗的CPU比较多，表示该类...
开始监控除Java之外的应用
可观测链路 OpenTelemetry 版 具备分布式调用链追踪和汇总、应用性能实时汇总和分布式拓扑动态发现等能力，帮助您全方位监控应用。背景信息 可观测链路 OpenTelemetry 版 可以帮助开发者快速分析和诊断分布式应用架构下的性能瓶颈，提高微...
功能与优势
问题分析与诊断 动态修改作业的配置，无需启停即可对日志Level、火焰图是否开启等配置进行在线调整。对于反压、Job异常、TM失联等常见问题提供智能化诊断和快速日志定位分析，给出调优或者修改建议，并连动自动调优能力帮助您定位问题。高...
双流JOIN语句
区别为实时计算关联的是两张动态表，关联的结果也会动态更新，以保证最终结果和批处理结果一致。双流JOIN语法 tableReference[,tableReference]*|tableExpression[NATURAL|INNER][{ LEFT|RIGHT|FULL }[OUTER]]JOIN tableExpression...
API概览
实时处理 API 标题 API概述 实时媒体转码 实时媒体转码 CreateLiveTranscodeTemplate 创建实时媒体转码模版 调用CreateLiveTranscodeTemplate创建实时转码模板，便于提交实时转码任务。GetLiveTranscodeTemplate 获取单个实时媒体转码模版 ...
配置MaxCompute输出
实时同步写入MCompute表支持 时间自动分区 与 根据字段内容动态分区 两种分区方式 时间自动分区：根据_execute_time_字段将数据写入到对应时间分区中，详情请参见 实时同步字段格式,重要 您最少需要设置二级分区（月和年），最多支持设置五...
SmartMetrics常见问题
预测好的上下边界已经自动写入到Prometheus中，但Prometheus不会提前显示未来数据，而是根据实际时间自动获取对应数据，实时显示在大盘上。另外，配置告警后，指标真实值会自动与预测值进行对比。数据源为什么只支持选择Prometheus？目前...
Flink动态CEP快速入门
实时计算Flink版支持通过DataStream作业的方式运行支持规则动态更新的Flink CEP作业。本文结合实时营销中的反作弊场景，为您介绍如何基于Flink全托管快速构建一个动态加载最新规则来处理上游Kafka数据的Flink CEP作业。背景信息 在电商平台...
动态扩缩容与参数动态更新
动态更新Flink作业参数可以实现更快的参数配置生效，减少作业启停对业务的中断时间，方便进行TM动态扩缩容和系统检查点的排查。背景信息 传统的Flink参数更新方式需要重新启动作业，可能会出现业务中断、数据回追延迟和资源占用高峰等问题...
2022-09-19版本
作业操作授权 支持动态复杂事件处理（CEP）CEP是对实时数据流进行模式匹配的一种能力。本次发布的是在开源Flink CEP的能力基础上，支持了将作业规则外置于数据库使得其可以被动态加载生效的能力，接口为Datastream API。动态CEP中规则的...
查看并管理实时实例
DAG图支持可视化动态呈现该节点的上下游依赖关系，同时支持对上下游节点进行运维操作：区域 描述 ① 节点信息栏 展示当前选中节点的概要信息。您还可以单击 查看节点详情，查看更多节点信息。Ververica Flink实时引擎：包括节点详情、运行...
查看并管理实时实例
DAG图支持可视化动态呈现该节点的上下游依赖关系，同时支持对上下游节点进行运维操作：区域 描述 ① 节点信息栏 展示当前选中节点的概要信息。您还可以单击 查看节点详情，查看更多节点信息。Ververica Flink实时引擎：包括节点详情、运行...
动态分区管理
Hologres的动态分区功能无需预先设定所有分区信息，可依据创建分区表时配置的动态分区规则，自动创建并管理分区子表。同时，还支持将符合条件的分区数据迁移到低频存储设备，在保证查询性能的同时，有效降低存储费用。功能介绍 动态分区...
什么是可观测链路 OpenTelemetry 版
分布式拓扑动态发现：用户的所有分布式微服务应用和相关PaaS产品可以通过 可观测链路 OpenTelemetry 版 收集到分布式调用信息。多语言开发程序接入：基于OpenTracing标准，兼容开源社区，例如Jaeger、Zipkin。丰富的下游对接场景：收集的...
实时同步任务延迟解决方案
确认是否有写入动态分区频繁切换问题（uploader map size has reached uploaderMapMaximumSize）对于写入MaxCompute的实时同步任务，当分区方式选择根据字段内容动态分区时，要特别注意选择对应于MaxCompute表分区列的源端列，在实时同步...
什么是阿里云实时计算Flink版
阿里云实时计算Flink版是一套基于Apache Flink构建的⼀站式实时大数据分析平台，提供端到端亚秒级实时数据分析能力，并通过标准SQL降低业务开发门槛，助力企业向实时化、智能化大数据计算升级转型。产品概述 阿里云实时计算Flink版是一种全...
关注Hologres技术圈
点击 实时数仓Hologres 关注Hologres开发者社区，获取有关Hologres最新产品咨询、技术动态、视频教学、客户案例实践等内容。
产品介绍
阿里云推流SDK是基于阿里云强大内容分发网络和音视频实时通讯技术的直播客户端推流开发工具，为您提供简单易用的开放接口、网络自适应的流畅体验、多节点的低延迟优化、功能强大的实时美颜等音视频直播技术服务。本文介绍推流SDK产品简介、...
阿里云实时数仓产品Hologres的应用场景
Hologres兼容PostgreSQL生态，是新一代的 阿里云实时数仓产品，与大数据生态无缝连接，支持实时与离线数据，对接第三方BI工具，实现可视化分析业务。本文为您介绍基于Hologres核心功能的典型应用场景。Hologres的典型应用场景如下：搭建...
什么是实时数仓Hologres
Hologres是阿里巴巴自主研发的一站式实时数仓引擎（Real-Time Data Warehouse），支持海量数据实时写入、实时更新、实时加工、实时分析，支持标准SQL（兼容PostgreSQL协议和语法，支持大部分PostgreSQL函数），支持PB级数据多维分析（OLAP...
Kafka实时同步
本文为您介绍如何将Kafka数据实时同步至Hologres。背景信息 Kafka 是一款高吞吐量、高可扩展性的分布式消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等场景。Hologres与大数据生态无缝打通，您可以通过...
实时同步数据库的数据至Hologres
本文为您介绍如何通过DataWorks数据集成实时同步数据库中的数据至Hologres。前提条件 开通DataWorks，详情请参见 入门概述。开通Hologres实例并绑定至DataWorks工作空间，详情请参见 DataWorks快速入门。已开通云数据库。说明 跨地域是否...
技术支持
关于阿里云实时计算Flink版产品和服务的相关问题，您可以通过以下渠道寻求支持和解决。支持范围 类别 详情 支持的服务 负责实时计算控制台的使用、咨询服务、稳定性问题和产品缺陷问题处理。实时计算控制台功能主要包括：工作空间购买流程 ...
SLB替换方案上线
为了给您提供更好的体验和节约成本，2023年9月8日起实时计算Flink版SLB替换方案分地域逐步上线，预计9月11日全地域完成替换。该替换方案旨在提供更高效的网络连接，以取代原先的负载均衡SLB服务。您新购实时计算Flink版时，无需再单独开通...
数据同步概述
实时数仓Hologres是一款兼容PostgreSQL 11协议的实时数仓，与大数据生态无缝连接，支持高并发地实时写入，数据写入即可查，同时也支持离线数据的加速查询、实时数据和离线数据联邦分析，助力快速搭建企业级实时数仓。Hologres数据同步说明 ...
2024-04-01版本
该版本是基于Apache Flink 1.17.2的企业级Flink引擎，主要包含以下变更：在实时湖仓方面，本版本主要支持了将数据写入OSS-HDFS、并且支持通过CTAS和CDAS语句写入Paimon时，可以创建动态分桶的Paimon表。在连接器方面，本版本重点发布了针对...
- 产品推荐
- 这些文档可能帮助您