查询任务列表
更新时间:2025-02-20
接口说明
查看所有数据传输任务列表
请求结构
JSON
1POST /v{version}/task/list
2Host: dts.baidubce.com
3Authorization: authorization string
4
5{
6 "maxKeys" : 15,
7 "marker" : "1",
8 "type" : "migration"
9}
请求参数
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 | 参数位置 |
---|---|---|---|---|---|
version | String | 是 | API版本号 | "1" | URL参数 |
type | String | 是 | 任务类型 | 单向任务:"migration"、双向同步任务:"bidirect"、 任务组:"group"、一键反向:"rollback"; 传空时返回所有类型任务 | Request Body 参数 |
marker | String | 否 | 分页参数,初次请求无需设置,后续请求使用上次响应中的nextMarker | 1 | Request Body 参数 |
maxKeys | Integer | 否 | 分页参数,每页数据条数,默认为 10 | 15 | Request Body 参数 |
响应头参数
除公共头域,无其它特殊头域。
响应体参数
响应体字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
task | List<Task> | 是 | 任务数组 | task |
nextMarker | String | 是 | 分页参数,下一页标记 | dtsmxxxyyy |
maxKeys | Integer | 是 | 分页参数,数据条数最大值 | 10 |
truncated | Boolean | 是 | 是否截断 | false |
Task字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
dtsId | String | 是 | 任务ID | dtsmxxyy1234 |
taskName | String | 是 | 任务名称 | dtsmxxyy1234 |
status | String | 是 | 任务状态 |
finished |
dataType | String[] | 是 | 传输数据类型数组(schema:结构迁移;base:全量迁移;increment:增量迁移) | ["base", "increment"] |
region | String | 是 | 地域 | bj |
createTime | String | 是 | 创建时间 | 2020-12-10T13: 24: 10Z |
srcConnection | Connection | 是 | srcConnection | srcConnection |
dstConnection | Connection | 是 | dstConnection | dstConnection |
schemaMapping | SchemaMapping | 是 | schemaMapping | schemaMapping |
runningTime | Integer | 是 | 任务已运行时长 | 20 |
subStatus | List<SubStatus> | 是 | 子任务状态 | |
dynamicInfo | DynamicInfo | 是 | dynamicInfo | dynamicInfo |
errmsg | String | 是 | 执行失败时返回的错误信息, 执行成功时为空字符串 | errmsg |
sdkRealtimeProgress | String | 是 | (只限数据订阅)任务实时进度, UTC格式 | sdkRealtimeProgress |
granularity | String | 是 | 传输任务的粒度,目前只区分实例级和库表级两种 | dbtb |
subDataScope | SubDataScope | 是 | (只限数据订阅)订阅通道数据范围 | subDataScope |
payInfo | PayInfo | 是 | 付费信息 | payInfo |
lockStatus | String | 是 | 任务是否被锁定, 取值有: unlock, lockExpiration | unlock |
initPosition | InitPosition | 是 | 自定义同步点 | initPosition |
accountMapping | AccountMapping[] | 是 | 账号迁移 | accountMapping |
incrIgnoreType | String | 是 | 特殊DDL过滤 | drop,truncate |
statistic | Statistic | 是 | DTS任务性能统计数据。包含:readSpeed(读取速率, 行/s)、writeSpeed(写入速率, 行/s) | readSpeed |
checksumResult | ChecksumResult | 是 | 校验结果,可能值:CONSISTENT(一致),INCONSISTENT(不一致),NONE(未知,校验任务运行未结束) | CONSISTENT |
dtsIdPos | String | 是 | 双向同步任务时,正向任务ID | dtsmxxyy1234 |
dtsIdNeg | String | 是 | 双向同步任务时,反向任务ID | dtsmxxyy1234 |
dtsTaskPos | DtsTaskPos | 是 | 双向同步任务时,正向任务信息 | dtsTaskPos |
dtsTaskNeg | DtsTaskNeg | 是 | 双向同步任务时,反向任务信息 | dtsTaskNeg |
dtsTasks | DtsTasks[] | 是 | 任务组任务时,子任务信息 | dtsTasks |
bindTags | List<BindTags> | 否 | 绑定标签 | BindTags |
Connection字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
instanceType | String | 否 | 实例类型 | bcerds |
region | String | 否 | 地域 | bj |
dbType | String | 否 | 数据库类型 | mysql |
dbUser | String | 否 | 数据库访问账号 | dts_trans |
dbPass | String | 否 | 数据库访问密码 | dbPass |
dbPort | Integer | 否 | 数据库访问端口 | 3306 |
dbHost | String | 否 | 数据库ip或主机名 | 192.168.1.1 |
instanceId | String | 否 | 实例ID | rdsmfgdti3d53f5 |
field_whitelist | String | 否 | 列过滤(白名单) | field_whitelist |
field_blacklist | String | 否 | 列过滤(黑名单) | field_blacklist |
supportOnlineDDL | String | 否 | 同步Online DDL | true,false |
maxRetryTime | String | 否 | 重试时间 | 720 |
sqlType | String | 否 | 同步语句选择 | I,U,D,Q |
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 |
SubStatus字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
s | String | 是 | 结构 | running |
b | String | 是 | 全量 | running |
i | String | 是 | 增量 | running |
DynamicInfo字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
schema | List<DynamicInfoSchema> | 是 | DynamicInfoSchema | DynamicInfoSchema |
base | List<DynamicInfoBase> | 是 | DynamicInfoBase | DynamicInfoBase |
increment | List<DynamicInfoIncrement> | 是 | DynamicInfoIncrement | DynamicInfoIncrement |
DynamicInfoSchema字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
current | String | 是 | 已迁移schema数 | 800 |
count | String | 是 | 迁移总schema数 | 1000 |
speed | String | 是 | 迁移速度 | 500 |
expectFinishTime | String | 是 | 预测剩余时间(s) | 20 |
DynamicInfoBase字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
current | String | 是 | 已迁移数据行数 | 800 |
count | String | 是 | 迁移总数据行数 | 1000 |
speed | String | 是 | 迁移速度 | 500 |
expectFinishTime | String | 是 | 预测剩余时间(s) | 20 |
DynamicInfoIncrement字段数据结构说明
参数名称 | 参数类型 | 描述 | 示例值 | |
---|---|---|---|---|
delay | String | 增量同步延迟(单位秒) "-1": 代表未知 | -1、0、13、102等 | |
position | String | 同步位点 | mysql的格式例如mysql-bin.000000:123456 | |
syncStatus | String | 同步任务状态 | "正常" 或 "异常" |
SubDataScope字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
startTime | String | 是 | 开始时间 | startTime |
endTime | String | 是 | 结束时间 | endTime |
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"。若不填写则标识做全量+增量迁移 |
PayInfo字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
productType | String | 是 | 付费方式,预付费(prepay)、后付费(postpay) | postpay |
sourceInstanceType | String | 是 | 源端实例类型(OnBce:百度智能云数据库;OffBce:自建数据存储) | OnBce |
targetInstanceType | String | 是 | 目标端实例类型(OnBce:百度智能云数据库;OffBce:自建数据存储) | OnBce |
crossRegionTag | Integer | 是 | 跨地域标识(0:同地域;1:跨地域) | 0 |
createTime | Long | 是 | 资源创建时间,UNIX 时间戳(毫秒数) | 1607606657000 |
standard | String | 是 | 规格(Large:大规格;目前仅支持大规格) | Large |
endTime | Long | 是 | UNIX 时间戳(毫秒数) | 1607606657000 |
DtsTaskPos字段数据结构说明
dtsTaskPos 字段,即双向同步任务时,正向任务信息,所以该字段的值结构跟任务本身结构一致。
DtsTaskNeg字段数据结构说明
dtsTaskNeg 字段,即双向同步任务时,反向任务信息,所以该字段的值结构跟任务本身结构一致。
DtsTasks字段数据结构说明
dtsTasks 字段,即任务组任务时,子任务信息,所以该字段的值结构跟任务本身结构一致。
BindTags字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
tagKey | String | 是 | 标签 key | 默认项目 |
tagValue | String | 是 | 标签 value | dtsTask1 |
请求示例
JSON
1POST /v1/task/list
2
3Host: dts.baidubce.com
4ContentType: application/json
5Authorization: bce-auth-v1/5a6f0606bf5e48f29dd132aa76aa5182/2017-06-12T13:13:05Z/1800/content-type;host;x-bce-date/8baeafe6bfc35b0cf6205e87e4ce6c0dbb442375951ace4d16e6c7a4dab95943
6{
7 "maxKeys" : 15,
8 "marker" : "1",
9 "type" : "migration"
10}
响应示例
JSON
1HTTP/1.1 200 OK
2
3{
4 "nextMarker" : "dtsmxxxyyy",
5 "task" : [ {
6 "subDataScope" : {
7 "startTime" : "startTime",
8 "endTime" : "endTime"
9 },
10 "schemaMapping" : [ {
11 "dst" : "test.table_dst",
12 "src" : "test.table_src",
13 "where" : "where",
14 "type" : "table"
15 }, {
16 "dst" : "test.table_dst",
17 "src" : "test.table_src",
18 "where" : "where",
19 "type" : "table"
20 } ],
21 "dataType" : [ "schema", "base" ],
22 "dtsId" : "dtsmxxyy1234",
23 "errmsg" : "errmsg",
24 "runningTime" : 20,
25 "dtsIdNeg" : "dtsmxxyy1234",
26 "subStatus" : [ {
27 "b" : "running",
28 "s" : "running",
29 "i" : "running"
30 }, {
31 "b" : "running",
32 "s" : "running",
33 "i" : "running"
34 } ],
35 "dtsIdPos" : "dtsmxxyy1234",
36 "sdkRealtimeProgress" : "sdkRealtimeProgress",
37 "lockStatus" : "unlock",
38 "createTime" : "2020-12-10T13: 24: 10Z",
39 "granularity" : "dbtb",
40 "dtsTaskNeg" : { },
41 "taskName" : "dtsmxxyy1234",
42 "region" : "bj",
43 "srcConnection" : {
44 "dbPass" : "dbPass",
45 "dbPort" : 3306,
46 "instanceId" : "rdsmfgdti3d53f5",
47 "instanceType" : "bcerds",
48 "dbUser" : "_dts_trans_",
49 "field_whitelist" : "field_whitelist",
50 "dbType" : "mysql",
51 "dbHost" : "192.168.1.1",
52 "field_blacklist" : "field_blacklist",
53 "region" : "bj"
54 },
55 "dynamicInfo" : {
56 "schema" : [ {
57 "expectFinishTime" : "20",
58 "current" : "800",
59 "count" : "1000",
60 "speed" : "500"
61 }, {
62 "expectFinishTime" : "20",
63 "current" : "800",
64 "count" : "1000",
65 "speed" : "500"
66 } ],
67 "increment" : [ [ { }, { } ], [ { }, { } ] ],
68 "base" : [ {
69 "expectFinishTime" : "20",
70 "current" : "800",
71 "count" : "1000",
72 "speed" : "500"
73 }, {
74 "expectFinishTime" : "20",
75 "current" : "800",
76 "count" : "1000",
77 "speed" : "500"
78 } ]
79 },
80 "payInfo" : {
81 "standard" : "Large",
82 "sourceInstanceType" : "OnBce",
83 "createTime" : 1607606657000,
84 "targetInstanceType" : "OnBce",
85 "crossRegionTag" : 0,
86 "endTime" : 1607606657000,
87 "productType" : "postpay"
88 },
89 "dtsTaskPos" : { },
90 "status" : "finished"
91 }, {
92 "subDataScope" : {
93 "startTime" : "startTime",
94 "endTime" : "endTime"
95 },
96 "schemaMapping" : [ {
97 "dst" : "test.table_dst",
98 "src" : "test.table_src",
99 "where" : "where",
100 "type" : "table"
101 }, {
102 "dst" : "test.table_dst",
103 "src" : "test.table_src",
104 "where" : "where",
105 "type" : "table"
106 } ],
107 "dataType" : [ "base", "base" ],
108 "dtsId" : "dtsmxxyy1234",
109 "errmsg" : "errmsg",
110 "runningTime" : 20,
111 "dtsIdNeg" : "dtsmxxyy1234",
112 "subStatus" : [ {
113 "b" : "running",
114 "s" : "running",
115 "i" : "running"
116 }, {
117 "b" : "running",
118 "s" : "running",
119 "i" : "running"
120 } ],
121 "dtsIdPos" : "dtsmxxyy1234",
122 "sdkRealtimeProgress" : "sdkRealtimeProgress",
123 "lockStatus" : "unlock",
124 "createTime" : "2020-12-10T13: 24: 10Z",
125 "granularity" : "dbtb",
126 "dtsTaskNeg" : { },
127 "taskName" : "dtsmxxyy1234",
128 "region" : "bj",
129 "srcConnection" : {
130 "dbPass" : "dbPass",
131 "dbPort" : 3306,
132 "instanceId" : "rdsmfgdti3d53f5",
133 "instanceType" : "bcerds",
134 "dbUser" : "_dts_trans_",
135 "field_whitelist" : "field_whitelist",
136 "dbType" : "mysql",
137 "dbHost" : "192.168.1.1",
138 "field_blacklist" : "field_blacklist",
139 "region" : "bj"
140 },
141 "dynamicInfo" : {
142 "schema" : [ {
143 "expectFinishTime" : "20",
144 "current" : "800",
145 "count" : "1000",
146 "speed" : "500"
147 }, {
148 "expectFinishTime" : "20",
149 "current" : "800",
150 "count" : "1000",
151 "speed" : "500"
152 } ],
153 "increment" : [ [ { }, { } ], [ { }, { } ] ],
154 "base" : [ {
155 "expectFinishTime" : "20",
156 "current" : "800",
157 "count" : "1000",
158 "speed" : "500"
159 }, {
160 "expectFinishTime" : "20",
161 "current" : "800",
162 "count" : "1000",
163 "speed" : "500"
164 } ]
165 },
166 "payInfo" : {
167 "standard" : "Large",
168 "sourceInstanceType" : "OnBce",
169 "createTime" : 1607606657000,
170 "targetInstanceType" : "OnBce",
171 "crossRegionTag" : 0,
172 "endTime" : 1607606657000,
173 "productType" : "postpay"
174 },
175 "dtsTaskPos" : { },
176 "dtsTasks" : [{}],
177 "statistic": {
178 "readSpeed": "",
179 "writeSpeed": ""
180 },
181 "initPosition": {
182 "type": "",
183 "position": ""
184 },
185 "status" : "finished"
186 } ],
187 "maxKeys" : 10,
188 "truncated" : false,
189 "bindTags": [{"tagKey": "默认项目", "tagValue": "dtstest"}]
190}