文档中心
文档
备案
控制台
登录
立即注册
导航
数据库传输服务
搜索目录或文档标题
搜索目录或文档标题
产品动态
新功能发布记录
产品简介
什么是数据库传输服务
什么是全增一体
应用场景
产品规格
约束和限制
使用限制（源库为 MySQL）
使用限制（源库为 MongoDB）
使用限制（源库为 PostgreSQL）
使用限制（源库为 Redis）
术语表
产品计费
计费概述
计费方式
计费项
转包年包月
续费管理
到期或欠费说明
变配和退订说明
查看账单
预检查项
预检查项（MySQL）
预检查项（Redis）
预检查项（MongoDB）
预检查项（PostgreSQL）
预检查项（ElasticSearch）
预检查项（Kafka & RocketMQ）
（邀测）预检查项（数据校验）
查看预检查详情
权限管理
如何授权用户实现跨账号传输数据
主账号权限管理
子用户权限管理
快速入门
添加 DTS 服务器的 IP 地址段
数据迁移快速入门
数据迁移流程
准备工作
创建并启动迁移任务
数据订阅快速入门
数据订阅流程
准备工作
创建并启动数据订阅任务
数据同步快速入门
数据同步流程
准备工作
创建并启动同步任务
数据迁移
迁移方案概览
创建 MySQL 数据迁移任务
源为火山引擎版 MySQL
迁移至火山引擎版 MySQL
迁移至火山引擎版 veDB MySQL
迁移至公网自建 MySQL
迁移至专有网络 MySQL
源为火山引擎版 veDB MySQL
迁移至火山引擎版 MySQL
迁移至火山引擎版 veDB MySQL
迁移至公网自建 MySQL
迁移至专有网络 veDB MySQL
源为公网自建 MySQL
迁移至火山引擎版 MySQL
迁移至火山引擎版 veDB MySQL
迁移至公网自建 MySQL
迁移至专有网络 MySQL
源为专有网络 MySQL
迁移至火山引擎版 MySQL
迁移至火山引擎版 veDB MySQL
迁移至公网自建 MySQL
迁移至专有网络 MySQL
创建 PostgreSQL 数据迁移任务
源为火山引擎版 PostgreSQL
迁移至火山引擎版 PostgreSQL
迁移至公网自建 PostgreSQL
迁移至专有网络 PostgreSQL
源为公网自建 PostgreSQL
迁移至火山引擎版 PostgreSQL
迁移至公网自建 PostgreSQL
迁移至专有网络 PostgreSQL
源为专有网络 PostgreSQL
迁移至火山引擎版 PostgreSQL
迁移至公网自建 PostgreSQL
迁移至专有网络 PostgreSQL
创建 Redis 数据迁移任务
源为火山引擎版 Redis
迁移至火山引擎版 Redis
迁移至公网自建 Redis
迁移至专有网络 Redis
源为公网自建 Redis
迁移至火山引擎版 Redis
迁移至公网自建 Redis
迁移至专有网络 Redis
源为专有网络 Redis
迁移至火山引擎版 Redis
迁移至公网自建 Redis
迁移至专有网络 Redis
创建 MongoDB 数据迁移任务
源库为火山引擎版 MongoDB
迁移至火山引擎版 MongoDB
迁移至公网自建 MongoDB
迁移至专有网络 MongoDB
源库为公网自建 MongoDB
迁移至火山引擎版 MongoDB
迁移至公网自建 MongoDB
迁移至专有网络 MongoDB
源为专有网络 MongoDB
迁移至火山引擎版 MongoDB
迁移至公网自建 MongoDB
迁移至专有网络 MongoDB
配置迁移任务
配置迁移延迟隔离
变更迁移任务规格
修改迁移任务源库或目标库的账号密码
管理迁移任务标签
调整全量迁移速率
复制迁移任务
查看迁移任务
查看迁移进度
暂停迁移任务
启动迁移任务
终止迁移任务
重试迁移任务
删除迁移任务
查看迁移任务配置
导出迁移任务列表
数据订阅
订阅方案概览
数据订阅格式
创建 MySQL 数据订阅任务
创建火山引擎版 MySQL数据订阅任务
创建火山引擎版 veDB MySQL数据订阅任务
创建公网自建 MySQL数据订阅任务
创建专有网络 MySQL 数据订阅任务
创建 PostgreSQL 数据订阅任务
创建火山引擎版 PostgreSQL数据订阅任务
创建公网自建 PostgreSQL数据订阅任务
创建专有网络 PostgreSQL 订阅任务
消费订阅数据
新建消费组
编辑消费组
变更订阅对象
修改订阅任务源库的账号密码
管理订阅任务标签
查看订阅任务
查看订阅进度
启动订阅任务
终止订阅任务
重试订阅任务
删除订阅任务
查看订阅任务配置
导出订阅任务列表
数据同步
同步方案概览
创建 MySQL 数据同步任务
源为火山引擎版 MySQL
同步至火山引擎版 MySQL
同步至火山引擎版 veDB MySQL
同步至公网自建 MySQL
同步至火山引擎版 ElasticSearch
同步至专有网络 ElasticSearch
同步至公网自建 ElasticSearch
同步至专有网络 MySQL
源为火山引擎版 veDB MySQL
同步至火山引擎版 MySQL
同步至火山引擎版 veDB MySQL
同步至公网自建 MySQL
同步至火山引擎版 ElasticSearch
同步至专有网络 ElasticSearch
同步至公网自建 ElasticSearch
同步至专有网络 MySQL
源为公网自建 MySQL
同步至火山引擎版 MySQL
同步至火山引擎版 veDB MySQL
同步至公网自建 MySQL
同步至火山引擎版 ElasticSearch
同步至专有网络 ElasticSearch
同步至公网自建 ElasticSearch
同步至专有网络 MySQL
源为专有网络 MySQL
同步至火山引擎版 MySQL
同步至火山引擎版 veDB MySQL
同步至公网自建 MySQL
同步至专有网络 MySQL
同步至火山引擎版 ElasticSearch
同步至专有网络 ElasticSearch
同步至公网自建 ElasticSearch
创建 Redis 数据同步任务
火山引擎版 Redis 同步至火山引擎版 Redis
创建 PostgreSQL 数据同步任务
源为火山引擎版 PostgreSQL
同步至火山引擎版 PostgreSQL
同步至公网自建 PostgreSQL
同步至专有网络 PostgreSQL
源为公网自建 PostgreSQL
同步至火山引擎版 PostgreSQL
同步至公网自建 PostgreSQL
同步至专有网络 PostgreSQL
源为专有网络 PostgreSQL
同步至火山引擎版 PostgreSQL
同步至公网自建 PostgreSQL
同步至专有网络 PostgreSQL
创建 MongoDB 数据同步任务
源为火山引擎版 MongoDB
同步至火山引擎版 MongoDB
同步至公网自建 MongoDB
同步至专有网络 MongoDB
源为公网自建 MongoDB
同步至火山引擎版 MongoDB
同步至公网自建 MongoDB
同步至专有网络 MongoDB
源为专有网络 MongoDB
同步至火山引擎版 MongoDB
同步至公网自建 MongoDB
同步至专有网络 MongoDB
数据同步拓扑
配置正向同步
配置反向同步
修改同步对象
查看同步任务
查看同步进度
配置同步延迟隔离
变更同步任务规格
修改同步任务源库或目标库的账号密码
管理同步任务标签
调整全量同步速率
复制同步任务
暂停同步任务
启动同步任务
重试同步任务
终止同步任务
删除同步任务
查看同步任务配置
调转双向同步任务的 DDL 同步方向
导出同步任务列表
数据源管理
ETL 任务管理
ETL 简介
DSL 语法
在 DTS 同步或订阅任务中配置 ETL
通过 ETL Playground 工具调试 ETL 规则
（邀测）数据校验
数据校验简介
配置数据校验
数据校验任务管理
监控告警
监控指标说明
事件指标说明
通过控制台配置监控和告警
配置 DTS 任务指标告警策略
配置 DTS 事件告警
查看监控数据
查看 DTS 告警历史
查看 DTS 事件信息
最佳实践
数据迁移最佳实践
通过 DTS 实现本地自建数据库的上云
使用 DTS 将阿里云的云数据库 Redis 版迁移至火山引擎
使用 DTS 迁移华为云分布式缓存服务 DCS 单机或主备的实例数据至火山引擎
迁移火山引擎副本集 MongoDB 实例至火山引擎分片集群 MongoDB 实例
数据订阅最佳实践
通过 Kafka 消费火山引擎 Proto 格式的订阅数据
通过 Kafka 消费 Canal Proto 格式的订阅数据
通过 RocketMQ 消费火山引擎 Proto 格式的订阅数据
通过 RocketMQ 消费 Canal Proto 格式的订阅数据
跨火山引擎账号实现数据传输
API 参考
API 发布历史
API 概览
调用方式
请求结构
公共参数
签名机制
返回结果
计费
ModifyInstanceOrder
数据传输
CreateTransmissionTask
DescribeTransmissionTaskProgress
DescribeTransmissionTasks
DescribeTransmissionTaskInfo
StartTransmissionTask
ResumeTransmissionTask
StartTransmissionTasks
ResumeTransmissionTasks
DeleteTransmissionTask
DeleteTransmissionTasks
ModifyTransmissionTask
RetryTransmissionTask
RetryTransmissionTasks
SuspendTransmissionTask
SuspendTransmissionTasks
StopTransmissionTask
StopTransmissionTasks
SpawnSwimmingLane
SetBiSyncDDLSource
数据订阅（消费组管理）
CreateSubscriptionGroup
DescribeSubscriptionGroups
DescribeSubscriptionGroupProgress
DeleteSubscriptionGroup
UpdateSubscriptionGroup
标签管理
AddTagsToResource
DescribeTagsByResource
RemoveTagsFromResource
数据校验
CreateDataValidationTask
DescribeDataValidationResult
DescribeDataValidationTasks
SuspendDataValidationTask
ResumeDataValidationTask
DeleteDataValidationTask
StopDataValidationTask
预检查
PreCheckAsync
GetAsyncPreCheckResult
附录
错误码
数据结构
SDK 参考
概述
Python SDK
下载安装 SDK
初始化客户端
代码示例
Go SDK
下载安装 SDK
初始化客户端
代码示例
常见问题
常见问题概览
产品通用 FAQ
DTS 目前支持哪些数据库?
DTS 支持哪些网络场景？
DTS 支持哪些实例接入方式？
DTS 是否支持断点续传？
在任务报错，提交工单联系技术支持时需要提供什么信息？
数据库传输服务 DTS 支持跨账号实现数据迁移或同步吗？
产品计费 FAQ
数据库传输服务 DTS 支持哪些计费方式？
按量付费是否支持转换为包年包月？
包年包月是否支持转换为按量付费？
任务到期或欠费后的影响是什么？
流量费指的是什么费用？
为什么数据库传输服务 DTS 有零折优惠，创建任务时一直提示余额不足？
传输任务 FAQ
使用 DTS 进行数据迁移时，源数据库的数据会不会被删掉？
增量迁移会影响业务吗?
在全量迁移任务进行中，可以手动结束迁移任务吗？
增量数据迁移任务为何一直在进行中不会结束？
为什么在数据同步任务中，全量初始化任务长时间内无进展？
是否支持变更数据迁移的链路规格？
为何在迁移进度页签下看不到某些迁移类型？
MySQL 结构迁移或结构初始化中，数据库对象的 DEFINER 如何设置？
为什么我在执行全量迁移或全量初始化任务后，目标数据库的磁盘使用量远远大于原实例的磁盘使用量？
在数据迁移或同步任务中，导致任务延迟的可能原因是什么？
如何获取实例的 GTID_EXECUTED？
在专有网络的迁移或同步任务中，为什么私有网络内会莫名出现多个以 dts_shuttle 开头的网卡？
如何将友商云 Redis 数据库的数据迁移到火山引擎缓存数据库 Redis 中？
在迁移或同步任务中，出现 Binlog Purged 导致增量任务断流失败时，怎么办？
为什么给数据库的普通账号添加了所有自定义权限后，预检查依然会失败？
全量迁移或同步完成后，开始进行增量迁移或同步时，是否有延时？
在源端无增量数据的前提下，为什么任务列表中全量迁移或全量初始化的进度一直显示在 99% 无进展？
在迁移或同步 MySQL 类型的任务时，造成数据差异的原因是什么？
迁移或同步完成后，为什么目标端的表的数量少于源端的表的数量？
在数据迁移或同步过程中，如果遇到 DTS 暂未支持的版本或表结构较多、数据量较少导致迁移同步较慢怎么办？
PostgreSQL 类型的迁移任务完成后，为什么目标端的文件会大于源端文件？
在数据迁移或同步 MySQL 类型任务时，造成数据差异的原因是什么？
在同一个实例内进行数据迁移时，将 A 表内的数据同步至空数据库的 B 表内，需要重命名表的名称吗？
为什么 JSON 类型字段的数据 Key 不保序？
在数据订阅过程中为什么数据的行数和 Binlog Event 不一致？
通过 DTS 完成数据同步后，遇到数据离散、Page 空洞很大，怎么办？
为什么在 Redis 为目标库的任务时会报错 OOM ？
为什么 Redis 为目标库时任务会报错 OOM ？
DTS 迁移或同步过程中，是否会锁表？对源数据库是否有影响？
如何快速完成 MySQL 类型数据的迁移或同步？
在迁移或同步过程中，为什么迁移或同步任务的进度一直显示为 0%?
在创建数据传输任务时，连通实例时如果报错怎么办？
故障排查
在专有网络数据传输过程中，如果遇到网络环境不稳定怎么办？
在任务执行过程中，导致任务执行失败的原因是什么？
在迁移或同步任务中，导致源端和目标端数据不一致的原因是什么？
当源库为 MySQL 时，开启 Binlog 日志，并设置参数 binlog_format 为 row，binlog_row_image 为 full 后，我该如何确保参数格式会立即生效？
遇到报错 Error 4109 (HY000): Failed to generate invisible primary key xxxxxx. 怎么办？
在进行 MySQL 到 ElasticSearch 的数据同步时，遇到本文介绍的报错怎么办？
预检查 FAQ
报错源库参数 gtid_mode 和预期不一致，期望是：ON，但设置为了：OFF，怎么办？
相关协议
数据库产品和服务条款
服务等级协议
文档首页
/
数据库传输服务
/
预检查项
/
预检查项（Kafka & RocketMQ）
预检查项（Kafka & RocketMQ）
最近更新时间：2024.02.01 16:26:13
首次发布时间：2023.02.23 11:13:22
我的收藏
文档反馈
数据库传输服务 DTS 将消息订阅到自有中间件 Kafka 或 RocketMQ 时，会先对数据库进行各项检查。本文介绍检查项的详细信息。
检查项
数据库类型
检查范围
级别
检查内容
备注
Topic 和权限
目标库
订阅
Error
检查消息队列 Kafka 版或消息队列 RocketMQ 版中是否存在给定 Topic 且拥有该 Topic 的写权限。
当将数据订阅到火山引擎 ECS 自建 Kafka 时，级别为 Warning。