Cette rubrique explique comment utiliser des opérations API pour créer, configurer et gérer un nœud de synchronisation de données dans Data Integration.
Prérequis
Vous avez créé un projet Maven. Pour plus d'informations, consultez la rubrique Créer un projet Maven.
Vous avez créé un workflow. Pour plus d'informations, consultez la rubrique Créer un workflow déclenché automatiquement.
Vous avez créé des sources de données et les avez ajoutées à DataWorks pour la synchronisation des données. Pour plus d'informations, consultez la rubrique Ajouter une source de données.
Limites
Dans DataWorks, les opérations API permettent uniquement de créer, configurer et gérer des nœuds de synchronisation par lots.
Seul l'éditeur de code permet de configurer les nœuds de synchronisation de données créés via l'appel de l'opération API CreateDISyncTask. Pour plus d'informations, consultez la rubrique Configuration en mode script.
Dans DataWorks, il est impossible de créer un workflow via une opération API. Vous ne pouvez créer un nœud de synchronisation que dans un workflow existant.
Préparatifs
-
Configurez les dépendances Maven.
-
Ouvrez le fichier pom.xml de votre projet Maven et ajoutez-y la dépendance
aliyun-java-sdk-core.<dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-core</artifactId> <version>4.5.20</version> </dependency> -
Ouvrez le fichier pom.xml du projet Maven et ajoutez-y la dépendance
aliyun-java-sdk-dataworks-public.<dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-dataworks-public</artifactId> <version>3.3.18</version> </dependency> -
Ouvrez le fichier pom.xml du projet Maven et ajoutez-y la dépendance
credentials-java. Nous vous recommandons d'utiliser credentials-java dans sa dernière version.<dependency> <groupId>com.aliyun</groupId> <artifactId>credentials-java</artifactId> <version>0.2.11</version> </dependency>RemarqueL'outil Alibaba Cloud Credentials vous permet de gérer vos paires AccessKey. Pour savoir comment utiliser cet outil, consultez la rubrique Configurer les identifiants.
-
-
Authentifiez un compte.
Avant d'utiliser une opération API pour créer un nœud de synchronisation de données, exécutez le code suivant afin d'authentifier le compte Alibaba Cloud utilisé pour accéder à DataWorks. Si l'authentification réussit, poursuivez les opérations. En cas d'échec, une erreur est renvoyée ; résolvez le problème en fonction du message d'erreur.
// Please ensure that the environment variables ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET are set.https://www.alibabacloud.com/help/en/alibaba-cloud-sdk-262060/latest/configure-credentials-378659 IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
Vue d'ensemble
Une fois les préparatifs terminés, appelez des opérations API pour effectuer les étapes suivantes :
Procédure
-
Créez un nœud de synchronisation de données dans Data Integration.
Appelez l'opération CreateDISyncTask pour créer un nœud de synchronisation de données dans Data Integration. Le code ci-dessous illustre la configuration de certains paramètres. Pour plus d'informations, consultez la rubrique CreateDISyncTask.
public void createFile() throws ClientException{ CreateDISyncTaskRequest request = new CreateDISyncTaskRequest(); request.setProjectId(181565L); request.setTaskType("DI_OFFLINE"); request.setTaskContent("{\"type\":\"job\",\"version\":\"2.0\",\"steps\":[{\"stepType\":\"mysql\",\"parameter\":{\"envType\":1,\"datasource\":\"dh_mysql\",\"column\":[\"id\",\"name\"],\"tableComment\":\"Comment for the table same\",\"connection\":[{\"datasource\":\"dh_mysql\",\"table\":[\"same\"]}],\"where\":\"\",\"splitPk\":\"id\",\"encoding\":\"UTF-8\"},\"name\":\"Reader\",\"category\":\"reader\"},{\"stepType\":\"odps\",\"parameter\":{\"partition\":\"pt=${bizdate}\",\"truncate\":true,\"datasource\":\"odps_first\",\"envType\":1,\"column\":[\"id\",\"name\"],\"emptyAsNull\":false,\"tableComment\":\"Comment for the table same\",\"table\":\"same\"},\"name\":\"Writer\",\"category\":\"writer\"}],\"setting\":{\"errorLimit\":{\"record\":\"\"},\"speed\":{\"throttle\":false,\"concurrent\":2}},\"order\":{\"hops\":[{\"from\":\"Reader\",\"to\":\"Writer\"}]}}"); request.setTaskParam("{\"FileFolderPath\":\"Business Flow/new_biz/Data Integration\",\"ResourceGroup\":\"S_res_group_280749521950784_1602767279794\"}"); request.setTaskName("new_di_task_0607_1416"); String regionId = "cn-hangzhou"; // Please ensure that the environment variables ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET are set.https://www.alibabacloud.com/help/en/alibaba-cloud-sdk-262060/latest/configure-credentials-378659 IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET")); DefaultProfile.addEndpoint("cn-hangzhou","dataworks-public","dataworks.cn-hangzhou.aliyuncs.com"); IAcsClient client; client = new DefaultAcsClient(profile); CreateDISyncTaskResponse response1 = client.getAcsResponse(request); Gson gson1 = new Gson(); System.out.println(gson1.toJson(response1)); } -
Appelez l'opération UpdateFile pour configurer les dépendances de planification du nœud.
Le tableau suivant présente les paramètres de requête de cette opération.
Paramètre
Type
Obligatoire
Exemple
Description
Action
String
Oui
UpdateFile
L'opération à effectuer.
FileFolderPath
String
Non
Business Flow/1/Data Integration/Folder 1/Folder 2
Le chemin d'accès au fichier.
ProjectId
Long
Non
10000
L'ID de l'espace de travail DataWorks. Connectez-vous à la console DataWorks et accédez à la page de gestion des espaces de travail pour obtenir l'ID de l'espace de travail.
FileName
String
Non
ods_user_info_d
Le nom du fichier. Modifiez la valeur du paramètre FileName pour changer le nom du fichier.
Appelez l'opération ListFiles pour récupérer l'ID du fichier dont vous souhaitez modifier le nom. Définissez ensuite le paramètre FileId sur cet ID et le paramètre FileName sur la nouvelle valeur lors de l'appel de l'opération UpdateFile.
FileDescription
String
Non
File description
La description du fichier.
Content
String
Non
SELECT "1";
Le code du fichier. Le format du code varie selon le type de fichier. Pour consulter le format correspondant à un type de fichier donné, accédez au Centre d'opérations, cliquez avec le bouton droit sur un nœud de ce type, puis sélectionnez Afficher le code.
AutoRerunTimes
Integer
Oui
3
Le nombre de réexécutions automatiques autorisées en cas d'erreur.
AutoRerunIntervalMillis
Integer
Non
120000
L'intervalle entre deux réexécutions automatiques consécutives après une erreur, exprimé en millisecondes. La valeur maximale est 1800000 (30 minutes).
Ce paramètre correspond au paramètre Intervalle de réexécution affiché après avoir coché la case Réexécuter automatiquement en cas d'erreur dans la section Planification de l'onglet Propriétés de la console DataWorks.
L'intervalle spécifié dans la console DataWorks est exprimé en minutes. Veillez à convertir correctement les unités de temps lors de l'appel de l'opération.
RerunMode
String
Non
ALL_ALLOWED
Indique si le nœud associé au fichier peut être réexécuté. Valeurs possibles :
ALL_ALLOWED : le nœud peut être réexécuté, qu'il ait réussi ou échoué.
FAILURE_ALLOWED : le nœud ne peut être réexécuté qu'en cas d'échec.
ALL_DENIED : le nœud ne peut pas être réexécuté, qu'il ait réussi ou échoué.
Ce paramètre correspond au paramètre Réexécution dans la section Planification de l'onglet Propriétés de la console DataWorks.
Stop
Boolean
Non
false
Indique si la planification du nœud doit être suspendue. Valeurs possibles :
true : suspend la planification du nœud.
false : ne suspend pas la planification du nœud.
Ce paramètre correspond au paramètre Récurrence dans la section Planification de l'onglet Propriétés de la console DataWorks.
ParaValue
String
Non
x=a y=b z=c
Les paramètres de planification du nœud.
Ce paramètre correspond à la section Paramètres de l'onglet Propriétés de la console DataWorks. Pour plus d'informations, consultez la rubrique Configurer les paramètres de planification.
StartEffectDate
Long
Non
936923400000
L'heure de début de la planification automatique. Définissez ce paramètre sur un horodatage UNIX représentant le nombre de millisecondes écoulées depuis le 1er janvier 1970, 00:00:00 UTC.
Ce paramètre correspond à l'heure de début spécifiée pour le paramètre Période de validité dans la section Planification de l'onglet Propriétés de la console DataWorks.
EndEffectDate
Long
Non
4155787800000
L'heure de fin de la planification automatique. Définissez ce paramètre sur un horodatage UNIX représentant le nombre de millisecondes écoulées depuis le 1er janvier 1970, 00:00:00 UTC.
Ce paramètre correspond à l'heure de fin spécifiée pour le paramètre Période de validité dans la section Planification de l'onglet Propriétés de la console DataWorks.
CronExpress
String
Non
00 00-59/5 1-23 ?
L'expression CRON représentant la politique de planification périodique du nœud. Ce paramètre correspond au paramètre Expression Cron dans la section Planification de l'onglet Propriétés de la console DataWorks. Après avoir configuré les paramètres Cycle de planification et Exécuter à dans la console DataWorks, DataWorks génère automatiquement une valeur pour le paramètre Expression Cron.
Exemples :
Expression CRON pour un nœud planifié pour s'exécuter tous les jours à 05:30 :
00 30 05 ?Expression CRON pour un nœud planifié pour s'exécuter à la quinzième minute de chaque heure :
00 15 * ?Expression CRON pour un nœud planifié pour s'exécuter toutes les 10 minutes :
00 00/10 * ?Expression CRON pour un nœud planifié pour s'exécuter toutes les 10 minutes de 08:00 à 17:00 chaque jour :
00 00-59/10 8-23 * ?Expression CRON pour un nœud planifié pour s'exécuter à 00:20 le premier jour de chaque mois :
00 20 00 1 * ?Expression CRON pour un nœud planifié pour s'exécuter tous les trois mois à partir du 1er janvier à 00:10 :
00 10 00 1 1-12/3 ?Expression CRON pour un nœud planifié pour s'exécuter à 00:05 tous les mardis et vendredis :
00 05 00 2,5
Le système de planification de DataWorks impose les limites suivantes aux expressions CRON :
Un nœud ne peut être planifié pour s'exécuter à un intervalle inférieur à 5 minutes.
L'heure la plus précoce à laquelle un nœud peut être planifié chaque jour est 05:00.
CycleType
String
Non
NOT_DAY
Le type de cycle de planification du nœud. Valeurs possibles : NOT_DAY et DAY. La valeur NOT_DAY indique que le nœud est planifié par minute ou par heure. La valeur DAY indique que le nœud est planifié par jour, par semaine ou par mois.
Ce paramètre correspond au paramètre Cycle de planification dans la section Planification de l'onglet Propriétés de la console DataWorks.
DependentType
String
Non
USER_DEFINE
Le type de dépendance de planification inter-cycles du nœud. Valeurs possibles :
SELF : l'instance générée pour le nœud au cours du cycle actuel dépend de l'instance générée pour le nœud au cours du cycle précédent.
CHILD : l'instance générée pour le nœud au cours du cycle actuel dépend des instances générées pour les nœuds descendants du niveau le plus proche du nœud au cours du cycle précédent.
USER_DEFINE : l'instance générée pour le nœud au cours du cycle actuel dépend des instances générées pour un ou plusieurs nœuds spécifiés au cours du cycle précédent.
NONE : aucun type de dépendance de planification inter-cycles n'est spécifié pour le nœud.
DependentNodeIdList
String
Non
5,10,15,20
L'ID du nœud dont dépend le nœud correspondant au fichier lorsque le paramètre DependentType est défini sur USER_DEFINE. Si vous spécifiez plusieurs ID, séparez-les par des virgules (,).
La valeur de ce paramètre correspond à l'ID du nœud que vous avez spécifié après avoir sélectionné Cycle précédent et défini Dépend de sur Autres nœuds dans la section Dépendances de l'onglet Propriétés de la console DataWorks.
InputList
String
Non
project_root,project.file1,project.001_out
Le nom de sortie du fichier parent dont dépend le fichier actuel. Si vous spécifiez plusieurs noms de sortie, séparez-les par des virgules (,).
Ce paramètre correspond au paramètre Nom de sortie situé sous Nœuds parents dans la section Dépendances de l'onglet Propriétés de la console DataWorks.
ProjectIdentifier
String
Non
dw_project
Le nom de l'espace de travail DataWorks. Connectez-vous à la console DataWorks et accédez à la page de gestion des espaces de travail pour obtenir le nom de l'espace de travail.
Vous devez configurer ce paramètre ou le paramètre ProjectId pour déterminer l'espace de travail DataWorks auquel l'opération s'applique.
FileId
Long
Oui
100000001
L'ID du fichier. Appelez l'opération ListFiles pour l'obtenir.
OutputList
String
Non
dw_project.ods_user_info_d
Le nom de sortie du fichier.
Ce paramètre correspond au paramètre Nom de sortie situé sous Sortie dans la section Dépendances de l'onglet Propriétés de la console DataWorks.
ResourceGroupIdentifier
String
Non
default_group
L'identifiant du groupe de ressources utilisé pour exécuter le nœud. Appelez l'opération ListResourceGroups pour interroger les groupes de ressources disponibles dans l'espace de travail.
ConnectionName
String
Non
odps_first
Le nom de la source de données utilisée pour exécuter le nœud. Appelez l'opération ListDataSources pour interroger les sources de données disponibles de l'espace de travail.
Owner
String
Non
18023848927592
L'ID du propriétaire du fichier.
AutoParsing
Boolean
Non
true
Indique si la fonctionnalité d'analyse automatique doit être activée pour le fichier. Valeurs possibles :
true : active la fonctionnalité d'analyse automatique pour le fichier.
false : désactive la fonctionnalité d'analyse automatique pour le fichier.
Ce paramètre correspond au paramètre Analyser le code affiché après avoir sélectionné Même cycle dans la section Dépendances de l'onglet Propriétés de la console DataWorks.
SchedulerType
String
Non
NORMAL
Le type de planification du nœud. Valeurs possibles :
NORMAL : le nœud est un nœud déclenché automatiquement.
MANUAL : le nœud est un nœud déclenché manuellement. Les nœuds déclenchés manuellement ne peuvent pas être planifiés automatiquement. Accédez au volet Workflows déclenchés manuellement pour afficher ces nœuds.
PAUSE : le nœud est en pause.
SKIP : le nœud est un nœud de test à blanc. Les nœuds de test à blanc sont démarrés selon la planification, mais le système définit leur statut comme réussi dès leur démarrage.
AdvancedSettings
String
Non
{"queue":"default","SPARK_CONF":"--conf spark.driver.memory=2g"}
Les configurations avancées du nœud.
Ce paramètre n'est valide que pour un nœud EMR Spark Streaming ou un nœud EMR Streaming SQL. Il correspond à l'onglet Paramètres avancés du nœud dans la console DataWorks.
La valeur de ce paramètre doit être au format JSON.
StartImmediately
Boolean
Non
true
Indique si le nœud doit être exécuté immédiatement après son déploiement dans l'environnement de production. Valeurs possibles :
true : exécute le nœud immédiatement après son déploiement dans l'environnement de production.
false : n'exécute pas le nœud immédiatement après son déploiement dans l'environnement de production.
Ce paramètre n'est valide que pour un nœud EMR Spark Streaming ou un nœud EMR Streaming SQL. Il correspond au paramètre Méthode de démarrage dans la section Planification de l'onglet Configurer de la console DataWorks.
InputParameters
String
Non
[{"ValueSource": "project_001.first_node:bizdate_param","ParameterName": "bizdate_input"}]
Les paramètres d'entrée du nœud. La valeur de ce paramètre doit être au format JSON. Pour plus d'informations sur les paramètres d'entrée, consultez le paramètre InputContextParameterList dans la section Paramètres de réponse de l'opération GetFile.
Ce paramètre correspond au tableau Paramètres d'entrée dans la section Paramètres d'entrée et de sortie de l'onglet Propriétés de la console DataWorks.
OutputParameters
String
Non
[{"Type": 1,"Value": "${bizdate}","ParameterName": "bizdate_param"}]
Les paramètres de sortie du nœud. La valeur de ce paramètre doit être au format JSON. Pour plus d'informations sur les paramètres de sortie, consultez le paramètre OutputContextParameterList dans la section Paramètres de réponse de l'opération GetFile.
Ce paramètre correspond au tableau Paramètres de sortie dans la section Paramètres d'entrée et de sortie de l'onglet Propriétés de la console DataWorks.
-
Validez le nœud.
Appelez l'opération SubmitFile pour valider le nœud dans l'environnement de développement du système de planification. Après validation, le système renvoie une réponse contenant l'ID de la tâche de déploiement associée. Appelez l'opération GetDeployment pour obtenir les détails de la tâche de déploiement à partir de cet ID.
public void submitFile() throws ClientException{ SubmitFileRequest request = new SubmitFileRequest(); request.setProjectId(78837L); request.setProjectIdentifier("zxy_8221431"); // The ID is the value of the FileId parameter that is returned when you create the node. request.setFileId(501576542L); request.setComment("Comment"); SubmitFileResponse acsResponse = client.getAcsResponse(request); // The ID is the deployment task ID that is returned after you commit or deploy the node. Long deploymentId = acsResponse.getData(); log.info(acsResponse.toString()); }Le code ci-dessus illustre la configuration de certains paramètres. Pour plus d'informations, consultez les rubriques SubmitFile et GetDeployment.
-
Déployez le nœud dans l'environnement de production.
Appelez l'opération DeployFile pour déployer le nœud dans l'environnement de production.
RemarqueSi votre espace de travail est en mode standard, vous devez effectuer cette étape.
public void deploy() throws ClientException{ DeployFileRequest request = new DeployFileRequest(); request.setProjectIdentifier("zxy_8221431"); request.setFileId(501576542L); request.setComment("Comment"); // You must specify the NodeId or FileId parameter. The value of NodeId is the value of the Node ID parameter in the General section of the Properties tab on the configuration tab of the node. request.setNodeId(700004537241L); DeployFileResponse acsResponse = client.getAcsResponse(request); // The ID is the deployment task ID that is returned after you commit or deploy the node. Long deploymentId = acsResponse.getData(); log.info(acsResponse.getData().toString()); }Le code ci-dessus illustre la configuration de certains paramètres. Pour plus d'informations, consultez la rubrique DeployFile.
-
Interrogez le statut du nœud.
Après le déploiement du nœud, le système renvoie une réponse contenant l'ID de la tâche de déploiement associée. Appelez l'opération GetDeployment pour obtenir les détails de cette tâche à partir de l'ID. Si la valeur du paramètre Status dans la réponse de l'opération GetDeployment est 1, le nœud est déployé.
public void getDeployment() throws ClientException{ GetDeploymentRequest request = new GetDeploymentRequest(); request.setProjectId(78837L); request.setProjectIdentifier("zxy_8221431"); // The ID is the deployment task ID that is returned after you commit or deploy the node. Call the GetDeployment operation to obtain the details of the related deployment task. request.setDeploymentId(2776067L); GetDeploymentResponse acsResponse = client.getAcsResponse(request); log.info(acsResponse.getData().toString()); }Le code ci-dessus illustre la configuration de certains paramètres. Pour plus d'informations, consultez la rubrique GetDeployment.
Modifier la configuration du nœud
Après avoir créé et configuré un nœud de synchronisation de données dans Data Integration, appelez l'opération UpdateDISyncTask pour modifier sa configuration. Vous pouvez également utiliser le paramètre TaskParam pour changer le groupe de ressources exclusif utilisé par le nœud. Une fois la configuration modifiée, vous devez à nouveau valider et déployer le nœud. Pour plus d'informations, consultez la section Vue d'ensemble.
Exemple de code
Dépendances POM
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-core</artifactId>
<version>4.5.20</version>
</dependency>
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-dataworks-public</artifactId>
<version>3.4.1</version>
</dependency>SDK pour Java
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.dataworks_public.model.v20200518.*;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;
import java.util.List;
public class createofflineTask {
static Long createTask(String fileName) throws Exception {
Long projectId = 2043L;
String taskType = "DI_OFFLINE";
String taskContent = "{\n" +
" \"type\": \"job\",\n" +
" \"version\": \"2.0\",\n" +
" \"steps\": [\n" +
" {\n" +
" \"stepType\": \"mysql\",\n" +
" \"parameter\": {\n" +
" \"envType\": 0,\n" +
" \"datasource\": \"mysql_autotest_dev\",\n" +
" \"column\": [\n" +
" \"id\",\n" +
" \"name\"\n" +
" ],\n" +
" \"connection\": [\n" +
" {\n" +
" \"datasource\": \"mysql_autotest_dev\",\n" +
" \"table\": [\n" +
" \"user\"\n" +
" ]\n" +
" }\n" +
" ],\n" +
" \"where\": \"\",\n" +
" \"splitPk\": \"\",\n" +
" \"encoding\": \"UTF-8\"\n" +
" },\n" +
" \"name\": \"Reader\",\n" +
" \"category\": \"reader\"\n" +
" },\n" +
" {\n" +
" \"stepType\": \"odps\",\n" +
" \"parameter\": {\n" +
" \"partition\": \"pt=${bizdate}\",\n" +
" \"truncate\": true,\n" +
" \"datasource\": \"odps_first\",\n" +
" \"envType\": 0,\n" +
" \"column\": [\n" +
" \"id\",\n" +
" \"name\"\n" +
" ],\n" +
" \"emptyAsNull\": false,\n" +
" \"tableComment\": \"null\",\n" +
" \"table\": \"user\"\n" +
" },\n" +
" \"name\": \"Writer\",\n" +
" \"category\": \"writer\"\n" +
" }\n" +
" ],\n" +
" \"setting\": {\n" +
" \"executeMode\": null,\n" +
" \"errorLimit\": {\n" +
" \"record\": \"\"\n" +
" },\n" +
" \"speed\": {\n" +
" \"concurrent\": 2,\n" +
" \"throttle\": false\n" +
" }\n" +
" },\n" +
" \"order\": {\n" +
" \"hops\": [\n" +
" {\n" +
" \"from\": \"Reader\",\n" +
" \"to\": \"Writer\"\n" +
" }\n" +
" ]\n" +
" }\n" +
"}";
CreateDISyncTaskRequest request = new CreateDISyncTaskRequest();
request.setProjectId(projectId);
request.setTaskType(taskType);
request.setTaskContent(taskContent);
request.setTaskName(fileName);
request.setTaskParam("{\"FileFolderPath\":\"Business Flow/test/Data Integration\",\"ResourceGroup\":\"S_res_group_XXX\"}");
// Use an exclusive resource group for Data Integration.
CreateDISyncTaskResponse response1 = client.getAcsResponse(request);
return response1.getData().getFileId();
}
public static void updateFile(Long fileId) throws Exception {
UpdateFileRequest request = new UpdateFileRequest();
request.setProjectId(2043L);
request.setFileId(fileId);
request.setAutoRerunTimes(3);
request.setRerunMode("FAILURE_ALLOWED");
request.setCronExpress("00 30 05 * * ?");
request.setCycleType("DAY");
request.setResourceGroupIdentifier("S_res_group_XXX");
// Use an exclusive resource group for scheduling.
request.setInputList("dataworks_di_autotest_root");
request.setAutoParsing(true);
request.setDependentNodeIdList("5,10,15,20");
request.setDependentType("SELF");
request.setStartEffectDate(0L);
request.setEndEffectDate(4155787800000L);
request.setFileDescription("description");
request.setStop(false);
request.setParaValue("x=a y=b z=c");
request.setSchedulerType("NORMAL");
request.setAutoRerunIntervalMillis(120000);
UpdateFileResponse response1 = client.getAcsResponse(request);
}
static IAcsClient client;
public static void main(String[] args) throws Exception {
String akId = "XX";
// Please ensure that the environment variables ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET are set.https://www.alibabacloud.com/help/en/alibaba-cloud-sdk-262060/latest/configure-credentials-378659
IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
DefaultProfile.addEndpoint(regionId, "dataworks-public", "dataworks." + regionId + ".aliyuncs.com");
client = new DefaultAcsClient(profile);
String taskName = "offline_job_0930_1648";
Long fileId = createTask(taskName); // Create a data synchronization node in Data Integration.
updateFile(fileId); // Configure scheduling properties for the node.
}
}