SetQueue-移动计算节点到指定队列
调用SetQueue移动计算节点到指定队列。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 ...
UpdateQueueConfig-更新队列资源组和计算节点实例信息
为集群中的队列更新资源组和计算节点实例的信息。接口说明 更新资源组后，如果您通过集群扩容新增节点，节点将会自动添加到新的资源组。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI ...
消息过滤
主题订阅添加消息过滤标签 本示例介绍通过设置订阅的标签值，将主题（TopicA）中标签值为tag-a的消息推送到队列（QueueB），实现消息过滤的功能。关于主题订阅的具体操作，请参见 创建订阅。在 创建订阅 面板 消息过滤标签 中填写主题...
消费者负载均衡
如上图所示，主题中的三个队列Queue1、Queue2、Queue3被分配给消费者分组中的两个消费者，每个队列只能分配给一个消费者消费，该示例中由于队列数大于消费者数，因此，消费者A2被分配了两个队列。若队列数小于消费者数量，可能会出现部分...
管理资源队列
每个工作空间都会默认包含dev_queue和root_queue两个队列，用于承载作业的运行。如果您有资源隔离和管理的需求，可以通过添加队列的方式实现。本文为您介绍队列的基本操作。前提条件 已创建工作空间，详情请参见 管理工作空间。添加队列 ...
CREATE QUEUE
语法 可使用 CREATE QUEUE 定义新队列：CREATE QUEUE name QUEUE TABLE queue_table_name[({ option_name option_value}[,.])]其中 option_name 和对应的 option_value 可以是：TYPE[normal_queue|exception_queue]RETRIES[INTEGER]...
云消息队列 RabbitMQ 版
queue 表 2.目标端消息队列RabbitMQ版参数配置 参数 说明 示例 地域 选择接收源端数据的目标实例所在的地域。华东1（杭州）实例ID 选择接收源端数据的目标 云消息队列 RabbitMQ 版 实例ID。amqp-cn-*03o002 Vhost 选择目标 云消息队列 ...
创建RabbitMQ Sink Connector
queue 消息路由规则（Routing Key）事件总线EventBridge 通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。当 目标类型 为 Exchange 时需要配置。部分事件$.data.key 消息体（body）事件总线EventBridge 通过JSONPath提取...
云消息队列 RabbitMQ 版
queue 表 2.目标端云消息队列 RocketMQ 版参数配置 参数 说明 示例 地域 接收 云消息队列 RocketMQ 版 消息的目标实例所在的地域。华东1（杭州）版本 选择目标端 云消息队列 RocketMQ 版 实例的版本。RocketMQ 4.x 实例ID 选择接收 云消息...
消息队列RabbitMQ版
queue 表 2.目标端消息队列RocketMQ版参数配置 参数 说明 示例 地域 接收 云消息队列 RocketMQ 版 消息的目标实例所在的地域。华东1（杭州）版本 选择目标端 云消息队列 RocketMQ 版 实例的版本。RocketMQ 4.x 实例ID 选择接收 云消息队列 ...
排他队列
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
路由到云消息队列 RabbitMQ 版
queue 消息路由规则（Routing Key）事件总线EventBridge 通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。当 目标类型 为 Exchange 时需要配置。部分事件$.data.key 消息体（body）事件总线EventBridge 通过JSONPath提取...
DATASOURCE:MNS:Queues
DATASOURCE:MNS:Queues类型用于查询指定阿里云账号下的所有队列（Queue）。语法 {"Type":"DATASOURCE:MNS:Queues","Properties":{"QueueName":String } } 属性 属性名称 类型 必须 允许更新 描述 约束 QueueName String 否 是 Queue的名称...
队列模型基本概念
队列（Queue）消息存储的目的地，分成普通队列和延时队列两类。消息包含数据和属性，可以分成普通消息和延时消息，在一个队列中能唯一标识一个消息的有Message ID和ReceiptHandle两个参数。普通队列 如果发送消息时不指定消息延时，消息...
名词解释
本文主要对 云消息队列 RabbitMQ 版 涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用 云消息队列 RabbitMQ 版。A Alternate Exchange 备份Exchange，简称AE，用于接收配置了备份Exchange的Exchange路由失败的消息。...
Queue管理
单TimelineStore下单identifier对应的消息队列（Queue）。TimelineQueue timelineQueue=timelineStore.createTimelineQueue(identifier);Queue是单存储库下单Identifier对应的消息队列的管理实例，主要有同步写、异步写、批量写、删、同步...
ack-kube-queue
ack-kube-queue是云原生AI套件提供的任务队列组件，主要围绕着Kube Queue任务队列，结合调度器和Quota系统，提供队列管理、优先级调度、使用弹性配额等功能，帮助您优化Kubernetes中的AI/ML工作负载和批处理工作负载的管理效率和调度性能。...
通过原始日志快速分析和定位问题
本文介绍基于 云消息队列 RabbitMQ 版 当前日志快速查询和分析问题的方法。当您遇到消息不符合预期、消费异常、消息堆积时，通过该方法可以帮助您高效识别出异常、保证业务正常运行。前提条件 推送 云消息队列 RabbitMQ 版 实例的消息操作...
JMS概述
云消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...
YARN高安全特性使用指南
表示所有队列默认将队列管理权限授权给hadoop组，此时非hadoop组的用户无法提交作业到任何队列（您可以使用 id 命令查看当前用户的组信息）。如果您集群的用户比较少，不需要进行管理ACL功能，则可以删除上面的两个配置项，然后在YARN服务...
基于事件流实现RabbitMQ消息路由
queue 消息路由规则（Routing Key）事件总线EventBridge 通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。当 目标类型 为 Exchange 时需要配置。部分事件$.data.key 消息体（body）事件总线EventBridge 通过JSONPath提取...
JMS P2P（主账号与RAM账号场景）
发送对象时必须让该对象实现serializable接口 MessageProducer msgPorducer=session.createProducer(queue);msgPorducer.send(objMsg);System.out.println("Object类型的消息已发送");} public static void main(String[]args)throws ...
JMS P2P（RAM角色跨账号授权场景）
MessageProducer msgProducer=session.createProducer(queue);Message msg=session.createTextMessage(MsgContent);msgProducer.send(msg);System.out.println("文本类型消息已发送");} public void sendMap(Session session,MapMessage ...
DROP QUEUE
语法 DROP QUEUE[IF EXISTS]name 说明 DROP QUEUE 允许具有 aq_administrator_role 特权的用户删除现有的队列。说明 PolarDB PostgreSQL版（兼容Oracle）为 DROP QUEUE SQL 命令包含额外的语法（Oracle 不提供）。可以将该语法与 DBMS_...
基本概念
云消息队列 RocketMQ 版 将这种正常情况下无法被消费的消息称为死信消息（Dead-Letter Message），将存储死信消息的特殊队列称为死信队列（Dead-Letter Queue）。相关操作，请参见 死信队列。消息路由 消息路由常用于不同地域之间的消息...
CreateQueue
调用CreateQueue创建Queue。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 CreateQueue 系统...
步骤二：创建资源
一个新的应用接入 云消息队列 RabbitMQ 版 服务端，您需要提前创建 云消息队列 RabbitMQ 版 的相关资源，包括创建 云消息队列 RabbitMQ 版 实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...
管理资源队列
每个Flink项目空间都会有一个默认队列（default-queue）来承载作业的运行。如果您有资源隔离和管理的需求，可以通过添加资源队列的方式实现。本文为您介绍如何添加、修改和删除资源队列。使用场景及方式 适用于有资源隔离和管理需求的场景...
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...
功能与特性概述
本文列举 云消息队列 RocketMQ 版 所支持的所有功能与特性。概览 云消息队列 RocketMQ 版 在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布...
顺序消息
如果是普通消息，订单A的消息可能会被轮询发送到不同的队列中，不同队列的消息将无法保持顺序，而顺序消息发送时 云消息队列 RocketMQ 版 支持将Sharding Key相同（例如同一订单号）的消息序路由到一个队列中。云消息队列 RocketMQ 版 服务...
使用须知
HTTP协议的迭代版本所支持的功能与TCP协议功能对比说明，请参见：Java SDK版本说明 Go SDK版本说明 Python SDK版本说明 Node.js SDK版本说明 PHP SDK版本说明 C#SDK版本说明 C++ SDK版本说明 注意事项 支持HTTP协议SDK接入为 云消息队列 ...
查询资源池列表
QueueList Array of Queue 资源池队列列表。Queue EcmResourcePoolConfigList Array of EcmResourcePoolConfig 资源池配置。EcmResourcePoolConfig Category String QUEUE_RESOURCE_LIMIT 参数类别。ConfigKey String minimum-user-limit-...
事务消息
云消息队列 RocketMQ 版 提供的分布式事务消息适用于所有对数据最终一致性有强需求的场景。本文介绍 云消息队列 RocketMQ 版 事务消息的概念、优势、典型场景、交互流程、使用规则以及示例代码。概念介绍 事务消息：云消息队列 RocketMQ 版...
SDK参考概述
SDK兼容性说明 云消息队列 RocketMQ 版 服务端版本和客户端SDK版本的兼容情况如下：服务端版本 客户端版本 兼容性 约束限制 5.x版本实例 RocketMQ 5.x SDK 兼容 云消息队列 RocketMQ 版 5.x版本实例的所有功能完全支持。RocketMQ 4.x/3.x ...
SDK概述
VPC README.md 公网README.md Ruby SDK Ruby SDK Demo PLAINTEXT SASL_SSL/PLAIN Ruby SDK收发消息 README.md Node.js SDK Node.js SDK Demo PLAINTEXT SASL_PLAIN Node.js SDK收发消息 README.md C#SDK 无 PLAINTEXT SASL_SSL/PLAIN SASL_...
定时和延时消息
本文主要介绍 云消息队列 RocketMQ 版 的定时消息和延时消息的概念、适用场景以及使用过程中的注意事项。概念介绍 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点...
消息收发功能
消息收发为 云消息队列 MQTT 版 最基本的功能，云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
云消息队列 MQTT 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建...
使用任务队列ack-kube-queue
任务队列ack-kube-queue旨在管理Kubernetes中的AI/ML工作负载和批处理工作负载。它允许系统管理员使用自定义队列的作业队列管理，以提高队列的灵活性。结合Quota系统，ack-kube-queue自动优化了工作负载和资源配额管理，以便最大化利用集群...
- 产品推荐
- 这些文档可能帮助您