概述
概念介绍—数据处理（Transform）数据处理是消息集成的重要功能组件，可以在配置消息流入或消息流出任务的同时选择性配置数据处理能力。依托 事件总线EventBridge 强大的自研数据处理及灵活的函数计算自定义能力，提供7种匹配模式（指定值...
概述
概念介绍—数据处理（Transform）数据处理是消息集成的重要功能组件，可以在配置消息流入或消息流出任务的同时选择性配置数据处理能力。依托 事件总线EventBridge 强大的自研数据处理及灵活的函数计算自定义能力，提供7种匹配模式（指定值...
概述
概念介绍—数据处理（Transform）数据处理是消息集成的重要功能组件，可以在配置消息流入或消息流出任务的同时选择性配置数据处理能力。依托 事件总线EventBridge 强大的自研数据处理及灵活的函数计算自定义能力，提供7种匹配模式（指定值...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。echo"DeleteMessage Failed:".$e;return;} 步骤五：删除队列 Sample里最后会删除这个测试队列。try {$this->client->deleteQueue($...
主题使用手册
消息已经处理完成，从队列里删除这条消息。queue->deleteMessage($receiptHandle);echo"DeleteMessage Succeed!break;} catch(MessageNotExistException$e){ echo"No New Message;} catch(MnsException$e){ echo"Process Failed:".$e;} ...
事件流概述
应用场景 流式ETL处理 事件流作为更轻量、实时（real-time）端到端的流式事件通道，提供轻量流式数据的过滤和转换的能力，在不同的数据仓库之间、数据处理程序之间、数据分析和处理系统之间进行数据同步，连接不同的系统与服务。...
创建倍速转码任务
背景信息 媒体处理提供离线转码服务，必须获取到完整的视频文件后才可以开始转码任务，对视频文件的转码处理需要一定耗时，是一种非实时的处理服务。常见的视频转码流程如下图所示：转码耗时的影响因素 受视频时长、文件大小、转码参数复杂...
产品功能
消息队列分布式事务 在多次调用消息系统的场景中，通过 GTS，应用可轻松具备消息事务的处理能力。混合的分布式事务 GTS 可将各个资源加入事务范畴，实现同时跨服务、数据库、跨消息系统的事务处理能力。多种事务模式 提供了标准事务模式、...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
下行消息
进入CMNS-下行消息页面 点击“消息发送”按钮 在“应用”下拉框选择您需要发送消息的客户端应用 在“类型”单选框选择您需要发送消息的类型 透传消息是消息直接发送至客户端应用，由客户端应用决定消息处理 通知消息是指消息显示在系统通知...
简介
使用 系统运维管理 SDK之前，您需要：了解并开通阿里云 系统运维管理，详情请参见 什么是系统运维管理。创建AccessKey。系统运维管理 支持以下主流语言的SDK包。语言 参考文档 Python 简介 Java 简介 Go 简介 C#简介 相关链接 阿里云开发者...
主题使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
配置流控规则
系统需处理的请求是随机不可控的，而系统的处理能力是有限的，因此就需要根据系统的处理能力对流量进行控制。功能入口 登录 MSE治理中心控制台，并在顶部菜单栏选择地域。在左侧导航栏，选择 治理中心>应用治理。在 应用列表 页面，单击...
设置消息通知
设置单任务消息通知 设置工作流消息通知 步骤一、开通消息服务MNS 重要 媒体处理的消息通知是绑定MNS产品推送的，媒体处理侧不产生费用，但是会产生MNS费用。计费详情请参见 价格说明。开通消息服务MNS并授权。详细操作请参见 开通消息服务...
HaaS EDU场景式应用整体介绍
2.1 首页系统信息屏 这是系统启动后的默认屏幕，包含了许多的知识点：OLED显示屏驱动与显示 系统版本获取 系统联网与IP地址获取 网络时间获取 Wi-Fi状态获取 蓝牙连接 电池电量获取 通过本案例的学习，能完整学习到AliOS Things操作系统...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
性能测试
另一种就是压测流量单独打标（如单独定义的Header），然后业务处理过程中识别这个标并传递下去，包括异步消息和中间件，最终落到数据库的影子表或者影子库中。此外，生产环境的压测尽量在业务低峰期进行从而避免影响生产的业务，无论上述哪...
仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
Exactly-Once投递语义
Exactly-Once语义是消息系统和流式计算系统中消息流转的最理想状态，但是在业界并没有太多理想的实现。因为真正意义上的Exactly-Once依赖消息系统的服务端、消息系统的客户端和用户消费逻辑这三者状态的协调。例如，当您的消费端完成一条...
监控报警
监控项说明 说明 消息堆积量、消息处理延迟时间、已就绪消息量、已就绪消息排队时间等消息堆积场景相关的指标的详细说明，请参见 堆积场景指标说明。指标分类 监控指标 MetricName 统计方法 单位 Instance 实例API调用TPS InstanceApi...
查看消息
系统消息：展示当前云电脑的系统信息，包括镜像版本更新的配置消息、执行消息和执行结果等。协同消息：展示在当前云电脑远程协助时触发的实时结果提醒。重要 各客户端和硬件终端是否支持在云电脑查看消息，请参见 支持查看消息的客户端。...
发现和排查实例问题
系统事件中会同时提供应对措施、事件周期等信息，建议您及时处理系统事件，避免实例重启、停止等问题影响您的业务。更多信息，请参见 ECS系统事件概述。通知包年包月实例到期的系统事件示例如下图所示。请确保在 消息中心 开启接收ECS到期...
消息队列
任务A作为生产者循环向消息队列发送消息，任务B作为消费者循环从消息队列接收消息，一般情况下，消费者处理数据是要花费很长时间，所以会导致消息产生的速度大于消息处理的速度，使得消息队列溢出。所以可以通过调整任务B优先级大于任务A来...
监控报警
监控项 单位 MetricName Dimensions Statistics 消息堆积量（Group）count ConsumerLag userId、instanceId、groupId Sum 消息处理延迟时间（GroupId）millisecond ConsumerLagLatencyPerGid userId、instanceId、groupId Maximum 消息处理...
内容富化
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
应用场景
前端的监控系统和大数据处理系统会利用 TSDB 的数据查询和计算分析能力进行业务监控和分析结果的实时展现。电力化工及工业制造监控分析 传统电力化工以及工业制造行业需要通过实时的监控系统进行设备状态检测，故障发现以及业务趋势分析。...
使用云消息队列 Kafka 版时出现消息堆积
消息堆积的处理方式 经过上述判断，确认消息的确存在堆积情况时，建议打印消息的消费耗时，或者根据堆栈信息查看线程执行情况。根据以下方案适当调整以加快消息的消费速度，避免出现消息堆积。增加Consumer实例个数。可以在进程内直接增加...
镜像安全扫描介绍
镜像安全扫描功能为容器镜像提供了全面的安全检测和管理能力，可以帮助您发现镜像中存在的高危系统漏洞、应用漏洞、恶意样本、配置风险和敏感数据；针对镜像系统漏洞提供了漏洞修复方案，以便您及时解决安全隐患。通过使用该功能，您可以...
基本概念
订阅关系（Subscription）订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。...
通过可观测性能力进行故障处理最佳实践
消息处理成功率=消息处理成功次数/消息处理失败次数+成功次数。查询方式，请查看 仪表盘 中，消费者指标下的统计面板。根据业务逻辑或指标的变化趋势定位具体原因，例如消息处理耗时变长，则可以查看消费者服务的内存、CPU等是否过载；或...
使用OpenAPI示例
说明 媒体处理的系统权限策略如下：AliyunMTSFullAccess：管理媒体转码服务（MTS）的权限。AliyunMTSPlayerAuth：使用媒体转码服务（MTS）播放器的权限。关于如何创建自定义权限，请参见 授权信息。单击 确定，完成授权操作。凭证 在创建...
消费者分组（ConsumerGroup）
定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者不同，消费者分组并不是运行实体，而是一个逻辑资源。在 云消息队列 RocketMQ 版 中，通过消费者分组内初始化多个消费者实现消费...
查看消费者状态
应用场景 消费者状态信息包括在线状态、订阅关系、消费TPS、消息堆积量和线程堆栈信息等，经常被应用于以下故障排查场景：故障场景 现象 处理建议 订阅关系不一致 在 Group 详情 页面，看到Group ID的 订阅关系 显示 订阅关系不一致，请...
消息（Message）
对于定时消息和事务消息，消息保存时间指的是消息生效对消费方可见的服务端系统时间。取值：由服务端系统填充。说明：客户端系统时钟和服务端系统时钟可能存在偏差，消息保留时间是以服务端系统时钟为准。消费重试次数 定义：消息消费失败...
查看告警发送历史
您可以查看告警的发送历史并对告警进行认领和处理。本文介绍如何在 SAE 控制台查看告警发送详情并管理告警。前提条件 已创建并启用告警规则。具体操作，请参见 应用监控告警规则。查看告警详情 登录 SAE控制台。在左侧导航栏，选择 应用...
授权信息
本文为您介绍 媒体处理（MPS）为RAM权限策略定义的操作（Action）、资源（Resource）和条件（Condition）。媒体处理（MPS）的RAM代码（RamCode）为 mts,mts-inner，支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持JSON格式，其...
接口和参数说明
本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ，其中 {SDK...
补丁管理原理介绍
Windows Windows 系统补丁更新原理 在Windows操作系统上，补丁管理会检查到 Windows实例中Windows Update自动更新相关配置说明 可用更新列表，查找适用于系统版本的补丁更新信息。当扫描或安装补丁更新时，补丁管理会自动剔除已被其补丁...
事务消息
半事务消息：暂不能投递的消息，生产者已经成功地将消息发送到了 云消息队列 RocketMQ 版 服务端，但是 云消息队列 RocketMQ 版 服务端未收到生产者对该消息的二次确认，此时该消息被标记成“暂不能投递”状态，处于该种状态下的消息即半...
Dashboard
借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RabbitMQ 版 为企业版和铂金版实例提供Dashboard大盘功能。通过该功能，您可以查看企业版和铂金版实例、Vhost、Queue和Exchange的各种指标数据，帮助您及时...
- 产品推荐
- 这些文档可能帮助您