EventBridge事件调度
MQTT调度 云消息队列 MQTT 版 作为事件源通过 事件总线 与 云工作流 调度集成后，通过云消息队列 MQTT 版调度能够触发关联工作流执行，通过 云工作流 可以对发布到 云消息队列 MQTT 版 的消息进行自定义处理。本文介绍如何在控制台创建MQTT...
工作队列
更正文档 概述 在操作系统中，如果我们需要进行一项工作处理，往往需要创建一个任务来加入内核的调度队列。一个任务对应一个处理函数，如果要进行不同的事务处理，则需要创建多个不同的任务。任务作为CPU调度的基本单元，任务数量越大，则...
查询流量调度策略的信息
ID（即未指定 TrafficQosPolicyId 参数的值），则接口会根据 TransitRouterId、TransitRouterAttachmentId、TrafficQosPolicyName 和 TrafficQosPolicyDescription 参数的值仅返回流量调度策略的信息，并不会查询流量调度策略下队列的信息...
使用流量调度功能控制各类流量的跨地域带宽
每个流量调度策略默认包含一个默认队列，在您使用流量调度功能的过程中，对于未符合流分类规则的流量以及符合流分类规则但未被划分队列的流量，均会被系统自动划分至流量调度策略的默认队列，默认队列占用跨地域连接的剩余带宽。...
定时/延时消息
此时服务端会等待消费者完成消费并提交消费结果，如果一定时间后没有收到消费者的响应，云消息队列 RocketMQ 版 会对消息进行重试处理。具体信息，请参见 消费重试。消费提交 消费者完成消费处理，并向服务端提交消费结果，服务端标记当前...
YARN调度器
核心调度未考虑整个集群的资源布局，也不支持Node Labels（分区调度）、Node Attributes（节点打标调度）、Placement Constraints（放置约束）等调度特性。CapacityScheduler：是Apache Hadoop社区、HDP（Hortonworks Data Platform）及...
AI负载调度
本文介绍弹性资源调度、AI任务调度、异构资源调度和任务队列调度，帮助用户提升集群的资源利用率和作业运行效率。弹性调度 ACK为不同弹性资源提供了混合调度的能力。功能 描述 参考文档 弹性调度 阿里云提供了不同种类的弹性资源，如ECS和...
查询流量调度策略队列的信息
调用ListCenInterRegionTrafficQosQueues接口查询流量调度策略队列的信息。接口说明 调用接口时请确保 TransitRouterId 或 TrafficQosPolicyId 或 TrafficQosQueueId 参数至少输入一个。调用接口时请确保输入的参数值无误。如果您输入的...
设置基线优先级与YARN队列优先级的映射关系
若您用于运行EMR任务的独享调度资源组于该日期之前购买，请先联系平台技术人员进行资源组升级，若资源组未升级，配置的映射关系将不生效，即YARN队列优先级最终仍由节点本身配置的YARN队列优先级决定。映射关系配置入口 进入运维中心页面。...
创建流量调度策略下队列的配置
如果您需要对不同类型和优先级的网络流量进行细致管理，以确保关键业务流量的性能并遵守服务级别协议，您可以调用CreateCenInterRegionTrafficQosQueue接口创建流量调度策略下队列的配置。接口说明 CreateCenInterRegionTrafficQosQueue ...
设置调度器参数
调度器是集群上调度作业的软件，负责分发作业、处理作业优先级、按需分配计算节点资源（如vCPU、内存、节点个数）等。您可以根据作业大小，预估使用的节点资源和作业完成时间，设置集群的调度器参数，从而提高资源使用率。本文介绍如何在...
删除流量调度策略下的队列
调用DeleteCenInterRegionTrafficQosQueue接口删除流量调度策略下的队列。接口说明 默认队列不支持删除。DeleteCenInterRegionTrafficQosQueue 接口属于异步接口，即系统会先返回一个 RequestId，但该队列并未删除完成，系统后台的删除任务...
YARN指标
Capacity NumPendingApplications yarn_resourcemanager_queue_numPendingApplications ResourceManager Capacity调度器特定队列阻塞调度的application个数。Capacity NumContainers yarn_resourcemanager_queue_numContainers ...
Dashboard
如果未创建服务关联角色，云消息队列 RabbitMQ 版 会为您自动创建一个服务关联角色，以便您使用 云消息队列 RabbitMQ 版 Dashboard功能。如果已创建服务关联角色，云消息队列 RabbitMQ 版 不会重复创建。关于服务关联角色的更多信息，请...
TCP协议客户端大版本发布
处理中消息量：统计在消费者客户端正在处理但客户端还未返回消费成功响应的消息的数量。已就绪消息量：统计在 云消息队列 RocketMQ 版 服务端已就绪，可以被消费者消费的消息数量。指标反映还未被消费者开始处理的消息规模。已就绪消息排队...
仪表盘
处理中消息量 统计在消费者客户端正在处理但客户端还未返回消费成功响应的消息的数量。单位：条。已就绪消息量 统计在 云消息队列 RocketMQ 版 服务端已就绪，可以被消费者消费的消息数量。指标反映还未被消费者开始处理的消息规模。单位：...
ack-kube-queue
ack-kube-queue是云原生AI套件提供的任务队列组件，主要围绕着Kube Queue任务队列，结合调度器和Quota系统，提供队列管理、优先级调度、使用弹性配额等功能，帮助您优化Kubernetes中的AI/ML工作负载和批处理工作负载的管理效率和调度性能。...
开源对比
消息重试机制 消息消费超过一定时间未响应会重新投递。超时时间和重试次数的详细解释，请参见 消息超时和重试机制。无消息重试机制。无法跳过有问题消息的消费处理，无法处理新生产的消息，从而会导致消息大量堆积引起内存问题，导致消息...
Node Labels特性使用
目前只有Capacity Scheduler调度器支持Node Labels分区调度，您可以通过调度器配置或者计算引擎node-label-expression参数让队列上的任务容器调度到队列可访问的分区上。更详细的Node Labels特性说明，请参见 YARN Node Labels。使用限制 ...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
kafka.max.in.flight.requests.per.connection 是 限制客户端在单个连接上能够发送的未响应请求的个数。设置此值是 1 表示Broker在响应请求之前客户端不能再向同一个Broker发送请求。kafka.retries 是 消息发送失败时，是否重复发送。设置...
查看任务执行记录
取值如下：未执行 执行中 已执行 已取消 操作步骤 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击 任务执行记录 页签。在 任务执行记录 页签下方...
应用场景
本文为您介绍 云消息队列 RocketMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如，针对一家互联网电商企业，其业务涉及广泛，如注册、订单、库存、物流等；同时，也会涉及许多业务峰值时刻，如秒杀活动...
创建EMR Spark节点
DataLake集群/自定义集群：EMR on ECS 高级参数 配置说明“queue”提交作业的调度队列，默认为default队列。如果您在注册EMR集群至DataWorks工作空间时，配置了工作空间级的 YARN资源队列：如果 勾选 了 全局配置是否优先 为 是，则实际...
创建跨地域流量调度策略
CreateCenInterRegionTrafficQosPolicy 接口属于异步接口，即系统会先返回一个流量调度策略 ID，但该流量调度策略并未创建完成，系统后台的创建任务仍在进行。您可以调用 ListCenInterRegionTrafficQosPolicies 接口查询流量调度策略的状态...
基本概念
消息堆积 生产者已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于消费者的消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。事务消息 事务...
什么是云消息队列 RocketMQ 版？
下图以创建订单为例对比传统事务和 云消息队列 RocketMQ 版 事务消息的方案：分布式定时/延时调度 云消息队列 RocketMQ 版 提供精确度到秒级的分布式 定时消息 能力，可广泛应用于订单超时中心处理、分布式延时调度系统等场景。使用 云消息...
顺序消息
此时服务端会等待消费者完成消费并提交消费结果，如果一定时间后没有收到消费者的响应，云消息队列 RocketMQ 版 会对消息进行重试处理。具体信息，请参见 消费重试。消费提交 消费者完成消费处理，并向服务端提交消费结果，服务端标记当前...
Connection和Channel
大量的Connection会对 云消息队列 RabbitMQ 版 造成巨大压力，甚至触发 云消息队列 RabbitMQ 版 SYN洪水攻击防护，导致 云消息队列 RabbitMQ 版 无响应，进而影响您的业务。Channel Channel是物理TCP连接中的虚拟连接。当应用通过...
接口和参数说明
本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ，其中 {SDK...
消费重试
消费者出现异常，云消息队列 RocketMQ 版 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的...
消息重试
云消息队列 RocketMQ 版 支持消息重试功能，即Consumer消费某条消息失败或消费超时，云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
实例生命周期管理
预付费（包年包月）实例 预付费（包年包月）实例生命周期各阶段状态 部署实例（1→2）：当购买了 云消息队列 Kafka 版 实例后，实例处于 未部署 状态，若您需要使用该实例，请先在控制台上完成部署，部署成功后，实例状态切换为 服务中。...
消息检索
测试发送消息 开通消息检索后，您可以向 云消息队列 Kafka 版 的数据源Topic发送消息，调度任务和测试消息检索是否创建成功。在 消息检索 页面，找到需要测试的目标Topic，根据任务状态在对应位置操作。如果任务处于 运行中 和 已暂停 状态...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
事务消息
此时服务端会等待消费者完成消费并提交消费结果，如果一定时间后没有收到消费者的响应，云消息队列 RocketMQ 版 会对消息进行重试处理。具体信息，请参见 消费重试。消费提交 消费者完成消费处理，并向服务端提交消费结果，服务端标记当前...
VPC接入
步骤三：部署实例 在 云消息队列 Kafka 版 控制台 的 实例列表 页面，找到 未部署 的实例，单击右侧 操作 列的 部署。在 部署实例 面板，配置以下参数，然后单击 确定。V2系列 实例部署说明 参数 说明 示例 VPC ID 选择 步骤二：获取VPC...
公网和VPC接入
步骤三：部署实例 在 云消息队列 Kafka 版 控制台 的 实例列表 页面，找到 未部署 的实例，单击右侧 操作 列的 部署。在 部署实例 面板，配置以下参数，然后单击 确定。V2系列 实例部署说明 参数 说明 示例 VPC ID 选择 步骤二：获取VPC...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。更多信息，请参见 VPC...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
产品功能
通过SchedulerX可以管理定时调度任务、查询任务执行记录和运行日志。本文介绍SchedulerX调度、执行和运维三个方面的功能。定时调度 Crontab 支持Unix Crontab表达式，不支持秒级别调度。更多信息，请参见 Cron。Fixed rate Crontab必须被60...
- 产品推荐
- 这些文档可能帮助您