设置基线优先级与YARN队列优先级的映射关系
方式二（单个节点YARN队列配置）：通过EMR节点编辑页面，设置单个EMR节点调度运行任务使用的YARN队列及队列优先级。详情请参见 创建EMR Hive节点、创建EMR Spark节点、创建EMR Spark SQL节点。若节点所在工作空间开启了全局配置优先，则...
队列控制台操作帮助
在 队列详情 页面的 基础信息 区域可查看修改后的队列配置。获取队列列表 在 队列列表 页面搜索文本框中输入队列名称的前缀，如test，然后单击搜索图标。查询列表中会列出所有名称前缀为test的队列。获取队列详情 在 队列列表 页面，找到...
部署异步推理服务
服务请求会先发送到队列子服务的输入队列中，推理子服务实例中的EAS服务框架会自动订阅队列以流式地方式获取请求数据，调用推理子服务中的接口对收到的请求数据进行推理，并将响应结果写入到输出队列中。当输出队列满时，即无法向输出队列...
设置全局YARN资源队列
数据质量：可在EMR表的分区规则中，通过 运行队列 配置单个分区规则的 YARN资源队列。详情请参见 配置规则：按表（单表）。其他产品模块：暂不支持在模块内单独设置 YARN资源队列。使用限制 仅以下角色可配置YARN资源队列：阿里云主账号。...
YARN调度器
租户内应用调度策略：租户内应用调度策略主要包括Fifo与Fair两种，Fifo即先入先出调度，对所有应用按优先级从高到低、提交时间从前往后的顺序排序，Fair是公平调度，对所有应用按资源使用比例从小到大、提交时间从前往后的顺序排序。...
云消息队列 RocketMQ 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 RocketMQ 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
使用限制
如果您购买了铂金版的 云消息队列 MQTT 版 实例，则可按需定制部分指标（下表中已标出），咨询定制 请联系 云消息队列 MQTT 版 技术支持，钉钉群号：35228338。实例限制 限制项 限制值 说明 实例名称 名称长度：3~64个字符 可用字符：仅限...
编辑资源队列
新增队列 重要 为叶子队列添加子队列时，必须先停止该队列，才可添加成功，否则会部署失败。（可选）在YARN服务的 编辑资源队列 页签，在 选择分区 下拉列表中选择已有的分区。默认展示DEFAULT_PARTITION分区。单击 管理队列 或 管理子队列...
产品优势
功能增强 延时消息 支持延时消息，实现秒级精准，无先入先出限制。简单易用，在代码上只需要设置一个参数即可完成，解决开源RabbitMQ无延时队列的痛点。高精度支持，最短可精确到秒级，最长可持续1天。高性能，性能与普通消息一致。多副本...
云消息队列 MQTT 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建...
云消息队列 Kafka 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 Kafka 版 中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源...
云消息队列RabbitMQ版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将指定 云消息队列 RabbitMQ 版 实例中的数据导出至其他的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。...
实例升降配
升降配操作入口 系统会根据您的实例的计费方式和配置自动计算出当前实例支持的变更操作，若您在以下操作入口未找到相关操作项，说明当前实例不支持该操作。登录 云消息队列 RocketMQ 版 控制台。在 实例列表 页面找到待变更配置的实例，并...
云消息队列 RabbitMQ 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建流入任务，将指定 云消息队列 RabbitMQ 版 实例中的数据快速导入至另外的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。...
MQTT客户端上下线事件数据流出
您可通过配置 云消息队列 MQTT 版 的客户端上下线通知规则，将获取的MQTT客户端上下线事件数据导出至其他阿里云产品。该方法为异步上下线通知。本文介绍客户端上下线通知的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云...
队列模型快速入门
本文为您介绍如何在 消息服务MNS控制台 上快速上手使用队列模型。前提条件 开通消息服务MNS并授权 创建队列 登录 消息服务MNS控制台。在左侧导航栏，单击 队列列表。在顶部菜单栏，选择地域。在 队列列表 页面，单击 创建队列。在 创建队列...
配置消息队列Kafka版实例的参数
本文为您介绍目标数据库实例为 专线/VPN网关/智能网关 方式接入的 阿里云消息队列Kafka版 时，部分特殊参数的配置方法和获取方式。注意事项 使用此方案将 阿里云消息队列Kafka版 接入DTS，会将数据写入到您指定的节点中。若您的源库为MySQL...
专业版实例计费
公网下行流量指的是使用公网接入点接入 云消息队列 MQTT 版 服务端产生的公网出流量。计费方式 按量付费 计费周期 每小时计算一次费用 计费公式 每小时公网流量费用=1小时内公网出流量累计值×单价 公网流量单价 地域 单价（元/GB）亚太 ...
接入Filebeat
本文介绍如何将 云消息队列 Kafka 版 接入Filebeat。Filebeat Filebeat是用于转发和集中日志数据的轻量级传输程序。Filebeat可以监听指定的日志文件或位置，从中收集日志事件并将其转发到Elasticsearch或Logstash进行索引。Filebeat的工作...
数据传输服务DTS
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将数据传输服务DTS中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。在...
消息服务MNS
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 消息服务MNS 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已创建 消息服务MNS 队列。具体步骤，请参见 开通消息服务MNS并授权。您已购买 云消息队列 ...
死信消息
配置死信消息保存规则 您可以在 云消息队列 RocketMQ 版 控制台 配置是否保存死信消息。操作入口如下：实例列表>实例详情>Group管理。死信消息可观测指标 指标说明 指标类型 指标项 Metrics元数据指标 rocketmq_send_to_dlq_messages：每...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
订阅消息
} } Push方式（批量消费）重要 配置 云消息队列 RocketMQ 版 的批量消费功能，请升级TCP Java SDK到1.8.7.3或以上版本，详细版本说明和获取方式，请参见 Java SDK版本说明。import com.aliyun.openservices.ons.api.Action;import ...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
消息队列 RocketMQ 客户端流控设计
代码示例 以下章节给出了基于配置中心来实现异步消息消费的全局动态流控的代码示例。关于 SDK 的详细介绍，参见 消息队列 RocketMQ 和 应用配置管理 ACM 产品官方文档。创建 ACM 配置 在 ACM 上创建消费延时的参数。设置全局消费延时变量 ...
访问控制概述
云消息队列 RocketMQ 版 支持通过RAM和ACL实现对 云消息队列 RocketMQ 版 资源的访问控制。使用限制 按量付费实例和包年包月实例需要先开启公网访问功能，才支持IP白名单功能。具体操作，请参见 实例升降配。按量付费实例和包年包月实例...
Workers
必填参数配置项（控制台会预设必填配置项）：配置项 说明 示例 bootstrap.servers Kafka实例的接入点。用于与Kafka实例相连接。alikafka-post-cn-7mz301t5*.alikafka.aliyuncs.com:9092 offset.storage.topic 存储offsets信息的Topic名称。...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
VPC环境，消息采用PLAINTEXT协议不鉴权不加密传输，通过默认接入点访问 云消息队列 Kafka 版，仅需配置 canal.serverMode 与 kafka.bootstrap.servers 参数。接入点的详细信息，请参见 接入点对比。您需设置为kafka。canal.serverMode=...
实例管理
实例是用于 云消息队列 MQTT 版 服务的虚拟机资源，会存储消息主题（Topic）和客户端ID（Group ID）信息。按照计费方式，云消息队列 MQTT 版 提供包年包月（预付费）计费模式的实例。实例规格分为企业铂金版、标准版 和专业版。使用限制 ...
收发定时消息和延时消息
重要 社区版的Apache RocketMQ和阿里云 云消息队列 RocketMQ 版 配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云 云消息队列 RocketMQ 版 不仅同时支持...
Topic管理
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，在使用 云消息队列 MQTT 版 前，需先创建该父级Topic资源。注意事项 Topic不能跨实例使用，例如不能使用实例B的接入点订阅创建在实例A中的Topic。Topic名称长度限制为3~64个字符...
收发定时和延时消息
重要 社区版的Apache RocketMQ和阿里云 云消息队列 RocketMQ 版 配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云 云消息队列 RocketMQ 版 不仅同时支持...
步骤二：创建资源
在调用SDK收发消息前，您需要提前创建 云消息队列 RocketMQ 版 的相关资源，包括创建 云消息队列 RocketMQ 版 实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时，需要将这些资源信息填写到SDK代码中。前提条件 创建专有...
MQTT快速入门
对于非MQTT协议的接入，例如新能源，您必须首先购买 云消息队列 MQTT 版 企业铂金版，并通过专属通道享受对应的文档和技术支持服务。说明 您可观看入门操作视频来快速上手 云消息队列 MQTT 版。视频详细信息，请参见 快速入门视频。注意...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
背景信息 云消息队列 MQTT 版 支持云端SDK，云上应用可直接通过云端SDK接入 云消息队列 MQTT 版 服务端进行消息收发并获取客户端的上下线状态。更多信息，请参见 获取MQTT客户端在线状态。同时 云消息队列 MQTT 版 支持和其他云产品进行...
GetInstanceList-查询指定地域的实例信息
云消息队列 Kafka 版实例支持域名接入点和 IP 接入点。域名接入点：由云消息队列 Kafka 版实例域名和端口号拼接而成，格式为 {实例域名}:{端口号}。IP 接入点：由 Broker 的 IP 地址和端口号拼接而成，格式为 {Broker 的 IP 地址}:{端口号}...
通过原始日志快速分析和定位问题
本文介绍基于 云消息队列 RabbitMQ 版 当前日志快速查询和分析问题的方法。当您遇到消息不符合预期、消费异常、消息堆积时，通过该方法可以帮助您高效识别出异常、保证业务正常运行。前提条件 推送 云消息队列 RabbitMQ 版 实例的消息操作...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
管理资源队列
每个Flink项目空间都会有一个默认队列（default-queue）来承载作业的运行。如果您有资源隔离和管理的需求，可以通过添加资源队列的方式实现。本文为您介绍如何添加、修改和删除资源队列。使用场景及方式 适用于有资源隔离和管理需求的场景...
- 产品推荐
- 这些文档可能帮助您