:GenerateDISyncTaskConfigForCreating

Action

String

Sim

GenerateDISyncTaskConfigForCreating

A operação a ser executada.

ProjectId

Long

Sim

10000

O ID do workspace do DataWorks. Faça login no console do DataWorks e acesse a página Workspace para obter o ID.

Configure este parâmetro para especificar o workspace do DataWorks ao qual a operação de API se aplica.

TaskType

String

Sim

DI_REALTIME

O tipo de tarefa a ser criada no Data Integration no modo assíncrono. Valores válidos:

• DI_REALTIME: tarefa de sincronização em tempo real

• DI_SOLUTION: outro tipo de tarefa de sincronização

O DataWorks permite criar tarefas de sincronização em tempo real e outros tipos de tarefas de sincronização no Data Integration apenas no modo assíncrono.

TaskParam

String

Sim

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

O script da tarefa de sincronização.

O DataWorks permite criar os seguintes tipos de tarefas de sincronização:

• Tarefa de sincronização de dados do MySQL para o MaxCompute

• Tarefa de sincronização de dados do MySQL para o Kafka

• Tarefa de sincronização de dados do MySQL para o Hologres

O parâmetro SelectedTables especifica as tabelas a serem sincronizadas a partir de vários bancos de dados. Já o parâmetro Tables define as tabelas a serem sincronizadas de um único banco de dados.

• Se o script contiver o parâmetro SelectedTables, o sistema sincronizará os dados das tabelas especificadas nesse parâmetro.

• Caso o script inclua o parâmetro Tables, o sistema sincronizará os dados das tabelas indicadas nele.

O código de exemplo abaixo apresenta um script para sincronização de dados do MySQL para o 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"
    }
  ]
}

O exemplo a seguir mostra um script para sincronização de dados do MySQL para o 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"
    }
  ]
}

Este trecho ilustra um script para sincronização de dados do MySQL para o 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"
    }
  ]
}

ClientToken

String

Não

ABFUOEUOTRTRJKE

Token de cliente usado para garantir a idempotência da solicitação. Este parâmetro evita operações duplicadas causadas por múltiplas chamadas.

Success

Boolean

true

Indica se a solicitação foi bem-sucedida. Valores válidos:

• true

• false

RequestId

String

0bc1411515937635973****

ID da solicitação. Use este ID para localizar logs e solucionar problemas.