AnalyticDB:Planification du SQL XIHE avec DataWorks

Objectif

La définition des dépendances entre les tâches constitue une fonctionnalité clé de la planification. Ce tutoriel vous explique comment créer deux tâches AnalyticDB for MySQL dépendantes dans DataWorks. Le schéma ci-dessous illustre la relation entre les tables et les tâches.

• Task 1

  Nettoyez la table orders en filtrant les commandes terminées, où o_orderstatus = 'F', et écrivez les résultats dans la table finished_orders.

• Task 2

  Interrogez la table finished_orders pour identifier les commandes dont le prix total est supérieur à 10 000, où o_totalprice > 10000, et écrivez les résultats dans la table high_value_finished_orders.

Prérequis

1. Effectuez la configuration initiale, notamment la création d'un cluster et la configuration d'une liste d'autorisation, en suivant les instructions fournies dans Démarrage rapide pour l'édition Data Warehouse.

   Remarque

   Assurez-vous que votre cluster AnalyticDB for MySQL et votre espace de travail DataWorks se trouvent dans la même région.

   • Si vous vous connectez à AnalyticDB for MySQL depuis DataWorks via un endpoint public d'AnalyticDB for MySQL, vous devez d'abord demander un endpoint public, puis ajouter la liste d'autorisation DataWorks à la liste d'autorisation AnalyticDB for MySQL.

   • Si vous vous connectez à AnalyticDB for MySQL depuis DataWorks en utilisant une adresse VPC pour accéder à AnalyticDB for MySQL, vous devez d'abord ajouter un mode de groupe de ressources exclusif dans DataWorks. Le VPC du groupe de ressources exclusif doit être identique à celui d'AnalyticDB for MySQL.

   • Ce tutoriel utilise la table orders issue du . Une fois connecté à votre base de données AnalyticDB for MySQL, exécutez les instructions SQL suivantes pour créer les tables requises.

     CREATE TABLE orders(
           o_orderkey bigint NOT NULL COMMENT'',
           o_custkey int NOT NULL COMMENT'',
           o_orderstatus varchar NOT NULL COMMENT'',
           o_totalprice decimal(15,2) NOT NULL COMMENT'',
           o_orderdate date NOT NULL COMMENT'',
           o_orderpriority varchar NOT NULL COMMENT'',
           o_clerkvar char NOT NULL COMMENT'',
           o_shippriority int NOT NULL COMMENT'',
           o_comment varchar NOT NULL COMMENT'',
           dummy varchar
       )DISTRIBUTED BY HASH(o_orderkey);
     CREATE TABLE finished_orders (
            o_orderkey bigint NOT NULL,
            o_totalprice decimal(15,2) NOT NULL,
            primary key (o_orderkey)
        )DISTRIBUTED BY HASH(o_orderkey);
     
     CREATE TABLE high_value_finished_orders (
           o_orderkey bigint NOT NULL,
           o_totalprice decimal(15,2) NOT NULL,
           PRIMARY KEY (`o_orderkey`)
       )
       DISTRIBUTED BY HASH(o_orderkey);

2. Créez un espace de travail dans DataWorks.

   Remarque

   Sélectionnez le mode standard pour l'espace de travail.

Étape 1 : Ajoutez une source de données AnalyticDB for MySQL dans DataWorks

Pour obtenir des instructions détaillées, consultez la rubrique Source de données AnalyticDB for MySQL 3.0.

Pour des raisons de sécurité, DataWorks contrôle les services autorisés à établir des connexions. Vous devez ajouter l'endpoint et le port de votre base de données AnalyticDB for MySQL à une liste d'autorisation.

Sur la page Security Settings, dans la section Sandbox Whitelist, cliquez sur Add Sandbox Whitelist pour ajouter l'endpoint de connexion et le port (par exemple 3306) d'AnalyticDB for MySQL à la liste d'autorisation.

Étape 2 : Créez un nœud AnalyticDB for MySQL

Pour obtenir des instructions détaillées, consultez la rubrique AnalyticDB for MySQL.

Étape 3 : Configurez les dépendances entre les tâches

DataWorks déclenche les tâches en fonction des propriétés temporelles ou d'une dépendance de planification au sein du même cycle, ce qui vous permet d'exécuter plusieurs tâches à un moment précis et dans un ordre défini.

Par exemple, vous pouvez planifier l'exécution quotidienne de la tâche finished_orders à 2 h 00. Vous pouvez ensuite configurer la tâche high_value_finished_orders pour qu'elle s'exécute uniquement après la réussite de la tâche finished_orders.

Étape 4 : Déployez les nœuds

Une fois les tâches et leurs dépendances configurées, déployez-les. Pour plus de détails, consultez la rubrique Déployer un nœud.

Après avoir soumis les nœuds pour déploiement, vous pouvez consulter leur statut.

Lorsque le déploiement est réussi, accédez à la page d'O&M des tâches pour surveiller et gérer vos tâches.