查询任务信息
所有文档
menu

数据传输服务 DTS

查询任务信息

产品详情自助选购

接口说明

查看指定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 任务状态
  • unConfig:未配置, 当用户创建完任务后, 就进入未配置状态, 该状态只有dtsId信息
  • ready:未启动, 当配置完后任务后就进入未启动状态, 这时就包含任务的所有信息
  • checking:前置检查中, 当用户点击启动后, 先会进行前置检查
  • checkPass:前置检查通过, 只有前置检查通过后, 才可以进行启动任务
  • checkFailed:前置检查失败, 任务启动时,会进行前置检查, 若检查失败, 就进入该状态, 这时可以进行修改任务或直接结束任务
  • running:运行中,前置检测通过且任务启动后进入该状态, 包括数据迁移中或数据同步中
  • stopping:暂停中,处于该状态的任务不能进行任何操作
  • stopped:已暂停,从该状态启动,会进行断点续传,比如:暂停后修改数据同步对象
  • stopCheckFailed:已暂停(新增同步对象前置检查失败),当新增同步对象时,会进行前置检查,如果检查失败,回到已暂停状态,但是可以查看检查失败原因
  • runFailed:运行失败, 当运行过程中出现异常就进入该状态,如果是可恢复错误, 修复后可继续启动,如果是不可恢复错误, 只能结束任务
  • finished:任务结束,包括手工进行结束,或任务完成后自动结束,或出现不可恢复的错误
  • 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    
    ContentType: application/json     
    Authorization: bce-auth-v1/5a6f0606bf5e48f29dd132aa76aa5182/2017-06-12T13:13:05Z/1800/content-type;host;x-bce-date/8baeafe6bfc35b0cf6205e87e4ce6c0dbb442375951ace4d16e6c7a4dab95943

    响应示例

    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"
    }
    上一篇
    创建任务
    下一篇
    查询任务列表