DataWorks met à votre disposition des nœuds DRDS pour développer et planifier l'exécution périodique de tâches DRDS, ainsi que pour intégrer ces dernières avec d'autres types de tâches. Cette rubrique explique comment utiliser un nœud DRDS afin de développer des tâches.
Informations générales
PolarDB for Xscale (PolarDB-X), anciennement appelé DRDS, est un service de base de données distribuée. Il permet une mise à l'échelle horizontale pour faire évoluer une base de données relationnelle vers un système distribué capable de stocker et d'accéder à de grands volumes de données. PolarDB-X conserve les fonctionnalités natives des bases de données relationnelles, telles que MySQL. Pour plus d'informations, consultez la page Présentation.
Prérequis
-
Le flux métier a été créé.
Data Studio effectue les opérations de développement spécifiques au moteur en se basant sur les flux métier. Avant de créer un nœud, créez un flux métier. Pour plus d'informations, consultez la page Créer un flux métier.
-
Une source de données DRDS a été ajoutée.
Ajoutez votre base de données PolarDB-X à DataWorks en tant que source de données DRDS avant de pouvoir l'utiliser pour accéder aux données qu'elle contient. Pour savoir comment ajouter une source de données, consultez la page Ajouter et gérer des sources de données. Pour en savoir plus sur l'utilisation d'une source de données DRDS dans DataWorks, reportez-vous à la section Source de données DRDS (PolarDB-X 1,0).
RemarqueVous ne pouvez créer des nœuds DRDS qu'à partir de sources de données DRDS ajoutées à DataWorks via une chaîne de connexion JDBC (Java Database Connectivity).
-
Une connexion réseau est établie entre votre source de données et un groupe de ressources.
Assurez-vous que la source de données souhaitée est connectée au groupe de ressources que vous souhaitez utiliser. Pour plus d'informations sur la configuration de la connectivité réseau, consultez la page Établir une connexion réseau entre un groupe de ressources et une source de données.
(Facultatif ; requis pour les utilisateurs RAM) L'utilisateur RAM utilisé pour le développement des tâches a été ajouté à l'espace de travail cible et s'est vu attribuer le rôle Development ou Workspace Administrator (ce dernier octroie des autorisations étendues ; attribuez-le avec prudence). Pour plus d'informations sur l'ajout de membres et l'attribution d'autorisations, consultez la page Ajouter des membres à un espace de travail.
Limites
Ce type de nœud est pris en charge dans les régions suivantes : Chine (Hangzhou), Chine (Shanghai), Chine (Beijing), Chine (Shenzhen), Chine (Chengdu), Chine (Hong Kong), Singapour, Malaisie (Kuala Lumpur), Allemagne (Francfort), États-Unis (Silicon Valley) et États-Unis (Virginie).
Étape 1 : Créer un nœud DRDS
-
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, puis cliquez sur Go to Data Development.
Cliquez avec le bouton droit sur le workflow cible, puis choisissez .
Dans la boîte de dialogue Create Node, saisissez un Name pour le nœud, puis cliquez sur OK. Une fois le nœud créé, développez et configurez la tâche dans l'éditeur de nœud.
Étape 2 : Développer une tâche DRDS
(Facultatif) Sélectionner une source de données DRDS
Si plusieurs sources de données DRDS ont été ajoutées à votre espace de travail, sélectionnez-en une dans la liste déroulante Select Data Source située en haut de l'onglet de configuration du nœud, selon vos besoins métier. Si une seule source de données DRDS est ajoutée à votre espace de travail, celle-ci est utilisée par défaut pour le développement des tâches.
Vous ne pouvez créer des nœuds DRDS qu'à partir de sources de données DRDS ajoutées à DataWorks via une chaîne de connexion JDBC (Java Database Connectivity).
Développer du code SQL : Exemple simple
Rédigez le code de la tâche dans l'éditeur de code situé sur l'onglet de configuration du nœud DRDS. Voici un exemple de code :
SELECT * FROM usertablename;Développer du code SQL : Utiliser des paramètres de planification
DataWorks propose des Scheduling Parameter qui permettent de transmettre dynamiquement des paramètres au code dans les scénarios de planification périodique. Dans une tâche de nœud, définissez une variable dans votre code en utilisant le format ${nom_variable}. Ensuite, attribuez une valeur à cette variable dans la section scheduling properties > Scheduling Parameter de la barre de navigation droite de la page d'édition du nœud. Pour plus d'informations sur les formats pris en charge et les détails de configuration, consultez les pages Formats pris en charge pour les paramètres de planification et Configurer et utiliser les paramètres de planification.
Exemple de code :
SELECT '${var}'; -- You can assign a specific scheduling parameter to the var variable.Étape 3 : Configurer la planification des tâches
Pour exécuter périodiquement la tâche du nœud, cliquez sur Scheduling sur le côté droit de la page d'édition du nœud, puis configurez les paramètres de planification selon vos besoins. Pour plus d'informations, consultez la page Présentation des propriétés de planification des tâches.
Configurez l'Rerun attribute et les Parent Nodes du nœud avant de pouvoir le soumettre.
Étape 4 : Tester le code de la tâche
Effectuez les opérations de test suivantes selon vos besoins afin de vérifier que la tâche se comporte comme prévu.
-
(Facultatif) Sélectionnez un groupe de ressources et attribuez des valeurs personnalisées aux paramètres.
Cliquez sur l'icône
dans la barre d'outils. Dans la boîte de dialogue Parameter, sélectionnez le groupe de ressources de planification destiné aux tests.Si le code de votre tâche utilise des variables de paramètres de planification, attribuez-leur ici des valeurs pour les tests. Pour plus d'informations sur la logique d'attribution des paramètres, consultez la page Processus de débogage des tâches.
-
Enregistrez et exécutez le code de la tâche.
Cliquez sur l'icône
dans la barre d'outils pour enregistrer le code de votre tâche. Cliquez ensuite sur l'icône 
pour exécuter la tâche. -
(Facultatif) Effectuez un test de fumée.
Pour réaliser un test de fumée dans l'environnement de développement et vérifier que la tâche planifiée du nœud s'exécute correctement, effectuez ce test pendant ou après la soumission du nœud. Pour plus d'informations, consultez la page Effectuer un test de fumée.
Étape 5 : Soumettre et publier la tâche
Après avoir configuré la tâche du nœud, soumettez-la et publiez-la. Une fois publiée, le nœud s'exécute périodiquement selon sa configuration de planification.
Cliquez sur l'icône
dans la barre d'outils pour enregistrer le nœud.-
Cliquez sur l'icône
dans la barre d'outils pour soumettre la tâche du nœud.Dans la boîte de dialogue Submission, saisissez une Change Description. Vous pouvez également choisir si une revue de code est requise après la soumission.
RemarqueConfigurez l'Rerun attribute et les Parent Nodes du nœud avant de pouvoir le soumettre.
La revue de code permet de garantir la qualité du code et d'éviter les erreurs causées par la publication directe en production de code non revu. Si la revue de code est activée, le code du nœud soumis doit être approuvé par les relecteurs avant sa publication. Pour plus d'informations, consultez la page Revue de code.
Si vous utilisez un espace de travail en mode standard, après avoir soumis la tâche avec succès, cliquez sur Publish dans le coin supérieur droit de la page d'édition du nœud pour déployer la tâche dans l'environnement de production. Pour plus d'informations, consultez la page Publier une tâche.
Étapes suivantes
Opérations sur les tâches : Une fois une tâche soumise et publiée, elle s'exécute périodiquement selon la configuration du nœud. Cliquez sur O&M dans le coin supérieur droit de la page d'édition du nœud pour accéder au Operation Center et consulter l'état de planification et d'exécution de la tâche planifiée. Pour plus d'informations, consultez la page Gestion des tâches planifiées.