CreateDISyncTask - : Central de Documentação do Alibaba Cloud

Depuração

O OpenAPI Explorer calcula automaticamente o valor da assinatura. Recomendamos chamar esta operação no OpenAPI Explorer para maior conveniência. A ferramenta também gera dinamicamente códigos de exemplo da operação para diferentes SDKs.

Parâmetros da solicitação

Parâmetro	Tipo	Obrigatório	Exemplo	Descrição
Action	String	Sim	CreateDISyncTask	Operação a ser executada. Defina o valor como CreateDISyncTask.
ProjectId	Long	Sim	10000	ID do workspace do DataWorks. Acesse o console do DataWorks e navegue até a página Workspace para obter esse ID.
TaskType	String	Sim	DI_OFFLINE	Tipo da tarefa de sincronização de dados. Valores válidos: DI_OFFLINE, DI_REALTIME e DI_SOLUTION.
TaskContent	String	Sim	{"type":"job","version":"2.0","steps":[{"stepType":"mysql","parameter":{"envType":1,"datasource":"mysql_pub","column":["id","name","create_time","age","score","t_01"],"connection":[{"datasource":"mysql_pub","table":["u_pk"]}],"where":"","splitPk":"id","encoding":"UTF-8"},"name":"Reader","category":"reader"},{"stepType":"odps","parameter":{"partition":"pt=${bizdate}","truncate":true,"datasource":"odps_source","envType":1,"column":["id","name","create_time","age","score","t_01"],"emptyAsNull":false,"tableComment":"null","table":"u_pk"},"name":"Writer","category":"writer"}],"setting":{"executeMode":null,"errorLimit":{"record":""},"speed":{"concurrent":2,"throttle":false}},"order":{"hops":[{"from":"Reader","to":"Writer"}]}}	Configurações da tarefa de sincronização em lote a ser criada. Chamar esta API equivale a criar a tarefa pelo editor de código no console do DataWorks. Para mais informações, consulte Criar uma tarefa de sincronização de dados usando o editor de código.
TaskParam	String	Sim	{"FileFolderPath":"Business Flow/XXX/Data Integration","ResourceGroup":"S_res_group_XXX_XXXX"}	Definições do caminho de armazenamento da tarefa de sincronização de dados e do grupo de recursos utilizado. Parâmetros compatíveis: FileFolderPath: caminho de armazenamento da tarefa de sincronização de dados. ResourceGroup: identificador do grupo de recursos do Data Integration usado pela tarefa. Chame a operação ListResourceGroups para consultar esse identificador.
TaskName	String	Sim	new_di_task	Nome da tarefa de sincronização de dados.
ClientToken	String	Não	0000-ABCD-EFG****	Token do cliente para garantir a idempotência da solicitação. Este parâmetro pode ficar vazio.

Parâmetros de resposta

Parâmetro	Tipo	Exemplo	Descrição
Success	Boolean	true	Indica se a solicitação foi bem-sucedida. Valores válidos: true e false.
RequestId	String	0bc1411515937635973****	ID da solicitação. Utilize este ID para localizar logs e solucionar problemas.
Data	Object		Informações sobre a criação da tarefa de sincronização de dados.
Status	String	success	Status de criação da tarefa de sincronização de dados. Valores válidos: success fail
Message	String	Invalid path: Business Flow/xxxx/Data Integration	Mensagem de erro retornada se a criação da tarefa de sincronização de dados falhar. Se a tarefa for criada com sucesso, este parâmetro não será retornado. Em caso de falha, o sistema retorna uma mensagem no formato "Invalid path: Business Flow/xxxx/Data Integration".
FileId	Long	1000001	ID da tarefa de sincronização de dados criada.

Exemplos

Exemplos de solicitações

http(s)://[Endpoint]/?Action=CreateDISyncTask
&ProjectId=10000
&TaskType=DI_OFFLINE
&TaskContent={"type":"job","version":"2.0","steps":[{"stepType":"mysql","parameter":{"envType":1,"datasource":"mysql_pub","column":["id","name","create_time","age","score","t_01"],"connection":[{"datasource":"mysql_pub","table":["u_pk"]}],"where":"","splitPk":"id","encoding":"UTF-8"},"name":"Reader","category":"reader"},{"stepType":"odps","parameter":{"partition":"pt=${bizdate}","truncate":true,"datasource":"odps_source","envType":1,"column":["id","name","create_time","age","score","t_01"],"emptyAsNull":false,"tableComment":"null","table":"u_pk"},"name":"Writer","category":"writer"}],"setting":{"executeMode":null,"errorLimit":{"record":""},"speed":{"concurrent":2,"throttle":false}},"order":{"hops":[{"from":"Reader","to":"Writer"}]}}
&TaskParam={"FileFolderPath":"Business Flow/XXX/Data Integration","ResourceGroup":"S_res_group_XXX_XXXX"}
&TaskName=new_di_task
&ClientToken=0000-ABCD-EFG****
&<Common request parameters>

Exemplos de respostas de sucesso

Formato XML

HTTP/1.1 200 OK
Content-Type:application/xml

<CreateDISyncTaskResponse>
    <Success>true</Success>
    <RequestId>0bc1411515937635973****</RequestId>
    <Data>
        <Status>success</Status>
        <FileId>1000001</FileId>
    </Data>
</CreateDISyncTaskResponse>

Formato JSON

HTTP/1.1 200 OK
Content-Type:application/json

{
  "Success" : true,
  "RequestId" : "0bc1411515937635973****",
  "Data" : {
    "Status" : "success",
    "FileId" : 1000001
  }
}

Códigos de erro

Código de status HTTP	Código de erro	Mensagem de erro	Descrição
400	Invalid.DI.Parameter	The parameter is invalid.	Um ou mais parâmetros são inválidos.
400	Invalid.DI.Parameter.File.Existed	The file name already exists.	O nome de arquivo especificado já existe.
403	Forbidden.DI.NoPrivilege	No access.	Você não tem as permissões necessárias.
500	InternalError.DI.Parameter	A DI internal error occurred.	Ocorreu um erro interno no Data Integration.

Para obter uma lista de códigos de erro, consulte Códigos de erro do serviço.