Le graphe orienté acyclique (DAG) d'Operation Center visualise les dépendances en amont et en aval de vos nœuds. Il propose également des fonctionnalités telles que l'agrégation des nœuds, l'analyse en amont et l'analyse en aval pour améliorer l'efficacité opérationnelle. Cette rubrique décrit les fonctionnalités de la vue DAG.
Limitations
Les fonctionnalités d'agrégation des nœuds, d'analyse en amont et d'analyse en aval dans la vue DAG sont disponibles uniquement dans DataWorks Professional Edition ou une édition supérieure. Pour plus d'informations sur la mise à niveau de votre édition, consultez Éditions et facturation.
Fonctionnalités du DAG
Cliquez sur DAG à côté d'un nœud pour ouvrir sa vue DAG. L'interface DAG comprend un canevas central affichant le graphe des nœuds, une liste de nœuds à gauche pour la sélection, ainsi que des commandes pour les fonctionnalités telles que l'agrégation des nœuds, l'analyse en amont et l'analyse en aval en haut de la page. Vous pouvez effectuer les opérations suivantes dans la vue DAG. Cette rubrique utilise une instance déclenchée automatiquement comme exemple.
-
Agrégation des nœuds
Si une instance déclenchée automatiquement comporte un grand nombre de nœuds ou de niveaux de dépendance, agrégez les nœuds selon des dimensions telles que l'état du nœud, l'espace de travail, le propriétaire ou la priorité afin d'afficher le nombre de nœuds pour une dimension donnée. Cela vous aide à comprendre la distribution des nœuds et à gérer l'exécution plus efficacement. Les exemples suivants illustrent l'affichage lorsque les nœuds ne sont Not Aggregate pas agrégés et lorsqu'ils sont aggregated by priority agrégés par priorité.
RemarqueVous pouvez agréger les nœuds par état uniquement dans le DAG d'une instance. Une instance peut être une instance déclenchée automatiquement, une instance de remplissage des données ou une instance de test.
Lorsque les nœuds ne sont pas agrégés, chaque nœud s'affiche individuellement dans le DAG. Chaque nœud indique son nom et son type, tels que virtual node, ODPS SQL ou batch synchronization. Les lignes entre les nœuds indiquent les dépendances. Un message en bas indique que la vue actuelle contient 10 nœuds répartis sur 8 niveaux de dépendance.
Lorsque les nœuds sont agrégés par priorité, l'affichage est le suivant. Vous pouvez voir rapidement que le nœud actuel possède 6 nœuds enfants avec une priorité de 1. Le DAG agrégé affiche le chemin de dépendance, commençant par fanyi_test_root (nœud virtuel) en haut, passant par User Behavior Analysis Case Description (nœud virtuel), table_ddl_ods_raw_log_d (ODPS SQL), deux groupes agrégés contenant chacun deux nœuds, puis vers dws_user_info_all_di (ODPS SQL), ads_user_info_1d (ODPS SQL) et enfin vers User Behavior Analysis Result Query (ODPS SQL). Les flèches entre les nœuds indiquent les dépendances de planification. Le panneau de gauche répertorie tous les noms de tâches et vous permet de sélectionner des nœuds à l'aide de cases à cocher.
-
Analyse en amont
Si un nœud reste en attente pendant une longue période, effectuez une analyse en amont. Cette opération révèle les nœuds en amont bloquants, ce qui vous permet de localiser et de résoudre rapidement les erreurs d'exécution pour améliorer l'efficacité d'exécution.
RemarqueVous pouvez utiliser la fonctionnalité d'analyse en amont uniquement dans le DAG d'une instance. Une instance peut être une instance déclenchée automatiquement, une instance de remplissage des données ou une instance de test.
Effectuez une Upstream Analysis uniquement sur les nœuds qui ne sont pas en cours d'exécution. Un maximum de six niveaux s'affiche. Si vous souhaitez afficher plus de niveaux, cliquez sur Continue Analysis dans le coin supérieur gauche.
L'analyse en amont vous aide à trouver rapidement les nœuds ancêtres dont dépend le nœud actuel mais qui ne se sont pas exécutés avec succès. Ces nœuds peuvent être dans l'état Running, Failed, Pending (Time), Pending (Resource) ou Frozen. Les nœuds ancêtres dans ces états bloquent l'exécution en aval.
Si un nœud d'exemple ne s'est pas exécuté depuis longtemps, sélectionnez-le et cliquez sur Upstream Analysis dans le coin supérieur gauche. Le résultat de l'analyse indique que le nœud en amont bloquant est le nœud
old_work_root. Grâce à ce résultat, vous pouvez localiser rapidement le nœud bloquant et traiter les erreurs associées.RemarqueÉtapes suivantes :
Après avoir localisé l'instance clé, filtrez par une dimension d'agrégation pour afficher l'espace de travail ou le propriétaire de l'instance clé qui affecte la sortie de données du nœud actuel. Cela améliore l'efficacité opérationnelle.
Une fois l'instance bloquante localisée, vous pouvez également cliquer dessus avec le bouton droit de la souris et sélectionner Run Diagnostics pour analyser rapidement la raison de l'échec de son exécution. Pour plus d'informations, consultez Diagnostic intelligent.
Dans les résultats de l'analyse en amont, old_work_root est un nœud virtuel et son nœud dépendant en aval est le nœud sd de type ODPS SQL.
-
Analyse en aval
Par défaut, la vue DAG affiche trois niveaux : le nœud actuel, ses nœuds ancêtres immédiats (un niveau au-dessus) et ses nœuds descendants immédiats (un niveau en dessous). Lorsqu'une instance déclenchée automatiquement comporte un grand nombre de nœuds ou de niveaux, il peut être difficile de visualiser l'étendue complète de l'impact. Utilisez la fonctionnalité d'analyse en aval pour filtrer selon des critères tels que l'état du nœud, l'espace de travail, le propriétaire ou la priorité. Cela vous aide à compter le nombre de nœuds à différents niveaux ou le nombre total de nœuds sur tous les niveaux pour une dimension spécifique.
RemarqueVue fusionnée ou stratifiée dans un état agrégé : après avoir cliqué sur Downstream Analysis, les nœuds sont agrégés par propriétaire par défaut et le nombre total de nœuds pour cette dimension sur tous les niveaux est calculé.
Vue groupée sans agrégation : s'il y a plus de 10 nœuds en aval, ils s'affichent par groupes par défaut. Cette vue offre une compréhension plus intuitive de l'impact commercial des nœuds.
Vue non groupée : dans la vue non agrégée, cliquez sur Ungroup pour développer les nœuds groupés. Cela vous permet de voir les relations en amont et en aval de tous les nœuds.
La vue Layer pour une Downstream Analysis affiche un maximum de six niveaux. Pour afficher plus de niveaux, cliquez sur Continue Analysis dans le coin supérieur gauche.
L'exemple suivant montre les résultats de l'exécution d'une Downstream Analysis sur le nœud tag :
Vue fusionnée : fusionne les nœuds en aval analysés en fonction de la dimension d'agrégation actuelle. Dans un état non agrégé, les nœuds en aval s'affichent par groupes. Dans cet exemple, la méthode Merge est utilisée et les nœuds sont aggregated by workspace agrégés par espace de travail. Tous les nœuds en aval sont fusionnés en une seule couche, affichant le nombre de nœuds appartenant à différents espaces de travail. Après avoir cliqué sur le bouton Merged dans la vue DAG, le résultat de l'analyse en aval pour le nœud tag s'affiche en mode fusionné. Les sept nœuds en aval sont présentés dans des groupes agrégés, chaque groupe contenant un nombre différent de nœuds descendants. La barre d'état en bas indique que 42 nœuds et 5 niveaux sont actuellement affichés.
Vue stratifiée : affiche les nœuds en aval analysés par niveau de dépendance en fonction de la dimension d'agrégation actuelle. Dans cet exemple, la méthode Layer est utilisée et les nœuds sont aggregated by workspace agrégés par espace de travail, affichant le nombre de nœuds dans différents espaces de travail à différents niveaux. Après avoir sélectionné la vue DAG et cliqué sur le bouton Layered, les nœuds en aval sont disposés de haut en bas par niveau. Chaque niveau affiche le nombre de nœuds qu'il contient et le bas de la page affiche le nombre total de nœuds et de niveaux affichés (par exemple, « 42 nœuds et 5 niveaux sont affichés »).
-
Styles d'affichage du DAG
Cliquez sur les icônes de fonction dans le coin supérieur droit de la vue DAG pour ajuster son style d'affichage. Par exemple, utilisez Toggle Full Screen View ou Fit Screen.
Les exemples suivants montrent le DAG pour les nœuds en aval d'un nœud dans les vues Ungroup et Group.
DAG Ungroup : cette vue vous aide à comprendre clairement les relations en amont et en aval de tous les nœuds. En mode non groupé, chaque nœud en aval s'affiche sous forme de carte individuelle disposée par niveau de dépendance, affichant un total de 15 nœuds et 2 niveaux. Cliquez sur l'icône Snapshot dans la barre d'outils de droite pour enregistrer le DAG actuel sous forme d'image.
DAG Group : cette vue affiche les nœuds en aval de manière ordonnée, avec cinq nœuds par ligne, ce qui facilite la visualisation rapide du nombre total de nœuds en aval.
Le DAG affiche les dépendances en amont et en aval entre les nœuds. Une ligne pleine indique une dépendance au sein du même cycle et une ligne pointillée indique une dépendance inter-cycles. Vous pouvez également cliquer avec le bouton droit de la souris sur un nœud pour effectuer des opérations.
|
Actions |
Description |
|
Show ancestor nodes/Show descendant nodes |
Operation Center réduit automatiquement les workflows comportant trois nœuds ou plus. Utilisez cette option pour développer tous les niveaux ancêtres et descendants. |
|
View Runtime Log |
Affichez le journal d'exécution de l'instance actuelle, qui peut être dans l'état Running, Succeeded ou Failed. Remarque
|
|
Run Diagnostics |
DataWorks Operation Center propose une fonctionnalité de diagnostic d'exécution pour vous aider à obtenir des informations de bout en bout sur l'exécution des nœuds et à localiser rapidement les problèmes. Pour plus d'informations, consultez Diagnostic intelligent. |
|
View Code |
Affichez le code de l'instance actuelle. |
|
Edit Node |
Ouvre le nœud dans DataStudio pour modification. |
|
View Lineage |
Affichez la lignée de données de l'instance actuelle. |
|
More |
Cliquez pour afficher des informations sur le nœud actuel, telles que Property, Context, Runtime Log, Operation Log et Code. |
|
Terminate |
Vous pouvez arrêter uniquement les instances dans l'état Pending ou Running. Après cette opération, l'état de l'instance passe à Failed. |
|
Rerun |
Réexécute un nœud. Une réexécution réussie déclenche ses nœuds en aval. Cette opération est souvent utilisée pour les exécutions ayant échoué ou manquées. Remarque
Vous pouvez réexécuter uniquement les nœuds dans l'état Not Running, Successful ou Failed. |
|
Rerun Descendent Nodes |
Réexécute un nœud et ses nœuds en aval. Vous devez sélectionner les nœuds à réexécuter. Après l'exécution réussie d'un nœud sélectionné, il peut déclencher la planification de ses nœuds en aval qui ne se sont pas encore exécutés. Cette opération est souvent utilisée pour le patching de données. Remarque
Vous pouvez sélectionner uniquement les nœuds dans les états Not Running, Complete et Failed. Si vous sélectionnez un nœud dans un autre état, la page affiche le message The selected nodes include nodes that do not meet the running conditions et la soumission de l'exécution est désactivée. |
|
Set to Successful |
Modifie l'état d'une instance ayant échoué en Succeeded et déclenche ses nœuds en aval. Cette opération est généralement utilisée pour récupérer après un échec. Remarque
Vous pouvez définir l'état sur Succeeded uniquement pour un nœud dans l'état Failed. Vous ne pouvez pas définir l'état sur Succeeded pour un workflow. |
|
Resume |
Si un nœud échoue lors de son exécution, vous pouvez le reprendre. Cette fonctionnalité est prise en charge uniquement pour les nœuds MaxCompute. Remarque
Si vous avez acheté un groupe de ressources exclusif pour la planification avant janvier 2021 et que vous devez effectuer une mise à niveau, vous devez d'abord cliquer sur le lien de candidature pour rejoindre le groupe de discussion « Alibaba Cloud Big Data & AI Platform ». Ensuite, scannez le code QR suivant pour rejoindre le groupe DingTalk du produit DataWorks pour le support avant-vente et après-vente. Vous pouvez @ le robot intelligent pour obtenir de l'aide ou contacter directement le personnel de service pendant les heures de support. |
|
Emergency Operations |
Opérations pour l'instance actuelle dans des situations urgentes. Les opérations d'urgence sont effectives uniquement pour l'exécution actuelle du nœud. Delete Dependencies : supprime les dépendances du nœud pour l'exécution actuelle. Cette option est utile si un nœud en amont requis a échoué. |
|
Freeze |
Le gel d'une instance déclenchée automatiquement s'applique uniquement à son exécution actuelle. Une instance déclenchée automatiquement gelée n'est pas planifiée automatiquement et ne traite pas les données. Elle bloque également la planification automatique de ses nœuds en aval. Scénario : si vous planifiez l'exécution d'un nœud toutes les heures, 24 instances sont générées pour la journée. Si l'une de ces instances horaires n'a pas besoin de s'exécuter, vous pouvez choisir de geler cette instance. Le gel d'une instance horaire n'affecte pas l'exécution des autres instances. Une fois l'opération de gel terminée, vous pouvez afficher l'enregistrement correspondant Freeze instance scheduling dans l'onglet Operation Log du nœud, qui inclut l'heure de l'opération, l'opérateur et les détails. |
|
Unfreeze |
Dégèle une instance qui se trouve dans un état gelé.
Remarque
L'opération de dégel affecte uniquement l'instance actuelle. Si la tâche périodique du nœud est gelée, les instances suivantes seront toujours créées dans un état gelé. |
Cliquez sur une instance ; un volet de détails de l'instance apparaît dans le coin inférieur droit de la page. Cliquez sur Show Details dans le volet pour afficher les détails d'une seule instance. L'exemple suivant utilise une instance déclenchée automatiquement.
|
Onglet |
Description |
|
Property |
Sur cet onglet, vous pouvez afficher les propriétés de planification de la tâche dans l'environnement de production. Pour plus d'informations sur les paramètres, consultez Configurer les propriétés de planification.
|
|
Runtime Log |
Utilisé pour afficher le processus d'exécution détaillé de la tâche. |
|
Operation Log |
Utilisé pour afficher les enregistrements d'opération d'une tâche ou d'une instance, y compris l'heure, l'opérateur et l'opération spécifique. |
|
Code |
Utilisé pour afficher le dernier code de la tâche actuelle dans l'environnement de production. Si le code est incorrect, vérifiez que la dernière version a été déployée avec succès. Pour plus d'informations, consultez Déployer des tâches. |
