搜索本产品文档关键词
配置一键反向
所有文档
menu

数据传输服务 DTS

配置一键反向

接口说明

配置传输任务, 内容包括传输对象的映射关系, 数据库连接信息等;
注:任务配置完触发一键反向任务前置检查,接口同: 前置检查

请求结构

JSON
1POST /v{version}/task/{taskId}/newRollback/config
2Host: dts.baidubce.com    
3Authorization: authorization string  
4{
5    "taskName": "dtsTask1",
6    "openRollbackConfig": "true",
7    "dtsTaskPos": {
8        "type": "",
9        "dataType": [
10            "increment",
11            "schema",
12            "base"
13        ],
14        "srcConnection": {
15            "instanceType": "",
16            "dbType": "",
17            "region": "",
18            "dbUser": "",
19            "dbPass": "",
20            "dbServer": "",
21            "shardUrl": "",
22            "field_whitelist": "",
23            "field_blacklist": "",
24            "maxRetryTime": ""
25        },
26        "dstConnection": {
27            "instanceType": "",
28            "dbType": "",
29            "region": "",
30            "dbUser": "",
31            "dbPass": "",
32            "dbServer": ""
33        },
34        "schemaMapping": [],
35        "accountMapping": [],
36        "granularity": "",
37        "dtsGroupName": ""
38    },
39    "dtsTaskNeg": {
40        "type": "",
41        "dataType": [
42            "increment"
43        ],
44        "srcConnection": {
45            "instanceType": "",
46            "dbType": "",
47            "region": "",
48            "dbUser": "",
49            "dbPass": "",
50            "dbServer": "",
51            "field_whitelist": "",
52            "field_blacklist": "",
53            "shardUrl": ""
54        },
55        "dstConnection": {
56            "instanceType": "",
57            "dbType": "",
58            "region": "",
59            "dbUser": "",
60            "dbPass": "",
61            "dbServer": "",
62            "shardUrl": "",
63            "maxRetryTime": "",
64            "sqlType": "I,U,D"
65        },
66        "schemaMapping": [],
67        "accountMapping": [],
68        "granularity": "",
69        "dtsGroupName": ""
70    }
71}

请求体参数

参数名称
参数类型
是否必须
描述
示例值
参数位置
version String API版本号 "1" URL参数
taskId String 任务ID "dtsmxxxyyy" URL参数
taskName String 任务名称 taskName Request Body 参数
openRollbackConfig String 是否打开反向任务配置 true Request Body 参数
dtsTaskPos String 正向数据流 dtsTaskPos Request Body 参数
dtsTaskNeg String 反向数据流 dtsTaskNeg Request Body 参数

dtsTaskPos字段数据结构说明

参数名称
参数类型
是否必须
描述
示例值
参数位置
type String 任务类型(数据传输任务:migration;),目前仅支持数据传输任务 migration Request Body 参数
dataType String[] 传输数据类型数组(schema:结构迁移;base:全量迁移;increment:增量迁移) ["base"] Request Body 参数
srcConnection Connection 源端 srcConnection Request Body 参数
dstConnection Connection 目标端 dstConnection Request Body 参数
granularity String 传输任务的粒度(instance:实例级;dbtb:库表级) instance Request Body 参数
schemaMapping SchemaMapping schemaMapping schemaMapping Request Body 参数
accountMapping AccountMapping[] 账号迁移 accountMapping Request Body 参数
incrIgnoreType String 特殊DDL过滤 drop,truncate Request Body 参数
initPosition InitPosition 自定义同步点 initPosition Request Body 参数
dtsGroupName String 任务组名称 dtsGroupName Request Body 参数

dtsTaskNeg字段数据结构说明

反向数据流,结构同dtsTaskPos字段

Connection字段数据结构说明

参数名称
参数类型
是否必须
描述
示例值
instanceType String 实例类型 bcerds
region String 地域 bj
dbType String 数据库类型 mysql
dbUser String 数据库访问账号 dts_trans
dbPass String 数据库访问密码
dbPort Integer 数据库访问端口 3306
dbHost String 数据库ip或主机名 192.168.1.1
dbServer String 数据库ip或主机名.支持ip:端口,ip或域名与端口以英文冒号分隔,多个地址以英文逗号分隔 192.168.1.1:3306
shardUrl String 分片ip或主机名。支持ip:端口,ip或域名与端口以英文冒号分隔,多个地址以英文逗号分隔 192.168.1.1:3306,192.168.1.1:3306
announceServer String redis cluster announce IP/Port。若redis cluster 低于4.0或未设置announce IP/Port该字段填空即可。长度限制10240 192.168.1.1:3306,192.168.1.1:3306(与dbServer一一对应)
instanceId String 实例ID rdsmfgdti3d53f5
field_whitelist String 列过滤(白名单) field_whitelist
field_blacklist String 列过滤(黑名单) field_blacklist
srcDstFlag String 公有云上redis实例:必选。标识公有云上实例源端和目标端。源端取值"src",目标端取值"dst"。非公有云,非redis实例:可为空。) src
supportOnlineDDL String 同步Online DDL true,false
maxRetryTime String 重试时间 720
sqlType String 同步语句选择 I,U,D,Q
positionStrategy String 可选值:
1."fail"(如果给定offset不存在,这任务报错退出)
2."base"(如果给定offset不存在,则任务从全量开始重新同步)
fail
vpcId String 接入类型为bcegateway时,需要指定VPC ID 7175535d-6657-4fb2-aed0-942221111111
vpcShortId String 接入类型为bcegateway时,需要指定VPC短ID vpc-46k27rb9wppz
subnetShortId String 接入类型为bcegateway时,需要指定子网短ID sbn-qtm3d4eituqc

Schema字段数据结构说明

参数名称
参数类型
是否必须
描述
示例值
type String 需要传输的对象类型, 取值有: db(库), table(表), view(视图), function(函数), procedure(存储过程) table
src String 源库的schema名称 test.table_src
dst String 目标库的schema名称 test.table_dst
where String where过滤条件 where

AccountMapping字段数据结构说明

参数名称
参数类型
是否必须
描述
示例值
user String 用户 dts_user
hosts String[] 地址 ["%", "1.2.3.4", "10.10.10.1"]

InitPosition字段数据结构说明

参数名称
参数类型
是否必须
描述
示例值
type String 默认值offset offset
position String 填写redis实例replication backlog中有效有效的offset值,格式为:"9654766427"。若不填写则标识做全量+增量迁移 9654766427

响应头参数

除公共头域,无其它特殊头域。

响应体参数

响应体字段数据结构说明

参数名称
参数类型
是否必须
描述
示例值
dtsId String 任务ID dtsxxxyyyzzz

请求示例

JSON
1POST /v{version}/task/{taskId}/newRollback/config
2Host: dts.baidubce.com    
3Content-Type: application/json     
4Authorization: authorization string  
5
6
7{
8    "taskName": "dtsTask1",
9    "openRollbackConfig": "true",
10    "dtsTaskPos": {
11        "type": "migration",
12        "dataType": [
13            "increment",
14            "schema",
15            "base"
16        ],
17        "srcConnection": {
18            "instanceType": "public",
19            "dbType": "mongodbCluster",
20            "region": "bj",
21            "dbUser": "",
22            "dbPass": "",
23            "dbServer": "",
24            "shardUrl": "",
25            "field_whitelist": "",
26            "field_blacklist": "",
27            "maxRetryTime": "720"
28        },
29        "dstConnection": {
30            "instanceType": "public",
31            "dbType": "mongodbCluster",
32            "region": "bj",
33            "dbUser": "",
34            "dbPass": "",
35            "dbServer": ""
36        },
37        "schemaMapping": [],
38        "accountMapping": [],
39        "granularity": "instance",
40        "dtsGroupName": ""
41    },
42    "dtsTaskNeg": {
43        "type": "migration",
44        "dataType": [
45            "increment"
46        ],
47        "srcConnection": {
48            "instanceType": "public",
49            "dbType": "mongodbCluster",
50            "region": "bj",
51            "dbUser": "",
52            "dbPass": "",
53            "dbServer": "",
54            "field_whitelist": "",
55            "field_blacklist": "",
56            "shardUrl": ""
57        },
58        "dstConnection": {
59            "instanceType": "public",
60            "dbType": "mongodbCluster",
61            "region": "bj",
62            "dbUser": "",
63            "dbPass": "",
64            "dbServer": "",
65            "shardUrl": "",
66            "maxRetryTime": "720",
67            "sqlType": "I,U,D"
68        },
69        "schemaMapping": [],
70        "accountMapping": [],
71        "granularity": "instance",
72        "dtsGroupName": ""
73    }
74}

响应示例

JSON
1HTTP/1.1 200 OK
2
3{
4  "dtsId" : "dtsxxxyyyzzz"
5}
上一篇
数据校验
下一篇
一键反向查询前置检查结果