查询任务信息
更新时间:2024-04-12
接口说明
查看指定ID的数据传输任务信息。
请求结构
JSON
1GET /v{version}/task/{dtsId}
2Host: dts.baidubce.com
3Authorization: authorization string
请求参数
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 | 参数位置 |
---|---|---|---|---|---|
version | String | 是 | API版本号 | "1" | URL参数 |
dtsId | String | 是 | 任务ID | "dtsmxxxyyy" | URL参数 |
响应头参数
除公共头域,无其它特殊头域。
响应体参数
响应体字段数据结构说明
参数名称 | 参数类型 | 是否必须 | 描述 | 示例值 |
---|---|---|---|---|
dtsId | String | 是 | 任务ID | dtsmxxyy1234 |
taskName | String | 是 | 任务名称 | dtsmxxyy1234 |
status | String | 是 | 任务状态 |
finished |
dataType | DataType | 是 | 数据类型 | |
region | String | 是 | 地域 | bj |
createTime | String | 是 | 创建时间 | 2020-12-10T13: 24: 10Z |
srcConnection | Connection | 是 | 源端 | srcConnection |
dstConnection | Connection | 是 | 目标端 | dstConnection |
schemaMapping | SchemaMapping | 是 | schemaMapping | schemaMapping |
runningTime | Integer | 是 | 任务已运行时长 | 20 |
subStatus | List<SubStatus> | 是 | 子任务状态 | |
dynamicInfo | DynamicInfo | 是 | dynamicInfo | dynamicInfo |
errmsg | String | 是 | 执行失败时返回的错误信息, 执行成功时为空字符串 | |
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) | writeSpeed |
checksumResult | ChecksumResult | 是 | 校验结果,可能值:CONSISTENT(一致),INCONSISTENT(不一致),NONE(未知,校验任务运行未结束) | CONSISTENT |
dtsIdPos | String | 是 | 双向同步任务时,正向任务ID | dtsmxxyy1234 |
dtsIdNeg | String | 是 | 双向同步任务时,反向任务ID | dtsmxxyy1234 |
dtsTaskPos | DtsTaskPos | 是 | 双向同步任务时,正向任务信息 | dtsTaskPos |
dtsTaskNeg | DtsTaskNeg | 是 | 双向同步任务时,反向任务信息 | dtsTaskNeg |
dtsTasks | DtsTasks[] | 是 | 任务组任务时,子任务信息 | dtsTasks |
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字段数据结构说明
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 字段,即任务组任务时,子任务信息,所以该字段的值结构跟任务本身结构一致。
请求示例
JSON
1GET /v1/task/{dtsId}
2Host: dts.baidubce.com
3ContentType: application/json
4Authorization: bce-auth-v1/5a6f0606bf5e48f29dd132aa76aa5182/2017-06-12T13:13:05Z/1800/content-type;host;x-bce-date/8baeafe6bfc35b0cf6205e87e4ce6c0dbb442375951ace4d16e6c7a4dab95943
响应示例
JSON
1HTTP/1.1 200 OK
2
3{
4 "subDataScope" : {
5 "startTime" : "startTime",
6 "endTime" : "endTime"
7 },
8 "schemaMapping" : [ {
9 "dst" : "test.table_dst",
10 "src" : "test.table_src",
11 "where" : "where",
12 "type" : "table"
13 }, {
14 "dst" : "test.table_dst",
15 "src" : "test.table_src",
16 "where" : "where",
17 "type" : "table"
18 } ],
19 "dataType" : [ "base", "base" ],
20 "dtsId" : "dtsmxxyy1234",
21 "errmsg" : "errmsg",
22 "runningTime" : 20,
23 "dtsIdNeg" : "dtsmxxyy1234",
24 "subStatus" : [ {
25 "b" : "running",
26 "s" : "running",
27 "i" : "running"
28 }, {
29 "b" : "running",
30 "s" : "running",
31 "i" : "running"
32 } ],
33 "dtsIdPos" : "dtsmxxyy1234",
34 "sdkRealtimeProgress" : "sdkRealtimeProgress",
35 "lockStatus" : "unlock",
36 "createTime" : "2020-12-10T13: 24: 10Z",
37 "granularity" : "dbtb",
38 "dtsTaskNeg" : { },
39 "taskName" : "dtsmxxyy1234",
40 "region" : "bj",
41 "srcConnection" : {
42 "dbPass" : "dbPass",
43 "dbPort" : 3306,
44 "instanceId" : "rdsmfgdti3d53f5",
45 "instanceType" : "bcerds",
46 "dbUser" : "_dts_trans_",
47 "field_whitelist" : "field_whitelist",
48 "dbType" : "mysql",
49 "dbHost" : "192.168.1.1",
50 "field_blacklist" : "field_blacklist",
51 "region" : "bj"
52 },
53 "dynamicInfo" : {
54 "schema" : [ {
55 "expectFinishTime" : "20",
56 "current" : "800",
57 "count" : "1000",
58 "speed" : "500"
59 }, {
60 "expectFinishTime" : "20",
61 "current" : "800",
62 "count" : "1000",
63 "speed" : "500"
64 } ],
65 "increment" : [ [ { }, { } ], [ { }, { } ] ],
66 "base" : [ {
67 "expectFinishTime" : "20",
68 "current" : "800",
69 "count" : "1000",
70 "speed" : "500"
71 }, {
72 "expectFinishTime" : "20",
73 "current" : "800",
74 "count" : "1000",
75 "speed" : "500"
76 } ]
77 },
78 "payInfo" : {
79 "standard" : "Large",
80 "sourceInstanceType" : "OnBce",
81 "createTime" : 1607606657000,
82 "targetInstanceType" : "OnBce",
83 "crossRegionTag" : 0,
84 "endTime" : 1607606657000,
85 "productType" : "postpay"
86 },
87 "dtsTaskPos" : { },
88 "dtsTasks" : [{}],
89 "statistic": {
90 "readSpeed": "",
91 "writeSpeed": ""
92 },
93 "initPosition": {
94 "type": "",
95 "position": ""
96 },
97 "status" : "finished"
98}