备案控制台
文档
产品文档
输入文档关键字查找
首页 大数据开发治理平台 DataWorks 开发参考 API参考 API目录 数据集成 GenerateDISyncTaskConfigForCreating - 异步生成同时任务的JSON

GenerateDISyncTaskConfigForCreating - 异步生成同时任务的JSON

更新时间：
一键部署
产品详情
相关技术圈
我的收藏

异步生成同时任务的JSON。

接口说明

DataWorks 目前仅支持直接使用 CreateDISyncTask 接口创建数据集成离线同步任务，而数据集成实时同步任务和其他同步类型的任务则需要先调用 GenerateDISyncTaskConfigForCreating 和 QueryDISyncTaskConfigProcessResult 接口，获取异步生成创建数据集成同步任务需要的参数，再将该参数作为 CreateDISyncTask 接口的入参，使用 CreateDISyncTask 接口创建相应的实时同步任务和其他同步类型的同步任务。 仅支持使用异步方式创建数据集成实时同步任务和其他同步类型的同步任务。

调试

您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。

授权信息

下表是API对应的授权信息，可以在RAM权限策略语句的Action元素中使用，用来给RAM用户或RAM角色授予调用此API的权限。具体说明如下：

  • 操作：是指具体的权限点。
  • 访问级别：是指每个操作的访问级别，取值为写入（Write）、读取（Read）或列出（List）。
  • 资源类型：是指操作中支持授权的资源类型。具体说明如下：
    • 对于必选的资源类型，用背景高亮的方式表示。
    • 对于不支持资源级授权的操作，用全部资源表示。
  • 条件关键字：是指云产品自身定义的条件关键字。
  • 关联操作：是指成功执行操作所需要的其他权限。操作者必须同时具备关联操作的权限，操作才能成功。
操作访问级别资源类型条件关键字关联操作
dataworks:*Read
  • 全部资源
    *
    无
无

请求参数

名称类型必填描述示例值
ProjectIdlong是

DataWorks 工作空间的 ID。您可以登录 DataWorks 控制台，进入工作空间配置页面获取工作空间 ID。

该参数用来确定本次 API 调用操作使用的 DataWorks 工作空间。

10000
TaskTypestring是

使用异步方式创建数据集成同步任务的任务类型。取值如下：

  • DI_REALTIME：表示实时同步任务。
  • DI_SOLUTION：表示其他同步类型的同步任务。

仅支持使用异步方式生成数据集成实时同步任务和其他同步类型的同步任务。

DI_REALTIME
TaskParamstring是

数据集成同步任务的脚本。 目前支持创建的同步任务类型如下：

  • 同步 MySQL 数据至 MaxCompute。
  • 同步 MySQL 数据至 Kafka。
  • 同步 MySQL 数据至 Hologres。

SelectedTables 用于多库模式选择同步表，Tables 用于单库模式选择同步表。

  • 当脚本中包含 SelectedTables 语句时，系统会使用 SelectedTables 语句中的表信息进行同步。
  • 当脚本中包含 Tables 语句时，系统会使用 Tables 的字段信息进行同步。

同步 MySQL 数据至 MaxCompute，示例语句如下。

{
  "type": "realtime",
  "version": "1.0",
  "setting": {
    "resourceGroup": "S_res_group_280749521950784_1623033752022",
    "taskType": "oneclick_to_odps"
  },
  "steps": [
    {
      "stepType": "mysql",
      "parameter": {
        "connection": [
          {
            "datasourceType": "mysql",
            "datasource": "mysql_pub1",
            "selectedTables": [
              {
                "dbName": "mysql_db",
                "schema": [
                  {
                    "tableInfos": [
                      {
                        "table": "molin_di_test_in_pk_v4"
                      }
                    ]
                  }
                ]
              }
            ]
          }
        ]
      },
      "name": "Reader",
      "category": "reader"
    },
    {
      "stepType": "odps",
      "parameter": {
        "datasource": "odps_source"
      },
      "name": "Writer",
      "category": "writer"
    }
  ]
}

同步 MySQL 数据至 Kafka，示例语句如下。

{
  "type": "realtime",
  "version": "1.0",
  "setting": {
    "resourceGroup": "S_res_group_280749521950784_1623033752022",
    "taskType": "oneclick_to_kafka"
  },
  "steps": [
    {
      "stepType": "mysql",
      "parameter": {
        "connection": [
          {
            "datasourceType": "mysql",
            "datasource": "pkset_test",
            "selectedTables": [
              {
                "dbName": "mysql_db",
                "schema": [
                  {
                    "tableInfos": [
                      {
                        "table": "molin_di_test_in_pk_v4"
                      }
                    ]
                  }
                ]
              }
            ]
          }
        ]
      },
      "name": "Reader",
      "category": "reader"
    },
    {
      "stepType": "kafka",
      "parameter": {
        "datasource": "azn_kafka"
      },
      "name": "Writer",
      "category": "writer"
    }
  ]
}

同步 MySQL 数据至 Hologres，示例语句如下。

{
  "type": "realtime",
  "version": "1.0",
  "setting": {
    "resourceGroup": "S_res_group_280749521950784_1623033752022",
    "taskType": "oneclick_to_holo"
  },
  "steps": [
    {
      "stepType": "mysql",
      "parameter": {
        "connection": [
          {
            "datasourceType": "mysql",
            "datasource": "mysql_pub",
            "selectedTables": [
              {
                "dbName": "mysql_db",
                "schema": [
                  {
                    "tableInfos": [
                      {
                        "table": "molin_di_test_in2_pk_v3"
                      }
                    ]
                  }
                ]
              }
            ]
          }
        ]
      },
      "name": "Reader",
      "category": "reader"
    },
    {
      "stepType": "holo",
      "parameter": {
        "datasource": "holo"
      },
      "name": "Writer",
      "category": "writer"
    }
  ]
}
{ "type": "realtime", "version": "1.0", "setting": { "resourceGroup": "S_res_group_280749521950784_1623033752022", "taskType": "oneclick_to_odps" }, "steps": [{ "stepType": "mysql", "parameter": { "connection": [ { "datasourceType": "mysql", "datasource": "mysql_pub1", "selectedTables": [ { "dbName": "mysql_db", "schema": [ { "tableInfos": [ { "table": "molin_di_test_in_pk_v4" }] } ] } ] } ] }, "name": "Reader", "category": "reader" }, { "stepType": "odps", "parameter": { "datasource": "odps_source" }, "name": "Writer", "category": "writer" } ] }
ClientTokenstring否

幂等参数。用于避免多次调用导致操作重复。

ABFUOEUOTRTRJKE

返回参数

名称类型描述示例值
object

返回结果。

Successboolean

请求是否成功。取值如下：

  • true：成功。
  • false：失败。
true
RequestIdstring

请求 ID。用于定位日志，排查问题。

0bc1411515937635973****
Dataobject

异步线程 ID 的生成结果。

Statusstring

生成异步线程 ID 的结果状态。取值如下：

  • success：表示成功生成异步线程 ID。
  • fail：表示异步线程 ID 生成失败。您可以查看失败原因，处理相关问题。
true
ProcessIdlong

异步线程 ID。您需要通过该 ID，调用 QueryDISyncTaskConfigProcessResult 接口获取异步生成创建数据集成同步任务需要的参数，使用该参数创建数据集成同步任务。

10
Messagestring

异步线程 ID 生成失败的原因描述。 如果成功生成异步线程 ID，则该参数的返回值为空。

XXX is invalid.

示例

正常返回示例

JSON格式

{
  "Success": true,
  "RequestId": "0bc1411515937635973****",
  "Data": {
    "Status": "true",
    "ProcessId": 10,
    "Message": "XXX is invalid."
  }
}

错误码

HTTP status code错误码错误信息描述
400Invalid.DI.ParameterThe parameter is invalid.参数错误
400Invalid.DI.Parameter.File.ExistedThe file name already exists.参数不合法，文件名已存在
403Forbidden.DI.NoPrivilegeNo access.没有权限访问
500InternalError.DI.ParameterA DI internal error occurred.数据集成内部业务错误

访问错误中心查看更多错误码。
上一篇：TerminateDISyncInstance - 终止同步任务下一篇：GenerateDISyncTaskConfigForUpdating - 异步生成更新同步任务配置
文档推荐
  • 本页导读 （1）