监控项说明
本文介绍云数据库MongoDB基本监控、高级监控和性能趋势功能支持的监控项、监控指标及其具体含义。基础监控 说明 不同类型实例支持的监控项请以控制台为准。支持的实例 监控项 监控指标及说明 单节点实例 副本集实例 分片集群实例 CPU使用率...
队列（MessageQueue）
内部属性 读写权限 定义：当前队列是否可以读写数据。取值：由服务端定义，枚举值如下 6：读写状态，当前队列同时允许写入消息和读取消息操作。4：只读状态，当前队列只允许读取历史消息，不允许向队列写入新的消息。2：只写状态，当前队列...
什么是读写分离
如果您的业务场景中读请求远大于写请求，且大量的读请求对主实例造成了负载压力，则可以购买只读实例，配合RDS PostgreSQL数据库代理的读写分离功能，通过一个数据库代理地址实现读写请求的自动转发，充分发挥各只读实例的读性能，减轻主...
设置全局YARN资源队列
方式二：配置产品模块内YARN队列 数据开发（DataStudio）：对于Hive、Spark节点，可在节点编辑页面右侧导航栏的 高级设置，通过 queue 参数设置单个节点任务的YARN资源队列。数据质量：可在EMR表的分区规则中，通过 运行队列 配置单个分区...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
基于Flink的资讯场景实时数仓
云数据库RDS 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务。基于阿里云分布式文件系统和SSD盘高性能存储，RDS支持MySQL、SQL Server、PostgreSQL和MariaDB引擎，并且提供了容灾、备份...
创建AnalyticDB Sink Connector
本文以AnalyticDB PostgreSQL版为例，创建数据库名为abd_sink_database和数据表名为abd_sink_table的资源。步骤二：创建AnalyticDB Sink Connector并启动 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在...
CREATE QUEUE
RETENTION[DOUBLE PRECISION]说明 CREATE QUEUE 命令允许数据库超级用户或具有系统定义的 aq_administrator_role 特权的任何用户，在当前数据库中创建新队列。如果队列名称是 schema 限定的，则在指定的 schema 中创建队列。如果 CREATE ...
跨云产品的数据流出
您可通过配置 云消息队列 MQTT 版 的数据流出规则来自定义数据从 云消息队列 MQTT 版 流出至其他阿里云产品。本文介绍数据流出的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将 云消息...
生态对接概述
阿里云生态 云数据库HBase版 基于HBase和Spark的数据处理平台 阿里云实时计算Flink 基于Flink的资讯场景实时数仓 大数据计算服务MaxCompute 接入MaxCompute 数据传输服务DTS 使用DTS同步MySQL 容器服务Kubernetes版 在Knative上实现Kafka...
跨云产品数据流入
您可通过配置 云消息队列 MQTT 版 的数据流入规则来自定义数据从其他阿里云产品流入到 云消息队列 MQTT 版。本文介绍跨产品数据流入的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将...
什么是云消息队列 Kafka 版？
云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势 云消息队列 Kafka 版 针对开源的Apache Kafka提供全托管服务，解决开源产品的痛点。有了 云...
使用MongoDB Connector连接MongoDB数据库
本文介绍如何创建MongoDB Connector，将MongoDB数据库和 云消息队列 Kafka 版 的数据进行双向同步。前提条件 开通事件总线EventBridge并授权。已开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见 控制台创建存储空间。已...
数据流入规则管理
如需将其他阿里云产品的数据导入 云消息队列 MQTT 版，您需创建数据流入规则。该规则用于从您配置的阿里云产品中读取数据并将数据通过MQTT协议推送到MQTT客户端，从而实现直接调用阿里云产品的API发送数据到MQTT客户端。流程说明 规则限制 ...
应用场景
数据中转枢纽 近10多年来，诸如KV存储（HBase）、搜索（Elasticsearch）、流式处理（Storm、Spark、Samza）、时序数据库（OpenTSDB）等专用系统应运而生。这些系统是为单一的目标而产生的，因其简单性使得在商业硬件上构建分布式系统变得...
应用场景
本文为您介绍 云消息队列 RabbitMQ 版 的应用场景，以便...分布式缓存同步 大量并发访问数据库会导致页面响应时间长。通过 云消息队列 RabbitMQ 版 构建分布式缓存，支持实时通知数据变化，有效降低页面响应时间，满足对变更的大量访问需求。
内容富化
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。内容映射 根据正则表达式对消息内容进行映射处理。例如，屏蔽消息中敏感字段或将消息大小缩减至最小标准。本文以 云消息...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
canal.mq.partition 否 数据库数据同步到 云消息队列 Kafka 版 Topic的指定分区。canal.mq.partitionsNum 否 Topic的分区数量。该参数与 canal.mq.partitionHash 一起使用，可以将数据同步至 云消息队列 Kafka 版 Topic不同的分区。canal....
数据流出规则管理
如需将 云消息队列 MQTT 版 的数据导出至其他阿里云产品，您需创建数据流出规则。该规则用于将MQTT客户端发送的消息导出到您配置的其他阿里云产品中，从而实现直接调用云产品的API读取MQTT客户端发送的消息。流程说明 规则限制 限制项 限制...
上下线通知规则管理
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...
迁移概述
迁移路由 云消息队列 Kafka 版 提供全托管、免运维的实例迁移服务，用于自建实例与 云消息队列 Kafka 版 实例之间或者 云消息队列 Kafka 版 实例之间的数据同步，无需借助工具即可在控制台上实现实例迁移，迁移完成后目标集群的元数据与源...
读写分离
在同一个连接内（同一个session内），读写分离中间件会根据各个数据库节点的数据同步程度，来选择合适的节点，在保证数据正确的基础上（写操作之后的读有正确的结果），实现读写请求的负载均衡。扩展查询（prepare语句或命令）的负载均衡。...
内容分割
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。内容映射 根据正则表达式对消息内容进行映射处理。例如，屏蔽消息中敏感字段或将消息大小缩减至最小标准。本文以 云消息...
新零售电子价签解决方案（MQTT）
电子价签后台管理服务可以将改价等任务的状态变更持久化到RDS数据库以确保任务变更成功，并将价签上报数据和操作日志存储到SLS，方便溯源和审计。方案优势 新零售电子价签解决方案的优势如下所述：服务能力强，可弹性伸缩 云消息队列 MQTT ...
内容映射
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。内容映射 根据正则表达式对消息内容进行映射处理。例如，屏蔽消息中敏感字段或将消息大小缩减至最小标准。本文以 云消息...
在线教育视频直播
表格存储 表格存储（Tablestore）是阿里云自研的面向海量结构化数据存储的Serverless NoSQL多模型数据库，被广泛用于社交、物联网、人工智能、元数据和大数据等业务场景。提供兼容HBase的WideColumn模型、消息模型Timeline以及时空模型...
云消息队列 Kafka 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列 MQTT 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
JMS概述
云消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...
读写分离版
本章节介绍云数据库Redis社区版读写分离实例的规格，包含内存容量、连接数、带宽、QPS参考值等信息。实例规格 说明 下表中的1节点代表该实例规格仅包含1个数据分片。例如规格为 读写分离1G版（1节点3只读）表示该实例具备1个数据分片，该...
主题（Topic）
Transaction：事务消息，云消息队列 RocketMQ 版 支持分布式事务消息，支持应用数据库更新和消息调用的事务一致性保障。约束：每个主题只支持一种消息类型。行为约束 消息类型强制校验 云消息队列 RocketMQ 版 5.x版本将消息类型拆分到主题...
动态路由
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。内容映射 根据正则表达式对消息内容进行映射处理。例如，屏蔽消息中敏感字段或将消息大小缩减至最小标准。本文以 云消息...
V2.x.x到V3.x.x的升级公告
V3.x.x版本除了独立存储之外，还对V2.x.x版本实现的 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 互通的功能进行抽象，使得 云消息队列 MQTT 版 的数据可以根据您配置相应规则转发到其他阿里云产品，也可以配置规则从其他阿里云产品导入...
收发延时消息
发送延时消息 具体的示例代码，请以 云消息队列 RocketMQ 版 代码库 为准。发送延时消息的示例代码如下：import com.aliyun.openservices.ons.api.Message;import com.aliyun.openservices.ons.api.ONSFactory;import ...
消息队列RabbitMQ版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列 RabbitMQ 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列 RabbitMQ 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
云消息队列 RabbitMQ 版
如果消息原始内容包含AccountID，处理时根据AccountID查询数据库，获得客户地域后填至源消息体中，并发送至目标服务。动态路由：根据正则表达式匹配消息内容，将匹配成功的消息路由至对应目标，将匹配不成功的消息路由至默认目标。内容分割...
排他队列
因此，您在使用排他队列前请谨慎评估队列可能被自动删除的风险，并考虑队列数据丢失的场景。如何声明排他队列 排他队列在客户端程序中通过 channel.queueDeclare 方法声明，将 exclusive 设置为 true。以Java语言为例，声明方式如下：/*...
- 产品推荐
- 这些文档可能帮助您