什么是消息演练
定位故障根源：经过消息演练之后，积累了消息系统的处理经验，对于未来的系统诊断定位有参考和提升作用。消息的演练场景 消息服务通常是由不同的模块组成。例如，RocketMQ分为生产者Producer、消费者Consumer、服务集群Broker和注册中心...
产品功能
消息队列分布式事务 在多次调用消息系统的场景中，通过 GTS，应用可轻松具备消息事务的处理能力。混合的分布式事务 GTS 可将各个资源加入事务范畴，实现同时跨服务、数据库、跨消息系统的事务处理能力。多种事务模式 提供了标准事务模式、...
构建基于CloudFlow的弹性高可用音视频处理系统
在音视频系统中，音视频转码是比较消耗计算力的一个子系统，您可以通过 函数计算 和 云工作流 构建弹性高可用的Serverless音视频处理系统。本文会从工程效率、运维、性能和成本方面介绍Serverless音视频处理系统和传统方案的差异。同时介绍...
构建基于Serverless架构的弹性高可用音视频处理系统
在音视频系统中，音视频转码是比较消耗计算力的一个子系统，您可以通过 函数计算 和 Serverless 工作流 构建弹性高可用的Serverless音视频处理系统。本文会从工程效率、运维、性能和成本方面介绍Serverless音视频处理系统和传统方案的差异...
使用OpenAPI示例
说明 媒体处理的系统权限策略如下：AliyunMTSFullAccess：管理媒体转码服务（MTS）的权限。AliyunMTSPlayerAuth：使用媒体转码服务（MTS）播放器的权限。关于如何创建自定义权限，请参见 授权信息。单击 确定，完成授权操作。凭证 在创建...
应用场景
（最终支付中心与下游系统数据一致）下游系统接收消息队列的支付成功的消息。下游系统处理相关业务逻辑。（最终支付中心与下游系统数据一致）分布式事务消息的更多详细内容请参见 消息类型。削峰填谷 流量削峰也是消息队列的常用场景，一般...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
查看消息
无影云电脑 中的消息中心主要展示云电脑状态变化、规格调整、策略更改等管理和使用云电脑时触发的变动相关的通知。您可在消息中心对消息进行查阅和管理，本文以V6.3.1版本的 Windows客户端 连接云电脑为例，为您介绍在云电脑内如何查看和...
仪表盘
20_ms le_50_ms le_200_ms le_500_ms le_overflow uid instance_id topic client_id invocation_status 消费者Metrics指标 Metrics类型 Metrics name 单位 指标说明 Label Histogram rocketmq_process_time ms PushConsumer的消息处理耗时...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
仪表盘
堆积消息量（已就绪消息+处理中消息）top20 GroupIDs 统计堆积的消息量最多的前20个Group。单位：条。处理中消息量 top20 GroupIDs 统计处理中的消息量最多的前20个Group。单位：条。消费处理耗时 top20 GroupIDs 统计消费处理耗时最长的前...
内容分割
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
内容映射
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
动态路由
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
主题使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
应用场景
批处理系统 很多行业的批处理系统中通常会有大量批处理操作，包含多张大表关联的复杂计算，并且涉及到大量的数据更新。批处理意味着每一次处理的数据量很大，而且有很多张大表要做关联，经常要做一些比较复杂的查询，并且更新量也比较大，...
订阅消息
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
日志管理概述
消息服务MNS 的日志管理功能将您的消息操作日志推送到指定LoggingBucket中。您在控制台上配置将日志推送到 日志服务 SLS（Simple Log Service），然后开启该地域队列或主题的日志管理功能，消息服务MNS 将自动推送该队列或主题消息的操作...
日志字段详情
MessageId 消息的MessageId，标识本次操作处理的消息。QueueName 本次操作对应的队列名称。AccountId 本次操作对应队列的账号。RemoteAddress 发起该操作的客户端地址。NextVisibleTime 该操作执行完成后，这条消息的下次可见时间。...
通过ARMS告警大盘提高告警处理效率
背景信息 企业在处理系统告警时，经常会遇到以下痛点：如何查看过去一段时间系统发生了哪些告警，哪类告警占比较高。告警配置没有收敛，多人在多个系统配置了多个告警。如何只查看我关心的告警以及对应的处理情况。制定了值班机制，无法...
Exactly-Once投递语义
什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次，即使生产端重试消息发送导致某消息重复投递，该消息在消费端也只被消费一次。Exactly-Once语义是消息系统和流式计算系统中消息流转的最...
捷旅假期
本文以捷旅假期为例，介绍如何通过 函数计算、云消息队列 RocketMQ 版 及对象存储等云服务，处理瞬时并发消息等问题。客户介绍 深圳市捷旅国际旅行社有限公司（简称“深捷旅”），自2001年成立以来专注于酒店行业的客房分销业务以及酒店...
Dashboard
{tenant_userid,instanceId,vHost,queueName} Consumer Metrics Type Metrics Name 单位 指标说明 Label gauge rabbitmq_consumer_acked_process_time_avg count 返回响应结果的消息的平均处理耗时。{tenant_userid,instanceId,vHost,...
接口和参数说明
messageListener 消息订阅回调，在回调中处理订阅的消息。设备上下线事件接口 接口名称：subscribeStatus 类名称：com.alibaba.mqtt.server.ServerConsumer 表 3.设备上下线事件接口参数 参数 说明 mqttGroupId 您在 云消息队列 MQTT 版 ...
Spring集成
spring.rabbitmq.listener.simple.prefetch 一个消费者最多可处理的未被确认（Ack）的消息数量（等同于客户端调用 Basic.qos 设置QoS值），如果有事务的话，必须大于等于transaction数量。spring.rabbitmq.listener.simple.transaction-...
重置消费位点
您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。前提条件 已停止所有Consumer客户端（云消息队列 Kafka 版 不支持在线重置消费位点）。重要 在停止Consumer客户端后，需要经过 ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG 配置的...
ECS系统事件汇总
您可以通过系统事件获取ECS资源的风险和异常信息，例如 某一实例到期、实例因底层升级需迁移或因系统维护重启了某一实例等，然后及时响应和处理系统事件，避免因ECS资源可用性或性能受损而影响业务。本文汇总了云服务器ECS支持的系统事件...
应用场景
事务消息处理 此时，需要利用 云消息队列 RocketMQ 版 所提供的事务消息来实现系统间的状态数据一致性。流程说明如下：注册系统向 云消息队列 RocketMQ 版 发送半事务消息。1.1 半事务消息发送成功，进入2。1.2 半事务消息发送失败，注册...
应用场景
前端的监控系统和大数据处理系统会利用 TSDB 的数据查询和计算分析能力进行业务监控和分析结果的实时展现。电力化工及工业制造监控分析 传统电力化工以及工业制造行业需要通过实时的监控系统进行设备状态检测，故障发现以及业务趋势分析。...
音视频弹性处理
本文介绍如何通过 Serverless 工作流、函数计算、文件存储、对象存储、及日志服务的组合方案，部署一个高弹性高可用的音视频处理系统。应用场景 有大量的视频需要上传。上传的视频需要及时处理去适配各种终端及网络条件。可以在短时间内...
告警功能配置及使用
告警功能配置 以下为白屏化配置告警通道的操作：告警通道选择 进入 系统管理-消息通道 页面，目前提供钉钉机器人以及邮件两种告警方式进行配置。配置钉钉机器人/邮件告警 钉钉机器人告警 进入配置页面，您需要输入机器人名称、Webhook以及...
云产品流转概述
一条消息处理后可以写入多个云产品，写入云产品限制请参见下一条：写入云产品消息量。对于被限流的消息，系统会自动重试处理，多次重试失败的数据会被丢弃。公共实例：1,000 TPS 企业版实例：查看实例的可用资源 写入云产品消息量 公共实例...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
主题（Topic）
行为约束 消息类型强制校验 云消息队列 RocketMQ 版 5.x版本将消息类型拆分到主题中进行独立运维和处理，因此系统会对发送的消息类型和主题定的消息类型进行强制校验，若校验不通过，则消息发送请求会被拒绝，并返回类型不匹配异常。...
新零售电子价签解决方案（MQTT）
电子价签管控服务通过接收 云消息队列 RocketMQ 版 消息，处理分析当前系统中在线的价签节点的状态，并将数据记录到SLS。更新屏显 电子价签管控服务发送改价的 云消息队列 RocketMQ 版 消息，触发改价操作。MQTT服务端会路由该 云消息队列 ...
事件管理
其次通过流转规则将系统内接受的告警信息按影响的服务/应用进行分类，可按告警信息字段设置触发事件规则，同时将自动按预先设置的流程将事件分派至对应的处理人或组。事件的处理与解决：事件处理人接受事件，并查看相应的告警详细信息，...
产品架构
即宽表/时序中的部分字段通过内部的数据链路自动同步搜索引擎，而数据的模型及读写访问对用户保持统一，用户无需关心搜索引擎的存在，跨引擎之间的数据关联、一致性、查询聚合、生命周期等工作全部由系统内部协同处理，用简单透明的方式...
关于WhatsApp营销模板调控的通知
系统将弃用剩余的暂停发送的消息，并触发Messages Webhooks，其中包含"status":"failed"和"code":"132015。重要 模板调控由Meta发起，从发送消息开始，如果60分钟内当前营销模板未收到足够的反馈将其模板质量更改为高质量或低质量，则系统...
消费端挂载NFS是否会影响消费速度？
问题现象 消费端在消费消息的主线程里同步将拉取的消息存储在NFS，导致消费端处理消息的速度变慢，阻塞消息处理。可能原因 NFS本身速度就不太理想。NFS是网络共享存储，虽然有多机器共享访问的能力优势，但多台机器访问是争抢的，消费者...
订阅关系（Subscription）
定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。通过配置订阅关系，...
- 产品推荐
- 这些文档可能帮助您