DataWorks：GenerateDISyncTaskConfigForCreating - 非同步產生同時任務的JSON

DataWorks 工作空間的 ID。您可以登入 DataWorks 控制台，進入工作空間配置頁面擷取工作空間 ID。

該參數用來確定本次 API 呼叫操作使用的 DataWorks 工作空間。

使用非同步方式建立Data Integration同步任務的任務類型。取值如下：

• DI_REALTIME：表示即時同步任務。

• DI_SOLUTION：表示其他同步類型的同步任務。

僅支援使用非同步方式產生Data Integration即時同步任務和其他同步類型的同步任務。

Data Integration同步任務的指令碼。 目前支援建立的同步任務類型如下：

• 同步 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"
    }
  ]
}

等冪參數。用於避免多次調用導致操作重複。