DataWorks:GenerateDISyncTaskConfigForCreating

DataWorks ワークスペースの ID です。DataWorks コンソール（https://workbench.data.aliyun.com/console）にログインし、「ワークスペース」ページから ID を確認できます。

このパラメーターを設定して、API オペレーションを適用する DataWorks ワークスペースを指定する必要があります。

非同期モードで Data Integration に作成するタスクの種類です。有効な値は以下のとおりです。

• DI_REALTIME：リアルタイム同期タスク

• DI_SOLUTION：その他の種類の同期タスク

DataWorks では、Data Integration におけるリアルタイム同期タスクおよびその他の種類の同期タスクは、非同期モードでのみ作成可能です。

• DI_OFFLINE

• DI_REALTIME

• DI_SOLUTION

同期タスクのスクリプトです。DataWorks では、以下の種類の同期タスクを作成できます。

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

リクエストのべき等性を保証するためのクライアントトークンです。このパラメーターは、複数回の呼び出しによって重複した操作が発生することを防止するために使用します。