队列的链式存储-队列的链式存储文档介绍内容-阿里云

作为Input接入

云消息队列 Kafka 版可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从云消息队列 Kafka 版消费消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

NAS存储卷FAQ

NAS存储卷挂载时间延长 NAS存储卷挂载失败时出现timeout错误使用NAS存储卷时，提示chown:option not permitted 挂载NAS存储卷失败使用NAS动态存储卷时Controller的任务队列已满且无法创建新的PV NAS存储卷挂载时间延长问题现象：NAS存储...

通过SDK使用分析存储

使用SDK在已开启分析存储的时序模型实例下为时序表创建分析存储并为分析存储创建绑定关系，然后使用SQL查询数据。说明您可以通过 Java SDK 或者 Go SDK 使用分析存储功能，本文以Java SDK为例介绍分析存储的使用。注意事项时序分析存储...

Topic使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x后，实现了独立存储，Topic资源不再依赖于云消息队列 RocketMQ 版，因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 ...

实例使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x后，不再需要与云消息队列 RocketMQ 版的实例进行绑定。本文介绍两个版本之间的控制台实例相关操作的具体差异，并提供控制台截图进行对比。变更说明由于V3.x.x版本的云消息队列 MQTT 版实现了...

表格存储

消息数据表格存储自研的Timeline模型主要用于消息数据，能够抽象出支撑海量Topic的轻量级消息队列，可以存储大量社交信息，包括IM聊天，以及评论、跟帖和点赞等Feed流信息。目前表格存储Timeline模型已被应用在众多IM系统中，例如支撑钉钉...

DBMS_AQADM

表 1.DBMS_AQADM函数/存储过程函数/存储过程返回类型说明 ALTER_QUEUE N/A 修改现有的队列。ALTER_QUEUE_TABLE N/A 修改现有的队列表。CREATE_QUEUE N/A 创建队列。CREATE_QUEUE_TABLE N/A 创建队列表。DROP_QUEUE N/A 删除现有队列。...

常见问题

本文列举了阿里云表格存储的常见问题，帮助您快速了解表格存储。一般性常见问题什么是表格存储？表格存储面向海量结构化数据提供Serverless表存储服务，同时针对物联网场景深度优化提供一站式的IoTstore解决方案。适用于海量账单、IM...

延时消息

因为云消息队列 RabbitMQ 版的消息是分布式存储的，如果您使用pull模式的 basic.get 方法获取消息，并不能保证正好从存储的节点获取消息。常见问题为什么实际的延时时间大于设置的延时时间？因为客户端使用了pull模式的basic.get方法...

重置消费位点

选择从指定时间点重置时，可以选择的最早时间为Topic中最早一条消息的存储时间，而云消息队列 RocketMQ 版 4.x系列实例的最大消息存储时长为3天，超过3天的消息会从Topic中被删除。因此，通过重置消费位点最多可重新消费到3天前的消息。...

数据格式

数据格式数据格式支持的连接器 JSON 消息队列Kafka、Upsert Kafka、Elasticsearch、对象存储OSS，云数据库MongoDB、StarRocks。Canal 消息队列Kafka、对象存储OSS。Debezium 消息队列Kafka、对象存储OSS。Maxwell 消息队列Kafka、对象...

计费常见问题

包年包月（预付费）实例的费用只限于云消息队列 MQTT 版所支持的协议，即云消息队列 MQTT 版的消息传输以及消息存储。若您使用云消息队列 MQTT 版的数据流入、数据流出规则和云消息队列 RocketMQ 版进行通信，云消息队列 RocketMQ ...

Serverless实例计费说明

计费公式每小时存储费用＝存储空间占用大小（GB）×存储单价（元/G/小时）计费单价地域存储空间单价（元/GB/小时）所有支持地域 0.0014 Topic费用云消息队列 RocketMQ 版的Serverless实例按照Topic数量收取费用。说明 Topic费用是只要...

NAS存储卷FAQ

问题原因当前工作负载调度的节点未安装对应存储的依赖资源。解决方案检查存储卷相关配置是否正确。关于NAS存储卷配置，请参见使用CNFS管理NAS共享存储卷（推荐）。关于CPFS相关配置，请参见 CPFS2.0静态卷。关于OSS相关配置，请参见 ...

什么是云消息队列 RocketMQ 版？

相对于自建RocketMQ集群，云消息队列 RocketMQ 版具有如下优势：架构先进性全面采用存储和计算分离的消息架构，存储和计算可以独立按需水平扩展，满足高效弹性运维和高性能大规格能力的诉求。高性能可提供单实例集群最高100万TPS稳定...

消息检索

开通消息检索相当于自动化创建了一个云消息队列 Kafka 版同步数据至表格存储的Connector任务，名称格式为：ots-ms-{Topic名称}-{6位随机字符}，该Connector任务在消息检索页面显示和管理，而不在 Connector 任务列表页面显示和管理。...

使用限制

企业铂金版：存储时长为3天，若您购买实例的存储空间规格不足时，云消息队列 RocketMQ 版会按存储时间滚动删除最早的消息，此时消息的存储时长可能不足3天。说明定时消息和延时消息的存储时长以定时或延时时长到期的时间为开始进行计算。...

实例规格

不支持消息存储时长 3天若您购买实例的存储空间规格不足时，云消息队列 RocketMQ 版会按存储时间滚动删除最早的消息，此时消息的存储时长可能不足3天。说明若您对消息存储时长有特殊要求，您可以联系云消息队列 RocketMQ 版技术支持...

API概览

主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。UpdateTopic 更新主题更新主题的备注信息。DeleteTopic...

新功能发布记录

本文介绍云消息队列 Kafka 版的产品功能动态及对应的文档。2024-04-15 功能名称功能描述功能类型相关文档 V3.0 Serverless系列实例在华东2（上海）地域开服云消息队列 Kafka 版 V3.0 Serverless系列实例支持在华东2（上海）地域选购...

新功能发布记录

新增开服地域预付费实例计费说明 Serverless后付费实例计费说明 2023-11-15 功能名称功能描述功能类型相关文档数据加密云消息队列 RabbitMQ 版的铂金版实例支持存储加密功能，通过AES-256加密算法对您存储在服务端的数据以及元数据...

Queue管理

本文介绍如何在云消息队列 RabbitMQ 版控制台创建消息的存储资源Queue、查看Dashboard大盘、被Exchange绑定、向指定Queue发送消息、查看Consumer Tag、清空Queue和删除Queue。背景信息 Consumer Tag是Consumer客户端的标识符。您可以在 ...

消息收发流程变更

云消息队列 MQTT 版 V2.x.x版本强依赖云消息队列 RocketMQ 版作为消息存储，因此云消息队列 MQTT 版消息和云消息队列 RocketMQ 版天然打通，创建了Topic后即可天然使用云消息队列 RocketMQ 版和云消息队列 MQTT 版的SDK相互通信...

发布者最佳实践

本文介绍云消息队列 Kafka 版发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息发送消息的示例代码如下：Future...

仪表盘

业务背景云消息队列 RocketMQ 版的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版的重点指标主要涉及以下业务场景。消息堆积...

消息轨迹

进死信时间消息消费失败被投递至死信队列的时间。使用限制 RocketMQ 4.x/3.x 版本的SDK客户端默认不开启消息轨迹功能，您需要在消息收发代码中开启消息轨迹功能，才能在控制台查询到消息的轨迹信息。具体配置如下：生产者 producer....

CreateTopic-创建主题

主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。调试您可以在OpenAPI Explorer中直接运行该接口，免去...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 Kafka 版提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。前提条件开通ARMS Prometheus监控服务 ...

Dashboard

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RabbitMQ 版为企业版和铂金版实例提供Dashboard大盘功能。通过该功能，您可以查看企业版和铂金版实例、Vhost、Queue和Exchange的各种指标数据，帮助您及时...

功能特性

云监控仪表盘阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 Kafka 版提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。仪表盘告警实例风险告警实例的...

常见问题

云消息队列 RocketMQ 版存储需要挂载磁盘吗？客户端连接常见问题客户端连接时出现“signature validate by dauth failed”错误客户端连接时出现“TimeoutException”错误客户端返回“valid resource owner failed”错误客户端返回...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版提供可实时进行数据统计的仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘...

什么是消息队列RabbitMQ版？

云消息队列 RabbitMQ 版是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...

云存储网关利用MQTT服务实现统一管控

通过云消息队列 MQTT 版所提供的服务，可采用统一的框架，即云控制台，来管理不同部署模式的云存储网关CSG（Cloud Storage Gateway），并实现安全合规的公网和私网穿透，以此提供一致的用户体验。名词解释 MQTT 一种物联网和移动互联网...

资源使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对云消息队列 RocketMQ 版的消息依赖，因此，云消息队列 MQTT 版的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明云消息队列 MQTT 版 ...

V2.x.x到V3.x.x的升级公告

升级说明云消息队列 MQTT 版的V3.x.x版本相比V2.x.x版本而言，实现了自身的消息独立存储，再也无需强制绑定云消息队列 RocketMQ 版，因此购买开通云消息队列 MQTT 版实例后即可直接创建资源，从而降低您的使用与理解成本。V3.x.x版本...

定时/延时消息

定时/延时消息为云消息队列 RocketMQ 版中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景说明定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...

创建OSS Sink Connector（旧版）

本文介绍如何创建使用OSS Sink Connector，您可以通过OSS Sink Connector将数据从云消息队列 Kafka 版的数据源Topic导出至对象存储OSS的Object中。前提条件详细步骤，请参见创建前提。步骤一：创建目标服务资源在对象存储OSS控制台...

从自建MySQL同步至云消息队列 Kafka 版

消息格式同步到云消息队列 Kafka 版集群中的数据以avro格式存储，schema定义详情请参见 DTS avro schema定义。说明数据同步到云消息队列 Kafka 版集群后，您需要根据avro schema定义进行数据解析。费用说明数据传输服务DTS费用，请...

创建资源

前提条件开通服务并授权创建实例并获取接入点实例是用于云消息队列 MQTT 版服务的虚拟机资源，会存储消息主题（Topic）和客户端相关（Group ID）信息。登录云消息队列 MQTT 版控制台，并在左侧导航栏单击实例列表。在顶部菜单栏...

队列的链式存储

新品推荐