日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

AI 助理
備案控制臺
文檔
輸入文檔關鍵字查找
首頁 大數據開發治理平臺 DataWorks 開發參考 API參考（2020-05-18） API目錄 數據集成 GenerateDISyncTaskConfigForCreating - 異步生成同時任務的JSON

GenerateDISyncTaskConfigForCreating - 異步生成同時任務的JSON

更新時間：
產品詳情
相關技術圈
我的收藏

異步生成同時任務的JSON。

接口說明

DataWorks 目前僅支持直接使用 CreateDISyncTask 接口創建數據集成離線同步任務，而數據集成實時同步任務和其他同步類型的任務則需要先調用 GenerateDISyncTaskConfigForCreating 和 QueryDISyncTaskConfigProcessResult 接口，獲取異步生成創建數據集成同步任務需要的參數，再將該參數作為 CreateDISyncTask 接口的入參，使用 CreateDISyncTask 接口創建相應的實時同步任務和其他同步類型的同步任務。 僅支持使用異步方式創建數據集成實時同步任務和其他同步類型的同步任務。

調試

您可以在OpenAPI Explorer中直接運行該接口，免去您計算簽名的困擾。運行成功后，OpenAPI Explorer可以自動生成SDK代碼示例。

授權信息

當前API暫無授權信息透出。

請求參數

名稱類型必填描述示例值
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.數據集成內部業務錯誤

訪問錯誤中心查看更多錯誤碼。