Les nœuds PolarDB for MySQL dans DataWorks vous permettent de développer, planifier et intégrer des tâches PolarDB for MySQL. Cette rubrique décrit comment développer des tâches à l'aide d'un nœud PolarDB for MySQL.
Informations générales
PolarDB for MySQL est une base de données cloud-native de nouvelle génération développée par Alibaba Cloud. Elle repose sur une architecture qui découple le calcul du stockage et tire parti de l'intégration logiciel-matériel. Cette conception offre un service de base de données hautement élastique, performant, sécurisé et fiable, avec une capacité de stockage massive. PolarDB for MySQL est entièrement compatible avec les écosystèmes MySQL et PostgreSQL, et hautement compatible avec la syntaxe Oracle. Pour plus d'informations, consultez la rubrique Qu'est-ce que PolarDB for MySQL ?.
Prérequis
-
Vous avez créé un flux de travail métier.
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 rubrique Créer un flux métier.
-
Vous avez ajouté une source de données PolarDB for MySQL.
Ajoutez votre base de données PolarDB for MySQL en tant que source de données dans DataWorks afin d'accéder à ses données. Pour créer une source de données, consultez la rubrique Ajouter et gérer des sources de données. Pour plus d'informations sur l'utilisation d'une source de données PolarDB for MySQL dans DataWorks, consultez la rubrique Source de données PolarDB.
RemarqueLes nœuds PolarDB for MySQL prennent uniquement en charge les sources de données PolarDB for MySQL créées avec 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 rubrique Établir une connexion réseau entre un groupe de ressources et une source de données.
(Facultatif ; requis pour les utilisateurs RAM) Vous avez ajouté l'utilisateur RAM utilisé pour le développement des tâches à l'espace de travail cible et lui avez attribué le rôle Development ou Workspace Administrator (ce dernier accorde des autorisations étendues ; attribuez-le avec prudence). Pour plus d'informations sur l'ajout de membres et l'attribution d'autorisations, consultez la rubrique Ajouter des membres à un espace de travail.
Limites
Régions prises en charge : 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 PolarDB for MySQL
-
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.
Cliquez avec le bouton droit sur le flux de travail cible et choisissez .
Dans la boîte de dialogue Create Node, saisissez un Name pour le nœud et cliquez sur OK. Une fois le nœud créé, utilisez-le pour développer et configurer votre tâche.
Étape 2 : Développer la tâche PolarDB for MySQL
(Facultatif) Sélectionner une source de données PolarDB for MySQL
Si plusieurs sources de données PolarDB for MySQL existent dans votre espace de travail, sélectionnez celle à utiliser sur la page de configuration du nœud. Si vous ne disposez que d'une seule source de données PolarDB for MySQL, elle est utilisée par défaut.
Les nœuds PolarDB for MySQL prennent uniquement en charge les sources de données PolarDB for MySQL créées avec une chaîne de connexion JDBC (Java Database Connectivity).
Développer le code SQL : Exemple simple
Dans l'éditeur de code du nœud PolarDB for MySQL, écrivez le code SQL à exécuter. Voici un exemple :
SELECT * FROM usertablename;
Développer le code SQL : Utiliser des paramètres de planification
DataWorks fournit des Scheduling Parameter, qui sont des variables dynamiques pour le code de vos tâches planifiées. Définissez des variables dans le code de votre tâche en utilisant le format ${nom_variable}. Ensuite, dans l'onglet Schedule du volet de droite, attribuez des valeurs à ces variables dans la section Scheduling Parameter. Pour plus d'informations sur les formats pris en charge et la configuration, consultez les rubriques Formats pris en charge des paramètres de planification et Configurer et utiliser les paramètres de planification.
Voici un exemple :
SELECT '${var}';
Étape 3 : Configurer la planification des tâches
Pour exécuter périodiquement la tâche du nœud, cliquez sur Scheduling à droite de la page d'édition du nœud et configurez les paramètres de planification selon vos besoins. Pour plus d'informations, consultez la rubrique Vue d'ensemble 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 pour vérifier que la tâche se comporte comme prévu.
-
(Facultatif) Sélectionnez un groupe de ressources et attribuez des valeurs de paramètre personnalisées.
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 pour les tests.Si le code de votre tâche utilise des variables de paramètres de planification, attribuez-leur des valeurs ici pour les tests. Pour plus d'informations sur la logique d'attribution des paramètres, consultez la rubrique 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 des tests de fumée.
Pour effectuer des tests de fumée dans l'environnement de développement et vérifier que la tâche planifiée du nœud s'exécute comme prévu, réalisez des tests de fumée pendant ou après la soumission du nœud. Pour plus d'informations, consultez la rubrique Effectuer des tests 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 en fonction de 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 de code non revu en production. 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 rubrique 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 rubrique Publier une tâche.
Étapes suivantes
Opérations sur les tâches : Une fois qu'une tâche est soumise et publiée, elle s'exécute périodiquement en fonction de 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 afficher l'état de planification et d'exécution de la tâche planifiée. Pour plus d'informations, consultez la rubrique Gestion des tâches planifiées.