缓存数据持久化
当您使用云数据库RDS MySQL并需要提升数据处理速率和降低访问延迟时，阿里云为您提供了缓存数据持久化的高效方案，该解决方案通过整合云数据库Redis与RDS、云数据库Memcache与RDS协同工作，确保数据的高速访问和持久化存储，具备高吞吐、低...
参数说明
pullThresholdForQueue 拉消息本地队列缓存消息最大数量，默认值：1000，单位：条，允许区间为[1,65535]。pullThresholdSizeForQueue 拉消息本地队列缓存消息总大小，默认值：100，单位：MB，允许区间为[1,1024]。maxReconsumeTimes 最大重...
Interactive型资源组的优先级队列与并发控制
为了更细致地控制查询并发数，AnalyticDB MySQL版 湖仓版（3.0）和 数仓版（3.0）的资源组提供了优先级队列的能力。每个资源组都有自己的一组优先级队列，包括LOWEST队列、LOW队列、NORMAL队列和HIGH队列。您可以设置查询的优先级，使不同...
负载管理最佳实践
wlm add_rule name=confine_query_in_table type=query action=ADD_PROPERTIES predicate='query_table_list in database.table1,database.table2' attrs='{"add_prop":{"query_priority":"low"} }' 通过配置修改Low队列的并发数达到限流的...
权益分发
方案架构 因为 云消息队列 RocketMQ 版 具有重试功能且能保证消息不丢失，所以推出此方案来确保DB和缓存数据的强一致性，即在DB和缓存间使用 云消息队列 RocketMQ 版，架构如下图所示。方案优势 云消息队列 RocketMQ 版 有以下优势：巨大的...
应用场景
本文为您介绍 云消息队列 RabbitMQ 版 的应用场景，以便...分布式缓存同步 大量并发访问数据库会导致页面响应时间长。通过 云消息队列 RabbitMQ 版 构建分布式缓存，支持实时通知数据变化，有效降低页面响应时间，满足对变更的大量访问需求。
从自建MySQL同步至云消息队列 Kafka 版
注意事项 DTS在执行全量数据初始化时将占用源库和目标库一定的读写资源，可能会导致数据库的负载上升，在数据库性能较差、规格较低或业务量较大的情况下（例如源库有大量慢SQL、存在无主键表或目标库存在死锁等），可能会加重数据库压力，...
排他队列
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
CREATE QUEUE
RETENTION[DOUBLE PRECISION]说明 CREATE QUEUE 命令允许数据库超级用户或具有系统定义的 aq_administrator_role 特权的任何用户，在当前数据库中创建新队列。如果队列名称是 schema 限定的，则在指定的 schema 中创建队列。如果 CREATE ...
使用MongoDB Connector连接MongoDB数据库
本文介绍如何创建MongoDB Connector，将MongoDB数据库和 云消息队列 Kafka 版 的数据进行双向同步。前提条件 开通事件总线EventBridge并授权。已开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见 控制台创建存储空间。已...
查询加速
原理介绍 全局缓存与并发计算原理说明如下所示：全局缓存 Prometheus Query计算引擎默认不对执行结果进行缓存，每次查询都需重新计算所有数据，在数据量大、时间范围长时性能较差。全局缓存功能支持复用上一次相同查询（PromQL语句和step...
生态对接概述
阿里云生态 云数据库HBase版 基于HBase和Spark的数据处理平台 阿里云实时计算Flink 基于Flink的资讯场景实时数仓 大数据计算服务MaxCompute 接入MaxCompute 数据传输服务DTS 使用DTS同步MySQL 容器服务Kubernetes版 在Knative上实现Kafka...
管理资源队列
每个工作空间都会默认包含dev_queue和root_queue两个队列，用于承载作业的运行。如果您有资源隔离和管理的需求，可以通过添加队列的方式实现。本文为您介绍队列的基本操作。前提条件 已创建工作空间，详情请参见 管理工作空间。添加队列 ...
什么是云消息队列 Kafka 版？
云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势 云消息队列 Kafka 版 针对开源的Apache Kafka提供全托管服务，解决开源产品的痛点。有了 云...
应用场景
数据中转枢纽 近10多年来，诸如KV存储（HBase）、搜索（Elasticsearch）、流式处理（Storm、Spark、Samza）、时序数据库（OpenTSDB）等专用系统应运而生。这些系统是为单一的目标而产生的，因其简单性使得在商业硬件上构建分布式系统变得...
内容富化
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。内容映射 根据正则表达式对消息内容进行映射处理。例如，屏蔽消息中敏感字段或将消息大小缩减至最小标准。本文以 云消息...
内容分割
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。内容映射 根据正则表达式对消息内容进行映射处理。例如，屏蔽消息中敏感字段或将消息大小缩减至最小标准。本文以 云消息...
新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
内容映射
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。内容映射 根据正则表达式对消息内容进行映射处理。例如，屏蔽消息中敏感字段或将消息大小缩减至最小标准。本文以 云消息...
收发延时消息
发送延时消息 具体的示例代码，请以 云消息队列 RocketMQ 版 代码库 为准。发送延时消息的示例代码如下：import com.aliyun.openservices.ons.api.Message;import com.aliyun.openservices.ons.api.ONSFactory;import ...
云消息队列 Kafka 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列 MQTT 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
动态路由
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。内容映射 根据正则表达式对消息内容进行映射处理。例如，屏蔽消息中敏感字段或将消息大小缩减至最小标准。本文以 云消息...
消息幂等
处理方法 以Message ID为幂等键对消息进行幂等处理的步骤如下：在数据库中创建一张unique key索引为唯一Message ID的表。在Producer客户端为每条消息设置唯一Message ID。设置唯一Message ID的示例代码如下：AMQP.BasicProperties props=...
主题（Topic）
Transaction：事务消息，云消息队列 RocketMQ 版 支持分布式事务消息，支持应用数据库更新和消息调用的事务一致性保障。约束：每个主题只支持一种消息类型。行为约束 消息类型强制校验 云消息队列 RocketMQ 版 5.x版本将消息类型拆分到主题...
消息队列RabbitMQ版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列 RabbitMQ 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列 RabbitMQ 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
数据传输服务DTS
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，以实现将数据传输服务DTS的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源...
云消息队列 RabbitMQ 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
收发定时消息
发送定时消息 具体的示例代码，请以 云消息队列 RocketMQ 版 代码库 为准。发送定时消息的示例代码如下。import com.aliyun.openservices.ons.api.Message;import com.aliyun.openservices.ons.api.ONSFactory;import ...
云消息队列 RocketMQ 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
消息队列Kafka版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列 RocketMQ 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
消息队列RocketMQ版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列RabbitMQ版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列 RocketMQ 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
迁移元数据上云
元数据存储于RabbitMQ集群的内部数据库，在集群的各个节点之间自动复制。集群内各节点的元数据内容都相同。使用限制 由于RabbitMQ和 云消息队列 RabbitMQ 版 在权限管控机制等方面存在差异，rabbit_version、users、permissions、...
名词解释
RDS 阿里云推出的一种稳定可靠、可弹性伸缩的在线数据库服务。在电子价签系统中用来持久化改价等任务的状态变更。SLS日志存储 阿里云推出的日志存储服务，在电子价签系统中用来持久化保存所有操作日志，用于审计和溯源。
数据传输服务DTS
在 消息流入创建 面板，设置 任务名称，选择 流入类型 为 数据库 DTS，配置以下信息，然后单击 确定。在 资源配置 区域，设置以下参数。表 1.源端数据传输服务DTS参数配置 参数 说明 示例 地域 默认选择创建消息流入任务时选择的地域。华东...
- 产品推荐
- 这些文档可能帮助您