Dans DataWorks, utilisez un nœud CDH Presto pour l'analyse de données en temps réel. Ce nœud fournit un moteur de requêtes SQL distribué qui renforce les capacités d'analyse de votre environnement CDH. Cette rubrique explique comment configurer et utiliser un nœud CDH Presto.
Prérequis
-
Vous avez créé un cluster Alibaba Cloud CDH et l'avez associé à un espace de travail DataWorks. Pour plus d'informations, consultez la rubrique Associer un moteur de calcul CDH.
ImportantAssurez-vous que le composant Presto est installé sur votre cluster CDH et configurez les informations associées lors de la liaison du cluster.
-
(Facultatif, pour les utilisateurs RAM) L'utilisateur RAM chargé du développement des tâches a été ajouté à l'espace de travail correspondant et s'est vu attribuer le rôle Development ou Workspace Administrator. Le rôle Workspace Administrator dispose d'autorisations étendues ; attribuez-le avec prudence. Pour plus d'informations sur l'ajout de membres, consultez la rubrique Ajouter des membres à un espace de travail.
RemarqueSi vous utilisez un compte Alibaba Cloud, ignorez cette étape.
Vous avez configuré une source de données Hive dans DataWorks et vérifié qu'elle a réussi le test de connectivité. Pour plus d'informations, consultez la rubrique Gérer les sources de données.
Créer un nœud
Pour obtenir des instructions, consultez la rubrique Créer un nœud.
Développement du nœud
Développez le code de la tâche dans l'éditeur SQL. Définissez des variables dans le code au format ${nom_variable}. Attribuez ensuite une valeur à la variable dans la section Scheduling Parameters du volet Scheduling Settings situé à droite de la page d'édition du nœud. Cela permet de transmettre dynamiquement des paramètres au code lors de l'exécution planifiée du nœud. Pour plus d'informations sur les paramètres de planification, consultez la rubrique Sources et expressions des paramètres de planification. L'exemple de code suivant illustre cette procédure.
SHOW TABLES;
SELECT * FROM userinfo ;
-- You can use this with scheduling parameters.
SELECT '${var}';
Débogage du nœud
-
Dans l'onglet Run Configuration, configurez les champs Compute Resource et Resource Group de la section Compute Resource.
Pour Compute resource, sélectionnez le nom du cluster CDH que vous avez enregistré sur DataWorks.
Sélectionnez un groupe de ressources de planification qui a réussi le test de connectivité avec la source de données. Pour plus d'informations, consultez la rubrique Solutions de connectivité réseau.
Dans la barre d'outils en haut de la page d'édition du nœud, cliquez sur Run.
Étapes suivantes
Configurer la planification des nœuds : Pour exécuter un nœud périodiquement, configurez sa Scheduling Policy dans le volet Scheduling Settings à droite.
Publier un nœud : Pour exécuter une tâche dans l'environnement de production, cliquez sur l'icône
afin de publier le nœud. Un nœud ne s'exécute selon la planification qu'après sa publication dans l'environnement de production.O&M des tâches : Une fois la tâche publiée, surveillez ses exécutions périodiques dans le Operation Center. Pour plus d'informations, consultez la rubrique Prise en main du Operation Center.