准备用于数据订阅的数据库账号
由于不同的数据库类型对权限要求有所不同，需要您在配置订阅任务前完成数据库账号的创建与授权操作。源库的数据库账号所需权限 数据库 所需权限 创建及授权方法 RDS MySQL 只读账号，或具备REPLICATION CLIENT、REPLICATION SLAVE、SHOW ...
RDS实例和本地数据库的表结构相同，但是索引不同，...
可以，如果数据订阅只订阅数据变更，那么两边索引不同不会影响。但是如果订阅了结构变更，而且RDS上涉及到索引变更的话，可能会由于两边索引不同，导致结构变更在本地消费失败。
创建PolarDB PostgreSQL版数据订阅任务
数据库名称 填入待订阅的数据库名称。数据库账号 填入 PolarDB PostgreSQL版 数据库的高权限账号。数据库密码 填入该数据库账号对应的密码。消费网络类型 网络类型 数据订阅实例的 网络类型 固定为 专有网络，您需要选择具体的 专有网络 和...
创建PolarDB PostgreSQL版（兼容Oracle）数据订阅任务
数据库名称 填入待订阅的数据库名称。数据库账号 填入 PolarDB PostgreSQL版（兼容Oracle）数据库的高权限账号。数据库密码 填入该数据库账号对应的密码。消费网络类型 网络类型 数据订阅实例的 网络类型 固定为 专有网络，您需要选择具体...
创建PolarDB MySQL版数据订阅通道
如果订阅的源数据库还处于其他任务中（例如该数据库还存在于某个正在运行的数据迁移任务中），您可能会订阅到订阅对象以外的数据，此类场景中，您需要手动在订阅客户端中过滤掉不需要的数据。操作步骤 购买数据订阅通道，详情请参见 购买...
创建PolarDB-X 2.0数据订阅任务
如果订阅的源数据库还处于其他任务中（例如该数据库还存在于某个正在运行的数据迁移任务中），您可能会订阅到订阅对象以外的数据，此类场景中，您需要手动在订阅客户端中过滤掉不需要的数据。若您订阅的单行数据超过16MB，则不支持消费，...
创建PolarDB-X 1.0数据订阅任务
由于 PolarDB-X 1.0 支持分库分表，源 PolarDB-X 1.0 的某一DDL指令会在所有分表上执行对应的DDL操作，并且每个订阅子任务的进度并不一致，因此DTS的订阅数据可能陆续包含多条此DDL操作，如您多次消费此类DDL操作，可能会导致订阅客户端...
创建PolarDB MySQL版数据订阅任务
通过数据订阅功能，您可以实时订阅增量数据，轻松帮助业务实现轻量级缓存更新、业务异步解耦...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建DMS逻辑库的数据订阅任务
本文介绍如何创建数据管理DMS（Data Management）逻辑库的数据订阅任务。...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费PolarDB-X 1.0订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
使用Canal和RocketMQ实现数据库变更订阅处理
Canal作为一款轻量级的CDC工具，可基于数据库增量日志解析，提供增量变更数据的订阅和消费能力。Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中，借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal...
使用Canal和RocketMQ实现数据库变更订阅处理
Canal作为一款轻量级的CDC工具，可基于数据库增量日志解析，提供增量变更数据的订阅和消费能力。Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中，借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal...
使用SDK示例代码消费PolarDB-X 1.0订阅数据
操作步骤 本文以IntelliJ IDEA软件（Community Edition 2020.1 Windows版本）为例，介绍如何运行SDK示例代码来消费PolarDB-X 1.0的订阅数据。创建新版数据订阅通道，具体操作请参见 创建RDS MySQL数据订阅任务。创建一个或多个消费组，具体...
【通知】2021年12月01日PolarDB-X 1.0数据订阅（旧版...
消费订阅数据，请参见 使用SDK示例代码消费PolarDB-X 1.0订阅数据。相关代码参考，请参见 分布式订阅任务对应的数据消费代码。注意 由于切换过程中，涉及部分消费代码的修改，因此为保证业务正常运行，请您尽快切换至 PolarDB-X 1.0 的新版...
使用SDK示例代码消费PolarDB-X 1.0订阅数据
操作步骤 本文以IntelliJ IDEA软件（Community Edition 2020.1 Windows版本）为例，介绍如何运行SDK示例代码来消费PolarDB-X 1.0的订阅数据。创建新版数据订阅通道，具体操作请参见 创建 PolarDB-X 1.0 数据订阅任务。创建一个或多个消费组...
查询PolarDB-X 1.0分布式订阅任务的子任务信息
DBList String {\"dtstestdata\":{\"name\":\"dtstestdata\",\"all\":false,\"Table\":{\"order\":{\"name\":\"order\",\"all\":true}}}} 子任务的订阅对象。详细定义说明，请参见 迁移、同步或订阅对象说明。Topic String ...
订阅PolarDB MySQL版集群日志
cluster.db_type：PolarDB MySQL版 集群兼容的数据库类型，取值当前仅支持MySQL。cluster.db_version：数据库版本号，取值为8.0、5.7或5.6。tag.*：自定义标签的名称。请将星号（*）替换为您自定义的标签名。更多关于 PolarDB MySQL版 集群...
使用DTS和DG迁移、同步或订阅本地或第三方云数据库
通过数据库网关DG（Database Gateway），您只需简单几步即可将本地或第三方云的数据库低成本地接入至阿里云。完成接入后，在创建数据传输服务DTS（Data Transmission Service）的数据迁移、同步或订阅任务时，您可以直接将数据库网关中接入...
使用DTS和DG迁移、同步或订阅本地或第三方云数据库
通过数据库网关DG（Database Gateway），您只需简单几步即可将本地或第三方云的数据库低成本地接入至阿里云。完成接入后，在创建数据传输服务DTS（Data Transmission Service）的数据迁移、同步或订阅任务时，您可以直接将数据库网关中接入...
订阅方案概览
源数据库 支持订阅的数据类型 配置文档 自建MySQL 5.1、5.5、5.6、5.7或8.0版本 RDS MySQL 所有版本 数据更新 结构更新 创建RDS MySQL数据订阅任务 PolarDB MySQL版 所有版本 数据更新 结构更新 创建PolarDB MySQL版数据订阅任务 PolarDB-X...
订阅方案概览
源数据库 支持订阅的数据类型 配置文档 自建MySQL 5.1、5.5、5.6、5.7或8.0版本 RDS MySQL 所有版本 数据更新 结构更新 创建RDS MySQL数据订阅任务 PolarDB MySQL版 所有版本 数据更新 结构更新 创建PolarDB MySQL版数据订阅任务 PolarDB-X...
订阅
一个订阅会定义到另一个数据库的连接以及它想要订阅的发布集合（一个或者多个）。订阅者数据库的行为与任何其他 PostgreSQL实例相同，并且可以被用作其他数据库的发布者，只需要定义它自己的发布。如果需要，一个订阅者节点可以有多个订阅...
CREATE SUBSCRIPTION
CREATE SUBSCRIPTION 用于为当前数据库添加一个新的订阅。简介 CREATE SUBSCRIPTION 为当前数据库添加一个新的订阅。订阅名称必须与数据库中任何现有的订阅不同。订阅表示到发布者的复制连接。因此，此命令不仅在本地目录中添加定义，还会...
逻辑订阅
本文简单介绍逻辑订阅的使用流程，示例的流程如下：源实例的数据库src创建发布，发布表public.t1，然后在目的实例的数据库dst创建订阅sub1_from_pub1，订阅源库表public.t1。更多详情请参见 逻辑订阅原理与最佳实践。注意事项 您可以在单个...
创建RDS MySQL数据订阅通道
如果订阅的源数据库还处于其他任务中（例如该数据库还存在于某个正在运行的数据迁移任务中），您可能会订阅到订阅对象以外的数据，此类场景中，您需要手动在订阅客户端中过滤掉不需要的数据。操作步骤 购买数据订阅通道，详情请参见 购买...
创建Oracle数据订阅通道
如果订阅的源数据库还处于其他任务中（例如该数据库还存在于某个正在运行的数据迁移任务中），您可能会订阅到订阅对象以外的数据，此类场景中，您需要手动在订阅客户端中过滤掉不需要的数据。准备工作 登录待订阅的Oracle数据库，创建用于...
修改数据库密码
当您因安全策略等原因，修改了用于数据迁移、数据同步或数据订阅的数据库账号的密码，您需要通过DTS控制台，将该数据库账号的密码修改为新密码。前提条件 您已创建数据迁移任务、数据同步作业或新版数据订阅通道。说明 旧版数据订阅通道不...
使用DTS创建数据订阅
数据库名称 填入待订阅的数据库名称。数据库账号 填入 RDS PostgreSQL 的高权限账号，且需为所选数据库的owner（授权账号）。账号创建及授权方式，请参见 创建账号 和 创建数据库。数据库密码 填入该数据库账号对应的密码。消费网络类型 ...
D100快速入门
添加订阅报表任务后，数据库审计系统会定期向您指定的邮箱发送订阅的数据库审计报表，帮助您了解数据库状态。请参见以下步骤，创建订阅任务。在左侧导航栏，选择 报表中心>报表订阅。在 报表订阅 页面，单击 添加。在 添加订阅任务 面板，...
DROP SUBSCRIPTION
DROP SUBSCRIPTION 用于删除数据库集群中的一个订阅。简介 DROP SUBSCRIPTION 删除数据库集群中的一个订阅。只有超级用户才可以删除订阅。如果订阅与复制槽相关联，就不能在事务块内部执行 DROP SUBSCRIPTION（可以使用 ALTER SUBSCRIPTION...
创建Oracle数据订阅任务
通过数据订阅功能，您可以实时订阅源库的增量数据，轻松帮助业务实现轻量级缓存更新、业务...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
C100快速入门
添加订阅报表任务后，数据库审计系统会定期向您指定的邮箱发送订阅的数据库审计报表，帮助您了解数据库状态。请参见以下步骤，创建订阅任务。在左侧导航栏，选择 报表中心>报表订阅。单击 添加，在 添加订阅任务 面板，完成订阅任务配置。...
配置订阅实例
SourceEndpoint.DatabaseName String 否 dtstestdata 待订阅的数据库名称。SourceEndpoint.OwnerID String 否 140692647406*源实例所属的阿里云账号ID。说明 仅在配置跨阿里云账号的数据订阅时本参数才可用，且必须传入。SourceEndpoint....
创建RDS PostgreSQL数据订阅任务
数据库名称 填入待订阅的数据库名称。数据库账号 填入 RDS PostgreSQL 的高权限账号，且需为所选数据库的owner（授权账号）。账号创建及授权方式，请参见 创建账号 和 创建数据库。数据库密码 填入该数据库账号对应的密码。消费网络类型 ...
C100售前支持相关问题
添加订阅报表任务后，数据库审计系统会定期向指定的邮箱发送订阅的数据库审计报表。资产配置问题 是否支持PolarDB集群审计？不支持直接对PolarDB集群进行审计，支持对集群中的数据库进行审计。云数据库PolarDB是阿里巴巴自主研发的新一代...
配置DTS订阅任务
SourceEndpointDatabaseName String 否 dtstestdata 待订阅的数据库名称。SourceEndpointUserName String 否 dtstest 源实例的数据库账号。说明 订阅不同的数据库所需的权限有所差异，请参见 准备用于数据订阅的数据库账号 中的账号权限。...
应用场景
DTS提供的数据订阅功能，可以帮助您异步订阅数据库的增量数据，并更新缓存的数据，实现轻量级的缓存更新策略。该架构具有以下优势：更新路径短，延迟低 业务完成更新数据库后直接返回，不需要关心缓存失效流程，整个更新路径短、延迟低。...
购买流程
订阅实例类型 选择待订阅的数据库类型，当前支持订阅MySQL、PolarDB-X、PolarDB MySQL、PolarDB O引擎、Oracle、PostgreSQL和DMS LogicDB。说明 其中MySQL包含RDS for MySQL和自建MySQL数据库。PolarDB-X中的数据库须基于已有的RDS MySQL...
支持的数据库
本文详细介绍DTS支持的数据库、迁移类型、同步初始化类型、同步拓扑和支持订阅的数据类型。说明 关于文中涉及的迁移类型、同步类型、订阅的数据类型等相关术语的详细解释，请参见 基本概念。当前仅当目标库为函数计算FC时，不支持跨地域的...
混合云解决方案
场景说明 ApsaraDB for SQL Server混合云解决方案用于实现本地SQL Server服务与RDS SQL Server服务之间的数据传输或者同步。利用SQL Server复制技术实现数据的同步，其典型应用场景就是写数据在本地，读数据在RDS...RDS的订阅数据库版本不限。
消息发布与订阅
云数据库Redis版也提供了与Redis相同的消息发布（publish）与订阅（subscribe）功能。即一个客户端发布消息，其他多个客户端订阅消息。场景介绍 云数据库Redis版发布的消息是“非持久”的，即消息发布者只负责发送消息，而不管消息是否有...
- 产品推荐
- 这些文档可能帮助您