CreateDISyncTask - - Centro de documentación de Alibaba Cloud

Crea una tarea de sincronización de datos.

Depuración

OpenAPI Explorer calcula automáticamente el valor de la firma. Para su comodidad, le recomendamos que invoque esta operación en OpenAPI Explorer. OpenAPI Explorer genera dinámicamente el código de ejemplo de la operación para diferentes SDK.

Parámetros de solicitud

Parámetro	Tipo	Obligatorio	Ejemplo	Descripción
Action	String	Sí	CreateDISyncTask	La operación que desea ejecutar. Establezca el valor en CreateDISyncTask.
ProjectId	Long	Sí	10000	El ID del espacio de trabajo de DataWorks. Inicie sesión en la DataWorks console y vaya a la página Workspace para obtener el ID del espacio de trabajo.
TaskType	String	Sí	DI_OFFLINE	El tipo de tarea de sincronización de datos. Valores válidos: DI_OFFLINE, DI_REALTIME y DI_SOLUTION.
TaskContent	String	Sí	{"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"}]}}	La configuración de la tarea de sincronización por lotes que se va a crear. Invocar esta operación de API para crear una tarea de sincronización por lotes equivale a crearla mediante el editor de código en la consola de DataWorks. Para obtener más información, consulte Create a data synchronization task by using the code editor.
TaskParam	String	Sí	{"FileFolderPath":"Business Flow/XXX/Data Integration","ResourceGroup":"S_res_group_XXX_XXXX"}	Los ajustes que especifican la ruta de almacenamiento de la tarea de sincronización de datos y el resource group que utiliza la tarea. Se admiten los siguientes parámetros: FileFolderPath: la ruta de almacenamiento de la tarea de sincronización de datos. ResourceGroup: el identificador del resource group de Data Integration que utiliza la tarea de sincronización de datos. Puede invocar la operación ListResourceGroups para consultar el identificador del resource group.
TaskName	String	Sí	new_di_task	El nombre de la tarea de sincronización de datos.
ClientToken	String	No	0000-ABCD-EFG****	El token de cliente que se utiliza para garantizar la idempotencia de la solicitud. Este parámetro puede dejarse vacío.

Parámetros de respuesta

Parámetro	Tipo	Ejemplo	Descripción
Success	Boolean	true	Indica si la solicitud se realizó correctamente. Valores válidos: true y false.
RequestId	String	0bc1411515937635973****	El ID de la solicitud. Puede usar este ID para localizar registros y solucionar problemas.
Data	Object		La información que indica si se creó la tarea de sincronización de datos.
Status	String	success	El estado de creación de la tarea de sincronización de datos. Valores válidos: success fail
Message	String	Invalid path: Business Flow/xxxx/Data Integration	El mensaje de error que se devuelve si no se logra crear la tarea de sincronización de datos. Si la tarea se crea correctamente, este parámetro no se devuelve. Si falla la creación, se devuelve un mensaje de error con el formato "Invalid path: Business Flow/xxxx/Data Integration".
FileId	Long	1000001	El ID de la tarea de sincronización de datos creada.

Ejemplos

Solicitudes de ejemplo

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>

Respuestas exitosas de ejemplo

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 error

Código de estado HTTP	Código de error	Mensaje de error	Descripción
400	Invalid.DI.Parameter	The parameter is invalid.	Uno o más parámetros no son válidos.
400	Invalid.DI.Parameter.File.Existed	The file name already exists.	El nombre de archivo especificado ya existe.
403	Forbidden.DI.NoPrivilege	No access.	No cuenta con los permisos obligatorios.
500	InternalError.DI.Parameter	A DI internal error occurred.	Ocurrió un error interno en Data Integration.

Para obtener una lista de códigos de error, consulte Códigos de error del servicio.