DataWorks:GenerateDISyncTaskConfigForCreating

O ID do espaço de trabalho do DataWorks. Você pode fazer logon no console do DataWorks e acessar a página Configuração do Espaço de Trabalho para obter o ID do espaço de trabalho.

Este parâmetro especifica o espaço de trabalho do DataWorks para a chamada de API atual.

O tipo da tarefa de sincronização do Data Integration criada usando o método assíncrono. Valores válidos:

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

• DI_SOLUTION: outros tipos de tarefas de sincronização

Apenas o método assíncrono é suportado para gerar tarefas de sincronização em tempo real e outros tipos de tarefas de sincronização no Data Integration.

O script da tarefa de sincronização do Data Integration. Os seguintes tipos de tarefas de sincronização podem ser criados:

• Sincronizar dados do MySQL para o MaxCompute.

• Sincronizar dados do MySQL para o Kafka.

• Sincronizar dados do MySQL para o Hologres.

SelectedTables é usado para selecionar tabelas de sincronização no modo de múltiplos bancos de dados, e Tables é usado para selecionar tabelas de sincronização no modo de banco de dados único.

• Se o script contiver a instrução SelectedTables, o sistema usará as informações da tabela na instrução SelectedTables para a sincronização.

• Se o script contiver a instrução Tables, o sistema usará as informações de campo de Tables para a sincronização.

O exemplo a seguir mostra o script para sincronizar 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 o script para sincronizar 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"
    }
  ]
}

O exemplo a seguir mostra o script para sincronizar 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"
    }
  ]
}

O token de idempotência. Este parâmetro evita operações duplicadas causadas por chamadas repetidas.