订阅通道是什么-和订阅通道相关的问题-阿里云开发者社区

回答

详细解答可以参考官方帮助文档实时数据订阅功能旨在帮助用户获取RDS/DRDS的实时增量数据，用户能够根据自身业务需求自由消费增量数据，例如实现缓存更新策略、业务异步解耦、异构数据源数据实时同步及含复杂ETL的数据实时同步等多种业务场景。功能列表(1) 支持公共云、金融云RDS For MySQL实例的数据订阅。(2) 支持经典网络、VPC网络下RDS For MySQL实例的数据订阅。数据源类型实时数据订阅支持的数据源类型包括： RDS For MySQLDRDS 其中，DRDS 不记录事务日志，所以如果需要订阅DRDS的实时增量数据，那么需要通过订阅DRDS底层挂载的RDS实例的增量日志来实现。订阅对象数据订阅的订阅对象可以为：库、表。用户可以根据需要订阅某几个表的增量数据。数据订阅将增量数据细分为数据变更(Data Manipulation Language 简称DML)和结构变更(Data Definition Language，简称DDL)，配置数据订阅时，可以选择需要订阅的具体数据变更类型。订阅通道订阅通道是进行增量数据订阅与消费的基本单元。如果要订阅RDS的增量数据，必须在数据传输控制台创建一个针对这个RDS实例的订阅通道。订阅通道会实时拉取RDS的增量数据，并将最新一段时间的增量数据保存在订阅通道中，用户可以使用数据传输提供SDK从这个订阅通道中订阅增量数据，并进行相应的消费。同时，用户可以在数据传输控制台进行订阅通道的创建、管理及删除等操作。一个订阅通道同时只能被一个下游SDK订阅消费，如果用户有多个下游需要订阅同一个RDS实例时，需要创建多个订阅通道。这些订阅通道订阅的RDS实例均为同一个实例ID。订阅通道在创建及运行过程中，不同阶段会处于不同的状态，具体如下表所示：通道状态状态说明可进行操作预检中订阅通道已经完成任务配置，正在进行启动之前的简单预检查删除订阅未启动迁移任务已经通过迁移之前的预检查，但是还没有启动订阅 - 开始订阅- 删除订阅初始化订阅通道正在进行启动初始化，一般需要1分钟左右删除订阅正常订阅通道正在正常拉取RDS实例的增量数据 - 查看示例代码- 查看订阅数据- 删除订阅异常订阅通道拉取RDS实例增量数据异常 - 查看示例代码- 删除订阅高级特性数据订阅支持多种特性，有效降低用户使用门槛，主要包括： (1) 动态增减订阅对象，在数据订阅过程中，用户可以随时增加或减少需要订阅的对象。 (2) 在线查看订阅数据，数据传输DTS控制台支持在线查看订阅通道中的增量数据。 (3) 修改消费时间点，数据订阅支持用户随时修改需要消费数据对应的时间点。 (4) 完善监控体系，数据订阅提供订阅通道状态、下游消费延迟的报警监控功能。用户可以根据业务敏感度，自定义消费延迟报警阈值。

2019-12-01 23:09:36 0 浏览量回答数 0

问题

如何创建订阅通道

DTS提供了RDS MySQL增量数据订阅的功能。要订阅消费增量数据，需要进行两个步骤的操作：在DTS控制台创建订阅RDS实例的订阅通道。使用DTS提供的SDK连接这个订阅通道，订阅并消费增量数据...

云栖大讲堂 2019-12-01 21:25:20 1154 浏览量回答数 0

问题

数据传输服务DTS的功能特性（什么是数据订阅？）

实时数据订阅功能旨在帮助用户获取RDS/DRDS的实时增量数据，用户能够根据自身业务需求自由消费增量数据，例如实现缓存更新策略、业务异步解耦、异构数据源数据实时同步及含复杂ETL的数据实时同步等多种业务场景。 ...

云栖大讲堂 2019-12-01 21:23:49 1106 浏览量回答数 0

回答

详细解答可以参考官方帮助文档下面详细介绍下创建一条订阅通道的配置步骤。购买订阅通道。登录数据传输DTS控制台，选择左侧的数据订阅，进入数据订阅页面。然后，点击页面右上角的创建数据订阅进入DTS购买页面。订阅通道支持包年包月及按量付费两种付费模式，可以根据需要选择不同的付费模式。在购买页面需要配置的参数包括：源实例地域源实例地域为需要订阅的RDS实例所在的地域。订购后不支持更换地域，所以选择时，请谨慎。数量数量为一次性购买的订阅通道的数量，如果购买的是按量付费实例，一次最多购买99条当购买完同步实例，返回数据传输控制台，点击新购链路右侧的“配置同步作业” 开始链路配置。订阅RDS实例ID配置。这个主要配置订阅通道名称及需要订阅的RDS实例ID。其中：订阅名称：订阅名称为订阅通道别名，没有唯一性要求。默认情况下，DTS为每个订阅通道自动生成一个名称，可以修改这个名称，为其配置一个具备业务意义的名称，便于后续的通道识别。RDS实例ID: 需要订阅增量数据对应的RDS实例的实例ID。当这些内容配置完成后，可以点击页面右下角的授权白名单并进入下一步。授权RDS实例白名单。这个步骤，主要是将DTS服务器IP添加到订阅RDS实例的白名单中。避免因RDS配置了白名单，DTS服务器不能连接RDS实例，从而导致订阅通道创建失败。为了保证订阅通道的稳定性，请勿将DTS服务器IP从RDS实例的白名单中删除。选择订阅对象。在这个步骤中，用户需要配置订阅的数据类型及订阅对象。其中: 订阅数据类型：DTS将订阅数据类型细分为数据变更、结构变更。数据变更是指DML(包含insert/delete/update)。结构变更是指DDL(例如：create/drop/alter table)。如果订阅了结构变更，那么DTS会将整个RDS实例的所有结构变更拉取出来，用户如果只需要部分DDL的话，需要在SDK消费的时候进行过滤。订阅对象：DTS的订阅对象粒度细分为库、表。即用户可以选择订阅某些库或者是订阅某几张表。当完成上面的配置后，即进入订阅通道启动之前的前置预检查阶段。预检查。当订阅通道配置完成后，DTS会进行前置预检查，当预检查通过后，可以点击右下角的开始订阅 ,启动订阅通道。启动订阅。当订阅通道刚创建完，会进入初始化阶段，这个阶段一般会持续1分钟左右。初始化完成后，即可在线查看订阅数据，或者使用SDK订阅增量数据。至此，完成数据订阅通道的配置。

2019-12-01 23:09:39 0 浏览量回答数 0

问题

如何创建数据订阅通道

数据订阅DTS提供的实时数据订阅功能，可以实时订阅RDS增量数据。轻松帮助业务解决轻量级缓存更新、业务异步解耦、含ETL逻辑的数据实时同步等场景。如果需要使用数据订阅功能，实时订阅消费RDS增量数据࿰...

云栖大讲堂 2019-12-01 21:24:16 1100 浏览量回答数 0

问题

启动订阅SDK时报get guid info failed，是什么原因？

这个是由于您在SDK中设置的订阅通道ID不对。需要将示例代码中的client.askForGUID("订阅通道ID");这里面的“订阅通道ID”替换成您要订阅的订阅通道对应的ID。...

云栖大讲堂 2019-12-01 21:27:08 752 浏览量回答数 0

回答

详细解答可以参考官方帮助文档这个是由于您在SDK中设置的订阅通道ID不对。需要将示例代码中的client.askForGUID("订阅通道ID");这里面的“订阅通道ID”替换成您要订阅的订阅通道对应的ID。

2019-12-01 23:31:02 0 浏览量回答数 0

回答

数据迁移 API 描述 CreateMigrationJob 购买数据迁移实例 ConfigureMigrationJob 配置数据迁移任务 StartMigrationJob 启动或重启数据迁移任务 SuspendMigrationJob 暂停数据迁移任务 StopMigrationJob 结束数据迁移任务 DescribeMigrationJobStatus 查询数据迁移任务状态 DescribeMigrationJobDetail 查询数据迁移任务详情 DeleteMigrationJob 删除数据迁移实例数据订阅 API 描述 CreateSubscriptionInstance 购买订阅实例 ConfigureSubscriptionInstance 配置订阅通道 StartSubscriptionInstance 启动订阅通道 ModifySubscriptionObject 修改订阅对象 ModifyConsumptionTimestamp 修改消费时间点 CreateConsumerGroup 新增消费组 ModifyConsumerGroupPassword 修改消费组密码 DescribeConsumerGroup 查询消费组详情 DescribeSubscriptionInstances 查询订阅实例列表 DescribeSubscriptionInstanceStatus 查询订阅通道状态 DeleteConsumerGroup 删除消费组 DeleteSubscriptionInstance 释放订阅实例数据同步 API 描述 CreateSynchronizationJob 购买同步实例 ConfigureSynchronizationJob 配置同步作业 StartSynchronizationJob 启动同步作业 SuspendSynchronizationJob 暂停同步作业 DescribeSynchronizationJobs 查询同步作业列表 DescribeSynchronizationJobStatus 查询同步作业状态 ModifySynchronizationObject 修改同步对象 DescribeSynchronizationObjectModifyStatus 查询同步对象变更状态 DeleteSynchronizationJob 删除同步实例 SwitchSynchronizationEndpoint 更改同步作业的数据库连接信息 DescribeEndpointSwitchStatus 查询更改数据库连接信息的任务执行状态监控报警 API 描述 ConfigureMigrationJobAlert 配置迁移任务的监控报警 DescribeMigrationJobAlert 查询迁移任务的监控报警设置 ConfigureSubscriptionInstanceAlert 配置订阅通道的监控报警 DescribeSubscriptionInstanceAlert 查询订阅通道的监控报警设置 ConfigureSynchronizationJobAlert 配置同步作业的监控报警 DescribeSubscriptionInstanceAlert 查询同步作业的监控报警设置

保持可爱mmm 2020-03-29 13:36:32 0 浏览量回答数 0

问题

如何修改订阅对象

DTS支持在订阅消费的过程中，动态增加/减少订阅对象。如果增加了订阅对象，那么修改完成后，订阅通道会从当前时间拉取新增订阅对象的增量数据。如果减少订阅对象，那么修改完成后，...

云栖大讲堂 2019-12-01 21:25:20 974 浏览量回答数 0

问题

如何查看订阅通道状态

描述当任务处于任意状态时，都可以调用这个接口查看订阅通道状态。可以查询的迁移状态包括：通道配置信息，通道状态，下游消费状态。请求参数参数名称数据类型是否必须参数描述A...

云栖大讲堂 2019-12-01 21:27:27 1074 浏览量回答数 0

问题

DTS提供的OpenAPI支持的API接口有哪些

本小节简单介绍DTS提供的OpenAPI支持的API接口。数据迁移 API接口描述ConfigureMigrationJob配置数据迁移任务StartMigrationJob启动或重启数据迁移任务SuspendMigrationJ...

云栖大讲堂 2019-12-01 21:27:21 1024 浏览量回答数 0

问题

如何查看订阅数据

DTS支持在线查看订阅数据，即可以在DTS控制台查看订阅通道中的增量数据，能够查看的时间范围为订阅通道的数据范围。本小节介绍在线查看订阅数据的方式，及数据记录的各个字段的含义。查看订阅数据入口...

云栖大讲堂 2019-12-01 21:25:39 1010 浏览量回答数 0

问题

如何修改消费位点

DTS支持在消费的过程中，随时修改消费时间点。一旦修改完消费时间点，那么下游SDK拉取到的增量数据从修改后的消费时间点开始。修改的消费时间点必须在订阅通道的数据范围之内。DTS目前只支持在控制台修改消费点...

云栖大讲堂 2019-12-01 21:25:20 995 浏览量回答数 0

问题

如果SDK退出后，过几天重启运行，不能成功订阅数据

这是因为数据订阅通道中保留数据的时间范围为1天，从［当前时间-1天 , 当天时间］,订阅通道会删除过期数据。所以如果上次SDK退出时最后一条消费数据的时间点对应的数据，不在当前订阅通道...

云栖大讲堂 2019-12-01 21:27:11 785 浏览量回答数 0

回答

详细解答可以参考官方帮助文档DTS控制台查看订阅数据的入口如下：只有正常和异常状态下的订阅通道可以查看订阅数据。处于初始化、预检查中的订阅通道不能查看订阅数据。

2019-12-01 23:09:47 0 浏览量回答数 0

问题

数据传输服务DTS中的名词解释有哪些

预检查预检查是迁移任务启动之前的必经阶段，主要是对影响迁移成功的前置条件进行检查。例如源目标实例的连通性，迁移账号的权限等的检查。如果预检查失败了，那么可以根据修复方法修复后，重...

云栖大讲堂 2019-12-01 21:24:02 952 浏览量回答数 0

问题

什么是RegionContex接口

setAccessKey(accessKey)设置安全凭证，参数为需要订阅数据的订阅通道对应的阿里云账号的AccessKey。setSecret(AccessKeySecret)设置安全凭证，参数为阿里云账号对应...

云栖大讲堂 2019-12-01 21:25:44 926 浏览量回答数 0

问题

一个sdk客户端可以订阅多个通道吗？

不能，目前数据传输服务的SDK还不能支持一个SDK订阅多个订阅通道的数据...

云栖大讲堂 2019-12-01 21:27:06 770 浏览量回答数 0

问题

如何解决订阅通道无法修改消费位点

这个一般是因为订阅通道还有下游在消费，可以先到DTS控制台查看消费来源IP，查看是否还有下游SDK在消费数据，如果有，那么需要先停止下游消费后，重新修改消费位点。具体的修...

云栖大讲堂 2019-12-01 21:27:11 717 浏览量回答数 0

问题

什么是ClusterClient接口

void addConcurrentListener(ClusterListener arg0)添加下游监听者，监听者加入到一个ClusterClient中，才可以订阅订阅通道中的增量数据。参数ClusterLi...

云栖大讲堂 2019-12-01 21:25:44 959 浏览量回答数 0

问题

数据订阅启动SDK报如下的错误：keep alive error，原因是什么？

如果数据订阅报如上的错误，一般原因可能有两个：1） SDK运行的服务器没有公网IP，不能连接数据传输服务的服务器 2）订阅通道的消费时间点不在订阅通道的数据范围之内...

云栖大讲堂 2019-12-01 21:27:05 816 浏览量回答数 0

回答

详细解答可以参考官方帮助文档如果数据订阅报如上的错误，一般原因可能有两个：1） SDK运行的服务器没有公网IP，不能连接数据传输服务的服务器 2）订阅通道的消费时间点不在订阅通道的数据范围之内

2019-12-01 23:31:02 0 浏览量回答数 0

问题

如何使用DTS提供的SDK容灾机制

为了简化用户使用SDK的复杂度，DTS实现了SDK容灾机制。这个机制依赖于SDK消费数据时，向DTS中控节点实时汇报消费时间点。本小节简单介绍如何使用DTS提供的SDK容灾机制。要求 SDK消费代码中&...

云栖大讲堂 2019-12-01 21:26:17 994 浏览量回答数 0

问题

如何修改订阅通道对象

描述订阅通道在未启动,启动失败,正常,异常状态，可以修改订阅对象当订阅通道状态为正常时，用户调用这个接口修改订阅对象后，数据传输服务直接调用启动接口，启动订阅通道当订阅通道状态...

云栖大讲堂 2019-12-01 21:27:27 963 浏览量回答数 0

问题

为什么控制台上的消费位点要比数据范围最大值还要大

因为订阅通道的数据范围更新频率为1分钟，而消费位点的更新频率为10秒。所以如果实时消费的话，消费位点的值可能比订阅通道数据范围的最大值要大...

云栖大讲堂 2019-12-01 21:27:10 612 浏览量回答数 0

回答

详细解答可以参考官方帮助文档下载并载入 SDK DemoDTS 提供的 JAVA SDK 支持的开发环境为：J2SE Development Kit (JDK) 1.5 或以上版本。下面以 Eclipse 工程为例，简单介绍 SDK 的安装步骤：到 DTS 数据订阅 SDK 下载页面下载 SDK 包以下以 Eclipse 为例导入下载到的 jar 包：在 Eclipse 上右键点击工程 -> Properties -> Java Build Path -> Libraries -> Add External JARs，选择 JAR 包的存放路径，将下载到的 JAR 包添加到工程中。选择 JAR 包，点击“OK”按钮，经过以上步骤，你就可以在工程中使用 DTS 订阅的 Java SDK 了。运行 DemoDTS 提供了 DTS SDK 的 Demo 示例，可以在 DTS 控制台的“查看示例代码”功能中复制这段示例代码。下面以 Eclipse 工程为例，简单介绍运行该 SDK Demo 的方式。在 Eclipse 中，在上面新建的工程中新建类 MainClass。打开生成的 Java 文件 MainClass，删除里面的代码模板。将示例代码黏贴在文件 MainClass 中。修改示例代码中的 AccessKeyID，AccessKeySecret，订阅通道 ID 三个配置项。其中，AccessKeyID/AccessKeySecret 为订阅实例所属阿里云账号的AccessKeyID/AccessKeySecret，订阅通道 ID 为需要订阅的数据订阅实例 ID，需要到数据传输 DTS 控制台中获取。 5.在 Eclipse 中右击该 Demo 文件 -> 运行方式 –> Java 应用程序，即成功运行示例 Demo。

2019-12-01 23:09:48 0 浏览量回答数 0

问题

数据订阅SDK中 usePublicIp=true 是什么意思？

数据订阅SDK配置 usePublicIp=true，表示SDK 通过公网访问DTS订阅通道...

云栖大讲堂 2019-12-01 21:27:13 805 浏览量回答数 0

回答

发布订阅(pub/sub)是一种消息通信模式，主要的目的是解耦消息发布者和消息订阅者之间的耦合，这点和设计模式中的观察者模式比较相似。pub /sub不仅仅解决发布者和订阅者直接代码级别耦合也解决两者在物理部署上的耦合。redis作为一个pub/sub server，在订阅者和发布者之间起到了消息路由的功能。订阅者可以通过subscribe和psubscribe命令向redis server订阅自己感兴趣的消息类型，redis将消息类型称为通道(channel)。当发布者通过publish命令向redis server发送特定类型的消息时。订阅该消息类型的全部client都会收到此消息。这里消息的传递是多对多的。一个client可以订阅多个 channel,也可以向多个channel发送消息

落地花开啦 2019-12-02 01:42:56 0 浏览量回答数 0

问题

消息服务的Queue如何推送？

用户使用已创建Queue作为Endpoint对Topic内容进行订阅；当有消息发布到Topic中时，Topic会通过内部数据通道，将Topic中的消息推送到各个订阅的Queue中。用户只需对订阅的Q...

轩墨 2019-12-01 22:07:59 1254 浏览量回答数 0

问题

如何启动订阅通道

描述通过这个接口启动订阅任务。只有通道处于未启动、启动失败或是暂停状态时，才能调用这个接口，启动订阅通道。请求参数参数名称数据类型是否必须参数描述ActionString是系统参数，...

云栖大讲堂 2019-12-01 21:27:28 1056 浏览量回答数 0

问答

订阅通道

云产品推荐

热门关键词

更多推荐