相关内容
SDK 数据订阅
数据订阅 sdk 下载单击下载 数据订阅 sdk version 2. 9.1。 运行原理拉取sdk 的拉取和确认消息是两个异步的线程同时在做的,拉取是按顺序拉取的,两个线程的执行分别独立是严格有序,但这两个线程之间是异步的。 拉取到的消息会按顺序调用用户注册的 notify 函数,sdk 保证每一条消息会推送一次,且只有一次...
数据订阅旧版
在 dts 控制台 购买并创建 tencentdb 实例的订阅通道。 使用 dts 数据订阅 sdk 连接订阅通道,订阅并消费增量数据。 订阅原理数据订阅通过模拟从库向主库获取对应 binlog 内容进行分析,架构图如下,通过解析 binlog,按照订阅通道配置的库表进行分析,对主库几乎无影响。 订阅的消息内容目前默认保留最近1天。 以...
数据订阅 Kafka 版
通过数据订阅功能您可以轻松实现源库的增量数据变更订阅,方便您搭建云数据库和异构系统之间的数据同步,如缓存更新,etl(数据仓库技术)实时同步,业务异步解耦等。 说明: 数据订阅 kafka 版数据订阅消息在中间存储 kafka 中默认保留1天(24小时),请及时消费,否则可能导致订阅数据丢失。 前提条件已准备好待...

一键订阅数据库健康日报教程
如果不幸出现了故障,可以第一时间看到dbbrain给出的实时诊断信息和从鹅厂专家级工程师数十年数据库运维经验演变而来的优化建议。 数据库日报提供的功能包括:数据库资产概况(运行中、隔离中、已过期、将过期)mysql实例地域分布任务执行情况汇总监控指标峰值总量实例排行(cpu、内存、访问、慢日志等)订阅数据库...
使用Kafka订阅数据库的实时Binlog
我们可以不必使用官方提供的sdk订阅binlog,而只需要使用kafka客户端,使用kafka的api实现binlog订阅。 官方文档:使用kafka客户端消费订阅数据https:help.aliyun.comdocument_detail121239.html? spm=a2c4g. 11186623. 6.785. 6d4d6d2aioqqqm官方提供的demo:https:github.comliorogersubscribe_example,该demo由龙...
重置数据订阅
数据订阅 kafka 版支持通过重新配置任务,来删除当前订阅实例的信息和数据,并重新配置新的数据订阅任务。 本文为您介绍如何通过控制台重置数据订阅。 前提条件已创建 数据订阅 kafka 版。 数据订阅状态为“运行中”或“异常中”。 操作步骤登录 dts 控制台,在左侧导航选择【数据订阅】,进入数据订阅页面。 在数据...
配置数据订阅通道
本接口用于配置数据订阅,只有在未配置状态的订阅实例才能调用此接口。 默认接口请求频率限制:20次秒。 注意:本接口支持金融区地域。 由于金融区和非金融区是隔离不互通的,因此当公共参数 region 为金融区地域(例如 ap-shanghai-fsi)时,需要同时指定带金融区地域的域名,最好和 region 的地域保持一致,例如...
重置数据订阅实例
本接口(resetsubscribe)用于重置数据订阅实例,已经激活的数据订阅实例,重置后可以使用activatesubscribe接口绑定其他的数据库实例默认接口请求频率限制:20次秒。 注意:本接口支持金融区地域。 由于金融区和非金融区是隔离不互通的,因此当公共参数 region 为金融区地域(例如 ap-shanghai-fsi)时,需要同时指定...
数据订阅库表到本地
本文将以一个简单案例来说明数据订阅中拉取对应表到本地文件的功能,并且提供简易 localdemo 下载 。 以下操作将在 centos 操作系统中完成。 配置环境java 环境配置yum install java-1. 8. 0-openjdk-devel 数据订阅 sdk 下载 获取密钥登录 访问管理控制台 获取密钥。 选择数据订阅登录 dts 控制台,选择左侧的【数据...
数据订阅库表到 Kafka
本文以一个简单案例来说明数据订阅中拉取对应表到 kafka 的功能,并提供简易 kafkademo 下载。 配置环境操作系统:centos相关下载数据订阅 sdkslf4j 组件kafka-clients java 环境配置 yum installjava-1. 8. 0-openjdk-devel 安装 kafka请参考 kafka 介绍 安装 kafka。 启动之后创建一个 testtop 主题。 binkafka...
获取数据订阅实例列表
本接口(describesubscribes)获取数据订阅实例信息列表,默认分页,每次返回20条默认接口请求频率限制:20次秒。 注意:本接口支持金融区地域。 由于金融区和非金融区是隔离不互通的,因此当公共参数 region 为金融区地域(例如 ap-shanghai-fsi)时,需要同时指定带金融区地域的域名,最好和 region 的地域保持一致...
修改数据订阅实例的名称
本接口(modifysubscribename)用于修改数据订阅实例的名称默认接口请求频率限制:20次秒。 注意:本接口支持金融区地域。 由于金融区和非金融区是隔离不互通的,因此当公共参数 region 为金融区地域(例如 ap-shanghai-fsi)时,需要同时指定带金融区地域的域名,最好和 region 的地域保持一致,例如:dts.ap-shanghai...
数据协作平台
企业用户可通过数据共享平台,在国家法律法规允许的范围内发布数据; 个人用户和其他企业用户可通过数据共享平台订阅已发布的数据...
修改订阅对象
在修改订阅对象页面,重新选择订阅类型,并编辑订阅对象,单击【保存】。 返回订阅列表,订阅实例进入启动中状态,进行任务预检查并初始化。 启动成功后,订阅实例进入运行中状态,即可使用 kafka 客户端消费订阅数据...
数据结构
名称类型必选描述 publishdatabasestring是发布数据库名称subscribedatabasestring是订阅数据库名称databasetuplestatus该数据结构表示具有发布订阅关系的两个数据库,以及其之间发布订阅的状态信息。 被如下接口引用:describepublishsubscribe。 名称类型描述 publishdatabasestring发布数据库名称subscribe...
数据结构
databasenamestring是订阅数据库的名称注意:此字段可能返回 null,表示取不到有效值。 tablenamesarray of string否订阅数据库中表名称数组注意:此字段可能返回 null,表示取不到有效值。 subscriberegionconf数据订阅地域售卖信息被如下接口引用:describeregionconf。 名称类型描述 regionnamestring地域名称,如...
查询订阅实例配置
输出参数 参数名称类型描述 subscribeidstring订阅实例idsubscribenamestring订阅实例名称 channelidstring订阅通道productstring订阅数据库类型 instanceidstring被订阅的实例instancestatusstring被订阅的实例的状态,可能的值有running,offline,isolate subsstatusstring订阅实例状态,可能的值有unconfigure-未...
数据传输服务
mongodb 数据迁移,mysql 数据在线导入,mysql 离线迁移数据,使用 dts 进行迁移,使用 redis-port 进行迁移,数据订阅库表到本地,postgresql 数据迁移,阿里 rds 迁移至 tencentdb,数据订阅库表到 redis,订阅正则表达式,数据订阅库表到 kafka,订阅常见问题,api 概览,请求结构,公共参数,签名方法,返回结果,更新历史,查询...
数据消费 Demo
数据订阅 kafka 版中,您可以直接通过0.11版本以上的 kafka 客户端进行消费订阅数据,本文为您提供了 java 和 go 两种语言的客户端消费 demo。 消费 demo 下载参考下表下载数据订阅 kafka 版客户端消费 demo 代码:demo 语言下载地址 go地址 java地址 配置参数说明 参数说明 brokerlist数据订阅kafka 的内网访问地址 ...
数据订阅案例
另外如果订阅整库的话,后续新增的表也是会在原有订阅通道出现,不需要对原订阅通道进行新增配置操作。 目前只支持 cdb for mysql5.6,后续会很快支持 cdb for mysql5.7。 数据订阅暂不支持view,触发器和外键。 数据订阅初次配置需要对相关 binlog_row_image 参数做调整,会根据符合条件自动 kill 老的 session 使...