QueryDISyncTaskConfigProcessResult - DataWorks: Central de Documentação do Alibaba Cloud

Descrição da operação

Atualmente, o DataWorks suporta apenas a chamada direta da operação CreateDISyncTask para criar ou da operação UpdateDISyncTask para atualizar uma tarefa de sincronização offline do Data Integration. Para criar ou atualizar uma tarefa de sincronização em tempo real do Data Integration, você deve primeiro chamar as operações GenerateDISyncTaskConfigForCreating, GenerateDISyncTaskConfigForUpdating e QueryDISyncTaskConfigProcessResult para obter os parâmetros necessários para gerar assincronamente a configuração para criar ou atualizar a tarefa. Em seguida, passe esses parâmetros como entrada para a operação CreateDISyncTask ou UpdateDISyncTask para criar ou atualizar a tarefa de sincronização em tempo real correspondente. Você só pode usar o método assíncrono para criar ou atualizar tarefas de sincronização em tempo real do Data Integration.

Experimente agora

Experimente esta API no OpenAPI Explorer, sem necessidade de assinatura manual. Chamadas bem-sucedidas geram automaticamente código SDK correspondente aos seus parâmetros. Faça o download com segurança de credenciais integrada para uso local.

Testar

Autorização RAM

Nenhuma autorização necessária para esta operação. Se você encontrar problemas com esta operação, entre em contato com o suporte técnico.

Parâmetros da solicitação

Parâmetro	Tipo	Obrigatório	Descrição	Exemplo
ProjectId	integer	Sim	O ID do workspace do DataWorks. Você pode fazer logon no console do DataWorks e acessar a página de configuração do workspace para obter o ID do workspace.\n\nEste parâmetro especifica o workspace do DataWorks para a chamada de API atual.	10000
TaskType	string	Sim	O tipo da tarefa de sincronização criada ou atualizada de forma assíncrona. Valores válidos:\n- DI_REALTIME: tarefa de sincronização em tempo real.\n- DI_SOLUTION: tarefa de sincronização de solução.\nApenas tarefas de sincronização em tempo real e tarefas de sincronização de solução no Data Integration podem ser criadas ou atualizadas de forma assíncrona. Valores válidos: DI_REALTIME : Tarefa de sincronização em tempo real. DI_SOLUTION : Tarefa de sincronização de solução. DI_OFFLINE : Tarefa de sincronização offline.	DI_REALTIME
AsyncProcessId	integer	Sim	O ID do thread assíncrono. Você pode chamar a operação GenerateDISyncTaskConfigForCreating ou GenerateDISyncTaskConfigForUpdating para obter o ID.\n- GenerateDISyncTaskConfigForCreating: cria uma tarefa de sincronização do Data Integration.\n- GenerateDISyncTaskConfigForUpdating: atualiza uma tarefa de sincronização do Data Integration.	10

Elementos de resposta

Elemento	Tipo	Descrição	Exemplo
	object	A resposta.
Success	boolean	Indica se a solicitação foi bem-sucedida. Valores válidos:\n- true: A solicitação foi bem-sucedida.\n- false: A solicitação falhou.	true
RequestId	string	O ID da solicitação. Você pode usar o ID para localizar logs e solucionar problemas.	0bc1411515937635973****
Data	object	O resultado da obtenção dos parâmetros necessários para gerar ou atualizar assincronamente uma tarefa de sincronização do Data Integration.
Status	string	O status da obtenção dos parâmetros necessários para gerar ou atualizar assincronamente uma tarefa de sincronização do Data Integration. Valores válidos:\n- success: Os parâmetros foram obtidos.\n- fail: Falha ao obter os parâmetros. Você pode visualizar a causa da falha e solucionar o problema.	success
Message	string	A descrição da causa da falha ao obter os parâmetros necessários para gerar ou atualizar assincronamente uma tarefa de sincronização do Data Integration. Se os parâmetros forem obtidos, este parâmetro estará vazio.	fileId:[100] is invalid.
TaskContent	string	Os parâmetros necessários para a tarefa de sincronização do Data Integration gerada pelo thread assíncrono. Esses parâmetros são usados como parâmetros de entrada da operação CreateDISyncTask ou UpdateDISyncTask para criar ou atualizar subsequentemente a tarefa de sincronização do Data Integration.	{"extend":{"mode":"migration_holo","resourceGroup":"280749","name":"h"},"type":"job","steps":[{"stepType":"mysql","parameter":{"connection":[{"datasourceType":"mysql","datasource":"mm","selectedTables":[{"schema":[{"tableInfos":[{"enable":true,"table":"m_v1","tableName":"m_v1"}]}],"dbName":"m"}]}]},"name":"reader","category":"reader"},{"stepType":"holo","parameter":{"datasource":"h","tableMappingRule":{"datasource":[{"tableRule":[{"srcTable":"m_v1","mergeIntoCycleType":"DEFAULT","hourDeltaEnable":false,"dstTable":"m.m_v1","dayDeltaEnable":false,"primaryKeyInfo":{"column":["id"],"type":"pk"},"dstCreateTableInfo":{"indexType":"m_v1","dataColumn":[{"columnSize":0,"name":"id","index":0,"comment":"","newDigit":0,"type":"int8","digit":0,"primaryKey":true}],"schemaName":"m","tableName":"m_v1"},"srcDbName":"m"}],"srcDatasourceName":"mm"}],"totalTableMapping":1},"writeMode":"replay"},"name":"writer","category":"writer"}],"version":"2.0","order":{"hops":[{"from":"reader","to":"writer"}]}}

Exemplos

Resposta de sucesso

JSON formato

{
  "Success": true,
  "RequestId": "0bc1411515937635973****",
  "Data": {
    "Status": "success",
    "Message": "fileId:[100] is invalid.",
    "TaskContent": "{\"extend\":{\"mode\":\"migration_holo\",\"resourceGroup\":\"280749\",\"name\":\"h\"},\"type\":\"job\",\"steps\":[{\"stepType\":\"mysql\",\"parameter\":{\"connection\":[{\"datasourceType\":\"mysql\",\"datasource\":\"mm\",\"selectedTables\":[{\"schema\":[{\"tableInfos\":[{\"enable\":true,\"table\":\"m_v1\",\"tableName\":\"m_v1\"}]}],\"dbName\":\"m\"}]}]},\"name\":\"reader\",\"category\":\"reader\"},{\"stepType\":\"holo\",\"parameter\":{\"datasource\":\"h\",\"tableMappingRule\":{\"datasource\":[{\"tableRule\":[{\"srcTable\":\"m_v1\",\"mergeIntoCycleType\":\"DEFAULT\",\"hourDeltaEnable\":false,\"dstTable\":\"m.m_v1\",\"dayDeltaEnable\":false,\"primaryKeyInfo\":{\"column\":[\"id\"],\"type\":\"pk\"},\"dstCreateTableInfo\":{\"indexType\":\"m_v1\",\"dataColumn\":[{\"columnSize\":0,\"name\":\"id\",\"index\":0,\"comment\":\"\",\"newDigit\":0,\"type\":\"int8\",\"digit\":0,\"primaryKey\":true}],\"schemaName\":\"m\",\"tableName\":\"m_v1\"},\"srcDbName\":\"m\"}],\"srcDatasourceName\":\"mm\"}],\"totalTableMapping\":1},\"writeMode\":\"replay\"},\"name\":\"writer\",\"category\":\"writer\"}],\"version\":\"2.0\",\"order\":{\"hops\":[{\"from\":\"reader\",\"to\":\"writer\"}]}}"
  }
}

Códigos de erro

Código de status HTTP	Código de erro	Mensagem de erro	Descrição
400	Param.Invalid	The parameter is invalid.	Ocorreu um erro de parâmetro.
500	InternalError.System	An internal error occurred.	Ocorreu um erro interno.
403	Forbidden.Access	Access is forbidden.

Consulte Códigos de Erro para uma lista completa.

Notas de versão

Consulte Notas de Versão para uma lista completa.