CreateDISyncTask - - Centre de documentation Alibaba Cloud

Débogage

OpenAPI Explorer calcule automatiquement la valeur de signature. Pour plus de commodité, nous vous recommandons d'appeler cette opération dans OpenAPI Explorer. OpenAPI Explorer génère dynamiquement des exemples de code pour différents SDK.

Paramètres de requête

Paramètre	Type	Obligatoire	Exemple	Description
Action	String	Oui	CreateDISyncTask	Opération à effectuer. Définissez la valeur sur CreateDISyncTask.
ProjectId	Long	Oui	10000	ID de l'espace de travail DataWorks. Connectez-vous à la console DataWorks et accédez à la page Workspace pour obtenir l'ID de l'espace de travail.
TaskType	String	Oui	DI_OFFLINE	Type de la tâche de synchronisation des données. Valeurs possibles : DI_OFFLINE, DI_REALTIME et DI_SOLUTION.
TaskContent	String	Oui	{"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"}]}}	Configuration de la tâche de synchronisation par lots à créer. L'appel de cette API pour créer une tâche de synchronisation par lots équivaut à utiliser l'éditeur de code dans la console DataWorks. Pour plus d'informations, consultez Créer une tâche de synchronisation des données à l'aide de l'éditeur de code.
TaskParam	String	Oui	{"FileFolderPath":"Business Flow/XXX/Data Integration","ResourceGroup":"S_res_group_XXX_XXXX"}	Paramètres définissant le chemin de stockage de la tâche de synchronisation des données et le groupe de ressources utilisé. Les paramètres suivants sont pris en charge : FileFolderPath : chemin de stockage de la tâche de synchronisation des données. ResourceGroup : identifiant du groupe de ressources Data Integration utilisé par la tâche de synchronisation des données. Appelez l'opération ListResourceGroups pour récupérer l'identifiant du groupe de ressources.
TaskName	String	Oui	new_di_task	Nom de la tâche de synchronisation des données.
ClientToken	String	Non	0000-ABCD-EFG****	Jeton client garantissant l'idempotence de la requête. Ce paramètre est facultatif.

Paramètres de réponse

Paramètre	Type	Exemple	Description
Success	Boolean	true	Indique si la requête a abouti. Valeurs possibles : true et false.
RequestId	String	0bc1411515937635973****	ID de la requête. Utilisez cet ID pour localiser les journaux et résoudre les problèmes.
Data	Object		Informations indiquant si la tâche de synchronisation des données a été créée.
Status	String	success	État de création de la tâche de synchronisation des données. Valeurs possibles : success fail
Message	String	Invalid path: Business Flow/xxxx/Data Integration	Message d'erreur renvoyé en cas d'échec de la création de la tâche de synchronisation des données. Si la création réussit, ce paramètre n'est pas renvoyé. En cas d'échec, un message d'erreur au format « Invalid path: Business Flow/xxxx/Data Integration » est renvoyé.
FileId	Long	1000001	ID de la tâche de synchronisation des données créée.

Exemples

Exemples de requêtes

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>

Exemples de réponses réussies

Format 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>

Format JSON

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

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

Codes d'erreur

Code d'état HTTP	Code d'erreur	Message d'erreur	Description
400	Invalid.DI.Parameter	The parameter is invalid.	Un ou plusieurs paramètres ne sont pas valides.
400	Invalid.DI.Parameter.File.Existed	The file name already exists.	Le nom de fichier spécifié existe déjà.
403	Forbidden.DI.NoPrivilege	No access.	Vous ne disposez pas des autorisations requises.
500	InternalError.DI.Parameter	A DI internal error occurred.	Une erreur interne s'est produite dans Data Integration.

Pour obtenir la liste des codes d'erreur, consultez les Codes d'erreur de service.