Le nœud de surveillance de la qualité dans DataWorks vous permet de configurer des règles pour surveiller la qualité des données des tables de vos sources de données et détecter les données erronées. Vous pouvez également personnaliser les politiques de planification pour exécuter périodiquement des tâches de validation des données. Cette rubrique décrit comment utiliser un nœud de surveillance de la qualité pour contrôler la qualité des données.
Contexte
La fonctionnalité Data Quality de DataWorks vous aide à détecter les modifications apportées aux données source et à identifier les données erronées générées lors du processus ETL (Extract, Transform, Load). Elle intercepte automatiquement les tâches problématiques pour empêcher la propagation des données erronées vers l'aval. Cela évite que des données inattendues ne perturbent les opérations et n'affectent les décisions commerciales. Elle réduit également considérablement le temps de dépannage et économise des ressources en évitant les réexécutions de tâches. Pour plus d'informations, consultez Data Quality.
Limites
Types de table pris en charge : MaxCompute, E-MapReduce, Hologres, CDH Hive, AnalyticDB for PostgreSQL, AnalyticDB for MySQL et StarRocks.
-
Portée des tables prises en charge :
Vous pouvez surveiller uniquement les tables des sources de données liées à l'espace de travail où se trouve le nœud de surveillance de la qualité.
-
Chaque nœud peut surveiller une seule table, mais vous pouvez configurer plusieurs règles de surveillance pour celle-ci. La portée de la surveillance varie selon le type de table :
Pour une table non partitionnée, la table entière est surveillée par défaut.
Pour une table partitionnée, vous devez spécifier une partition à surveiller à l'aide d'une expression de filtre de partition.
RemarquePour surveiller plusieurs tables, créez plusieurs nœuds.
-
Limites opérationnelles :
Les règles de surveillance de la qualité créées dans Data Studio peuvent être exécutées, modifiées et déployées uniquement au sein de Data Studio. Bien que ces règles soient visibles dans le module Data Quality, vous ne pouvez ni les déclencher selon une planification ni les gérer depuis cet emplacement.
Si vous modifiez les règles de surveillance dans un nœud de surveillance de la qualité, puis que vous déployez le nœud, les règles de surveillance précédemment générées sont remplacées.
Prérequis
-
Un moteur de calcul est lié à votre espace de travail et la table que vous souhaitez surveiller y a été créée.
Avant d'exécuter une tâche de surveillance de la qualité des données, vous devez créer la table que le nœud de surveillance vérifiera. Pour plus d'informations, consultez Lier un moteur de calcul et Développer un nœud.
-
Un groupe de ressources a été créé.
Les nœuds de surveillance de la qualité peuvent s'exécuter uniquement sur un groupe de ressources serverless. Pour plus d'informations, consultez Gérer les groupes de ressources.
(Facultatif, pour les utilisateurs RAM) L'utilisateur RAM dédié au développement des tâches est ajouté à l'espace de travail correspondant et reçoit le rôle Development ou Workspace Administrator. Le rôle Workspace Administrator dispose d'autorisations étendues et doit être attribué avec prudence. Pour plus d'informations sur l'ajout et l'autorisation des membres, consultez Ajouter des membres à un espace de travail.
Étape 1 : Créer un nœud de surveillance de la qualité
Accédez à la page Workspaces de la console DataWorks. Dans la barre de navigation supérieure, sélectionnez la région souhaitée. Recherchez l'espace de travail désiré et choisissez dans la colonne Actions.
Dans le volet de navigation de gauche, cliquez sur
pour accéder à Data Development. À côté de Project Directory, cliquez sur
et choisissez . Suivez les instructions affichées à l'écran pour saisir le chemin d'accès et le nom du nœud, puis créez-le.
Étape 2 : Configurer les règles de surveillance de la qualité
1. Sélectionner la table à surveiller
Sur la page de l'éditeur du nœud de surveillance de la qualité, cliquez sur Add Table. Dans la boîte de dialogue Add Table, sélectionnez la table à surveiller. Vous pouvez utiliser le filtre More pour localiser la table plus rapidement.
Si votre table ne figure pas dans la liste, accédez à My Data dans Data Map.
2. Configurer la portée des données de surveillance
Table non partitionnée : la table entière est surveillée par défaut. Vous pouvez ignorer cette étape.
Table partitionnée : vous devez sélectionner les données de partition à surveiller. Vous pouvez utiliser paramètres de planification. Cliquez sur Preview pour vérifier que l'expression de filtre de partition est résolue correctement.
3. Configurer les règles de surveillance de la qualité des données
Vous pouvez créer de nouvelles règles ou importer des règles existantes. Les règles configurées sont activées par défaut.
Lorsque vous créez des règles dans un nœud de surveillance de la qualité, vous pouvez utiliser la fonctionnalité DataWorks Copilot rule recommendation pour générer intelligemment des règles de qualité basées sur les informations de votre table. Vous pouvez ensuite accepter ou rejeter les suggestions selon vos besoins.
DataWorks Copilot est en aperçu public dans certaines régions. S'il n'est pas disponible dans la région où se trouve votre espace de travail, vous pouvez créer ou importer manuellement des règles comme décrit dans cette rubrique.
-
Créer une nouvelle règle
Cliquez sur Create Rule pour créer une règle de surveillance de la qualité basée sur un modèle ou sur du SQL personnalisé. Les sections suivantes décrivent ces méthodes.
Modèle intégré
Suivez ces étapes pour créer rapidement une règle de surveillance de la qualité à partir d'un modèle de règle.
RemarqueVous pouvez également trouver le modèle de règle requis dans la liste des modèles intégrés à gauche et cliquer sur + Use pour le créer.
Cliquez sur l'onglet + Built-in Template Rule à droite de la boîte de dialogue. Dans le panneau Built-in Templates à gauche, développez une catégorie de modèle telle que Table Row Count, recherchez le modèle cible et cliquez sur + Use. Dans le formulaire à droite, configurez les paramètres de la règle et cliquez sur OK.
Modèle personnalisé
Avant d'utiliser cette méthode, vous devez d'abord créer un modèle de règle personnalisé dans . Vous pouvez ensuite créer des règles de surveillance de la qualité à partir de ce modèle. Pour plus d'informations, consultez Créer et gérer des modèles de règles personnalisés.
Les étapes suivantes montrent comment créer une règle de qualité des données à partir d'un modèle personnalisé.
RemarqueVous pouvez également trouver le modèle de règle requis dans la liste des modèles personnalisés à gauche et cliquer sur + Use pour le créer.
Dans la boîte de dialogue Create Rule, cliquez sur l'onglet + Custom Template Rule. Configurez Rule Name, Rule Template, Quality Dimension, FLAG Parameter, SQL, Comparison Method et Monitoring Threshold (y compris les seuils normaux et rouges), puis cliquez sur OK.
SQL personnalisé
Cette méthode vous permet de définir une logique de validation de la qualité des données personnalisée pour une table.
Cliquez sur l'onglet + Custom SQL en haut. Dans le formulaire à droite, configurez Rule Name, Rule Template (sélectionnez Custom SQL), Quality Dimension, FLAG Parameter, SQL, Comparison Method (choisissez Manual Settings ou Intelligent Dynamic Threshold) et Monitoring Threshold, puis cliquez sur OK.
-
Importer des règles existantes
Si des règles de surveillance pour la table cible existent déjà dans le module Data Quality, vous pouvez les importer pour cloner rapidement les règles. Si aucune règle n'existe, accédez à Data Quality pour les créer au préalable. Pour plus d'informations, consultez Configurer les règles : par table (table unique).
RemarqueCette méthode prend en charge l'importation de plusieurs règles en bloc et permet de configurer des règles de surveillance au niveau des champs de la table.
Cliquez sur Import Rule. Vous pouvez rechercher et sélectionner les règles à importer par ID ou nom de règle, modèle de règle ou portée associée (table entière ou champs spécifiques).
Après avoir sélectionné les règles, cliquez sur OK pour terminer l'importation.
Une fois qu'un nœud de surveillance de la qualité est déployé, les règles qu'il contient peuvent être consultées dans le module Data Quality, mais les opérations de gestion telles que la modification ou la suppression ne sont pas autorisées à cet endroit.
4. Configurer les ressources d'exécution
Sélectionnez les ressources d'exécution pour les vérifications des règles de qualité. Cette sélection détermine la source de données dans laquelle la tâche de surveillance de la qualité s'exécute. Par défaut, il s'agit de la source de données où se trouve la table surveillée.
Si vous sélectionnez une autre source de données, assurez-vous qu'elle dispose des autorisations d'accès à la table.
Étape 3 : Configurer les politiques de traitement
Dans la section Handling Policy de la page de l'éditeur du nœud, vous pouvez configurer des politiques de traitement et des abonnements aux notifications pour les exceptions détectées par les règles de surveillance de la qualité.
Catégories d'exception
|
Catégorie d'exception |
Description |
|
Règle forte : échec de la vérification |
|
|
Règle forte : exception critique |
|
|
Règle forte : exception d'avertissement |
|
|
Règle faible : échec de la vérification |
|
|
Règle faible : exception critique |
|
|
Règle faible : exception d'avertissement |
Politiques de traitement des exceptions
Vous pouvez configurer des politiques de traitement pour les exceptions générées par les vérifications de règles :
-
Ne pas ignorer : si une catégorie d'exception spécifique est détectée (par exemple, une règle forte déclenche une exception critique), vous pouvez configurer le système pour arrêter le nœud actuel et définir son statut sur Échec.
RemarqueAprès l'échec du nœud actuel, les nœuds en aval ne seront pas exécutés. Cela bloque le pipeline de production et empêche la propagation des données problématiques.
Vous pouvez ajouter plusieurs catégories d'exceptions à vérifier.
Cette politique est généralement utilisée lorsqu'une exception a un impact majeur et doit bloquer les tâches en aval.
Ignorer : ignorez l'exception et continuez à exécuter les nœuds en aval.
Méthodes de notification des exceptions
Vous pouvez configurer la manière de recevoir les notifications pour les exceptions (par exemple, par e-mail). Lorsqu'une exception se produit, la plateforme envoie une notification via la méthode spécifiée afin que vous puissiez traiter l'exception rapidement.
La plateforme prend en charge plusieurs méthodes de notification, qui peuvent varier selon l'interface utilisateur. Notez les points suivants :
Les notifications par e-mail, par e-mail et SMS, et par téléphone ne peuvent être envoyées qu'aux utilisateurs du compte actuel. Assurez-vous que les adresses e-mail et les numéros de téléphone des destinataires sont configurés correctement. Pour plus d'informations, consultez Afficher et définir les contacts d'alerte.
Pour les autres méthodes, vous devez saisir l'URL du webhook pour recevoir les notifications. Pour obtenir des instructions sur la manière d'obtenir cette URL, consultez Obtenir une URL de webhook.
Étape 4 : Configurer la planification
Pour exécuter la tâche du nœud périodiquement, cliquez sur Scheduling Settings à droite de la page de l'éditeur du nœud et configurez les propriétés de planification en fonction de vos besoins métier. Pour plus d'informations, consultez Configurer la planification d'un nœud.
Étape 5 : Déboguer la tâche
Effectuez les opérations de débogage suivantes selon les besoins pour vérifier si la tâche s'exécute comme prévu.
-
(Facultatif) Sélectionnez le groupe de ressources d'exécution et attribuez des valeurs aux paramètres personnalisés.
À droite du nœud de surveillance de la qualité, cliquez sur Run Configuration et configurez le Resource Group for Scheduling à utiliser pour l'exécution de débogage.
Si votre tâche utilise des paramètres de planification, vous pouvez attribuer des valeurs aux variables dans la section Script Parameters pour le débogage. Pour plus d'informations sur la logique d'attribution des paramètres, consultez Déboguer une tâche.
-
Enregistrez et exécutez la tâche.
Cliquez sur l'icône
dans la barre d'outils supérieure pour enregistrer la tâche. Cliquez sur l'icône
pour exécuter la tâche.Une fois la tâche terminée, vous pouvez afficher les résultats d'exécution en bas de la page de l'éditeur du nœud. Si l'exécution échoue, résolvez le problème en vous basant sur le message d'erreur.
Étape 6 : Déployer la tâche
Une fois la tâche du nœud configurée, vous devez la déployer. Après le déploiement, le nœud s'exécute périodiquement selon sa configuration de planification.
Lorsque vous déployez un nœud de surveillance de la qualité, les règles de qualité configurées au sein de celui-ci sont également déployées.
Dans la barre d'outils supérieure, cliquez sur l'icône
pour enregistrer le nœud.Dans la barre d'outils supérieure, cliquez sur l'icône
pour déployer le nœud.
Pour plus d'informations sur le déploiement des nœuds, consultez Déployer des nœuds et des workflows.
Étapes suivantes
O&M des tâches : après le déploiement d'une tâche, elle s'exécute périodiquement en fonction de sa configuration de planification. Vous pouvez cliquer sur O&M dans le coin supérieur droit de la page de l'éditeur du nœud pour accéder à Operation Center et afficher les détails de planification et d'exécution de la tâche, tels que l'état d'exécution du nœud et les détails des règles déclenchées. Pour plus d'informations, consultez Gérer les tâches planifiées.
Data Quality : après le déploiement d'une règle de surveillance de la qualité, vous pouvez accéder au module Data Quality pour afficher les détails de la règle. Toutefois, vous ne pouvez pas y effectuer d'opérations de gestion telles que la modification ou la suppression de la règle. Pour plus d'informations, consultez Data Quality.