查询任务信息
更新时间：2023-03-15
接口说明
查看指定ID的数据传输任务信息
请求结构
GET /v{version}/task/{dtsId}
Host: dts.baidubce.com
Authorization: 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 字段，即任务组任务时，子任务信息，所以该字段的值结构跟任务本身结构一致。
请求示例
GET /v1/task/{dtsId}
Host: dts.baidubce.com
Authorization: authorization string响应示例
HTTP/1.1 200 OK
{
"subDataScope" : {
"startTime" : "startTime",
"endTime" : "endTime"
},
"schemaMapping" : [ {
"dst" : "test.table_dst",
"src" : "test.table_src",
"where" : "where",
"type" : "table"
}, {
"dst" : "test.table_dst",
"src" : "test.table_src",
"where" : "where",
"type" : "table"
} ],
"dataType" : [ "base", "base" ],
"dtsId" : "dtsmxxyy1234",
"errmsg" : "errmsg",
"runningTime" : 20,
"dtsIdNeg" : "dtsmxxyy1234",
"subStatus" : [ {
"b" : "running",
"s" : "running",
"i" : "running"
}, {
"b" : "running",
"s" : "running",
"i" : "running"
} ],
"dtsIdPos" : "dtsmxxyy1234",
"sdkRealtimeProgress" : "sdkRealtimeProgress",
"lockStatus" : "unlock",
"createTime" : "2020-12-10T13: 24: 10Z",
"granularity" : "dbtb",
"dtsTaskNeg" : { },
"taskName" : "dtsmxxyy1234",
"region" : "bj",
"srcConnection" : {
"dbPass" : "dbPass",
"dbPort" : 3306,
"instanceId" : "rdsmfgdti3d53f5",
"instanceType" : "bcerds",
"dbUser" : "_dts_trans_",
"field_whitelist" : "field_whitelist",
"dbType" : "mysql",
"dbHost" : "192.168.1.1",
"field_blacklist" : "field_blacklist",
"region" : "bj"
},
"dynamicInfo" : {
"schema" : [ {
"expectFinishTime" : "20",
"current" : "800",
"count" : "1000",
"speed" : "500"
}, {
"expectFinishTime" : "20",
"current" : "800",
"count" : "1000",
"speed" : "500"
} ],
"increment" : [ [ { }, { } ], [ { }, { } ] ],
"base" : [ {
"expectFinishTime" : "20",
"current" : "800",
"count" : "1000",
"speed" : "500"
}, {
"expectFinishTime" : "20",
"current" : "800",
"count" : "1000",
"speed" : "500"
} ]
},
"payInfo" : {
"standard" : "Large",
"sourceInstanceType" : "OnBce",
"createTime" : 1607606657000,
"targetInstanceType" : "OnBce",
"crossRegionTag" : 0,
"endTime" : 1607606657000,
"productType" : "postpay"
},
"dtsTaskPos" : { },
"dtsTasks" : [{}],
"statistic": {
"readSpeed": "",
"writeSpeed": ""
},
"initPosition": {
"type": "",
"position": ""
},
"status" : "finished"
}