Cette rubrique utilise la tâche write_result, configurée pour s'exécuter chaque semaine, afin d'illustrer la configuration des propriétés de planification et de dépendance dans DataWorks.
Prérequis
Vous avez créé un nœud sans charge (start) et un nœud ODPS SQL (insert_data). Pour plus d'informations, consultez la rubrique Créer un workflow.
Vous avez créé une tâche de synchronisation à partir du nœud de synchronisation write_result. Pour plus d'informations, consultez la rubrique Créer une tâche de synchronisation.
Contexte
DataWorks prend en charge le déclenchement des planifications par heure et par dépendances. Le service peut planifier avec précision et ponctualité des dizaines de millions de tâches quotidiennes en fonction de leurs relations DAG. Vous pouvez configurer des cycles de planification à la minute, à l'heure, au jour, à la semaine ou au mois. Pour plus d'informations, consultez la rubrique Configurer les propriétés temporelles.
Configurer les propriétés temporelles
-
Accédez à la page DataStudio.
Connectez-vous à la console DataWorks. Dans la région cible, cliquez sur dans le volet de navigation de gauche. Sélectionnez un espace de travail dans la liste déroulante et cliquez sur Go to Data Development.
Dans le workflow correspondant, double-cliquez sur le nœud de synchronisation hors ligne write_result pour ouvrir sa page d'édition.
-
Dans le volet de navigation situé à droite de la page d'édition, cliquez sur Scheduling.
RemarqueLes nœuds créés dans un workflow manuel doivent être déclenchés manuellement et ne peuvent pas s'exécuter via la planification.
-
Dans la zone Time Properties, configurez les propriétés temporelles de planification de la tâche.
Paramètre
Description
Instance Generation Mode
Les options incluent Next Day et Immediately After Deployment. Pour plus d'informations, consultez la rubrique Modes de génération d'instances.
Recurrence
-
Normal : démarre la planification à l'heure configurée dans chaque cycle de planification et exécute la tâche normalement pour traiter les données.
-
Suspend scheduling : démarre la planification à l'heure configurée dans chaque cycle de planification, mais met le nœud en pause afin qu'il ne traite pas les données.
-
Dry Run : démarre la planification à l'heure configurée dans chaque cycle de planification, mais exécute le nœud en tant que tâche sans charge, sans traitement des données.
Scheduling period
Le cycle d'exécution du nœud peut être annuel, mensuel, hebdomadaire, quotidien, horaire ou à la minute. Dans cet exemple, la planification démarre à
00:00tous les lundis et mardis.cron expression
Affichée par défaut en fonction de l'heure de planification configurée et ne peut pas être modifiée.
Timeout Definition
La tâche est automatiquement arrêtée si sa durée d'exécution dépasse le délai d'expiration.
-
Le délai d'expiration s'applique aux instances récurrentes, aux instances de remplissage et aux instances de test.
-
Le délai d'expiration par défaut est ajusté dynamiquement en fonction de la charge réelle du système et varie de 3 à 7 jours.
Remarque-
Timeout Definition La valeur maximale peut être définie sur 168 heures.
-
Les frais de trafic, de calcul et autres encourus par une tâche s'appliquent toujours si la tâche est arrêtée car son exécution dépasse le délai d'expiration.
Rerun attribute
Les options incluent You can run again after successful or failed operation., Do not re-run after successful operation, and re-run after failure. et Disallow Regardless of Running Status.
Auto Rerun upon Failure
Si Rerun attribute est défini sur You can run again after successful or failed operation. et Do not re-run after successful operation, and re-run after failure., cette propriété est affichée et vous pouvez configurer les réexécutions automatiques après les erreurs de tâche. Si elle est définie sur Disallow Regardless of Running Status, cette propriété est masquée et la tâche ne sera pas réexécutée automatiquement après une erreur.
Rerun Times
Lorsque vous sélectionnez Error automatic re-run, vous devez configurer Rerun Times.
Rerun Interval
Lorsque vous sélectionnez Error automatic re-run, vous devez configurer Rerun Interval. L'intervalle par défaut entre les réexécutions est de 30 minutes. Vous pouvez le définir sur un minimum de 1 minute et un maximum de 30 minutes.
Validity Period
Période de validité du nœud. Définissez-la selon vos besoins.
Pour plus d'informations sur les propriétés temporelles, consultez la rubrique Configurer les propriétés temporelles.
-
Configurer les dépendances de planification
Les propriétés de dépendance spécifient les dépendances en amont du nœud. Même lorsque l'instance du nœud actuel atteint son heure planifiée, elle ne démarre qu'après la fin de l'exécution des instances en amont.
Par exemple, l'instance du nœud actuel ne démarre qu'après la fin de l'exécution de l'instance du nœud insert_data en amont.
D'un point de vue métier, un nœud en aval doit attendre qu'un nœud en amont produise les données de table avant de pouvoir les traiter, par exemple pour nettoyer la table en amont ou écrire les résultats nettoyés dans une autre base de données. Ces opérations nécessitent que le nœud en amont s'exécute avec succès et produise les données. Les dépendances de planification garantissent que les données en amont sont disponibles au démarrage du nœud en aval. Pour plus d'informations sur les dépendances de planification, consultez la rubrique Guide de configuration des dépendances de planification.
Par défaut, le système de planification crée un nœud workspace_name_root en tant que racine de chaque espace de travail. Un nœud sans autre nœud en amont peut dépendre directement de ce nœud racine.
Soumettre et publier la tâche
Dans la page d'édition du nœud write_result, cliquez sur l'icône

dans la barre d'outils pour enregistrer le nœud.-
Soumettez la tâche.
RemarqueVous devez définir les propriétés Rerun attribute et Parent Nodes du nœud avant de pouvoir soumettre la tâche.
Cliquez sur l'icône

dans la barre d'outils.Dans la boîte de dialogue Submit, saisissez une Change Description.
Cliquez sur OK.
Si vous utilisez un espace de travail en Standard mode, la tâche de synchronisation est disponible dans l'environnement de développement après la soumission. Pour la publier dans l'Production Environment pour la periodic scheduling, cliquez sur Task Publishing. Publiez la tâche de synchronisation dans l'environnement de production sur cette page. Pour obtenir des instructions, consultez la rubrique Publier des tâches.
Une tâche de synchronisation commence à générer des instances aux heures configurées et à s'exécuter automatiquement selon son cycle de planification à partir du lendemain uniquement après avoir été soumise au système de planification.
RemarqueSi vous soumettez la tâche de synchronisation après 23 h 30, le système de planification commencera à générer des instances récurrentes et à les exécuter automatiquement le troisième jour.
Étapes suivantes
Vous avez appris à configurer les propriétés de planification et de dépendance pour une tâche de synchronisation hors ligne. Dans le tutoriel suivant, vous apprendrez à effectuer des opérations sur les tâches récurrentes et à inspecter les journaux pour résoudre les problèmes de la tâche soumise. Pour plus d'informations, consultez la rubrique Exécuter et dépanner les tâches.