Démarrage rapide : Exécuter des requêtes Apache Hive dans Azure HDInsight avec Apache Zeppelin

Dans ce guide de démarrage rapide, vous allez apprendre à utiliser Apache Zeppelin pour exécuter des requêtes Apache Hive dans Azure HDInsight. Les clusters HDInsight Interactive Query incluent des notebooks Apache Zeppelin que vous pouvez utiliser pour exécuter des requêtes Hive interactives.

Si vous n’avez pas d’abonnement Azure, créez un compte gratuit avant de commencer.

Prerequisites

Un cluster HDInsight Interactive Query. Consultez Créer un cluster pour créer un cluster HDInsight. Veillez à choisir le type de cluster Interactive Query .

Créer une note Apache Zeppelin

1. Remplacez CLUSTERNAME par le nom de votre cluster dans l’URL https://CLUSTERNAME.azurehdinsight.net/zeppelinsuivante. Entrez ensuite l’URL dans un navigateur web.

2. Entrez le nom d’utilisateur et le mot de passe de connexion de votre cluster. À partir de la page Zeppelin, vous pouvez créer une note ou ouvrir des notes existantes. HiveSample contient des exemples de requêtes Hive.

   

3. Sélectionnez Créer une note.

4. Dans la boîte de dialogue Créer une note , tapez ou sélectionnez les valeurs suivantes :

   • Nom de la note : entrez un nom pour la note.
   • Interpréteur par défaut : sélectionnez jdbc dans la liste déroulante.

5. Sélectionnez Créer une note.

6. Entrez la requête Hive suivante dans la section code, puis appuyez sur Maj + Entrée :

   %jdbc(hive)
   show tables
   

   

   L’instruction %jdbc(hive) de la première ligne indique au notebook d’utiliser l’interpréteur JDBC Hive.

   La requête retourne une table Hive appelée hivesampletable.

   Voici deux requêtes Hive supplémentaires que vous pouvez exécuter sur hivesampletable :

   %jdbc(hive)
   select * from hivesampletable limit 10
   
   %jdbc(hive)
   select ${group_name}, count(*) as total_count
   from hivesampletable
   group by ${group_name=market,market|deviceplatform|devicemake}
   limit ${total_count=10}
   

   Par rapport au Hive traditionnel, les résultats de la requête reviennent beaucoup plus rapidement.

Autres exemples

1. Créez une table. Exécutez le code dans le bloc-notes Zeppelin :

   %jdbc(hive)
   CREATE EXTERNAL TABLE log4jLogs (
       t1 string,
       t2 string,
       t3 string,
       t4 string,
       t5 string,
       t6 string,
       t7 string)
   ROW FORMAT DELIMITED
   FIELDS TERMINATED BY ' '
   STORED AS TEXTFILE;
   

2. Chargez des données dans la nouvelle table. Exécutez le code dans le bloc-notes Zeppelin :

   %jdbc(hive)
   LOAD DATA
   INPATH 'wasbs:///example/data/sample.log'
   INTO TABLE log4jLogs;
   

3. Insérez un seul enregistrement. Exécutez le code dans le bloc-notes Zeppelin :

   %jdbc(hive)
   INSERT INTO TABLE log4jLogs2
   VALUES ('A', 'B', 'C', 'D', 'E', 'F', 'G');
   

Pour plus de syntaxe, consultez le manuel du langage Hive .

Nettoyer les ressources

Après avoir suivi ce guide de démarrage rapide, vous souhaiterez peut-être supprimer le cluster. Avec HDInsight, vos données sont stockées dans le stockage Azure. Vous pouvez ainsi supprimer un cluster en toute sécurité s’il n’est pas en cours d’utilisation. Vous devez également payer pour un cluster HDInsight, même quand vous ne l’utilisez pas. Étant donné que les frais pour le cluster sont bien plus élevés que les frais de stockage, mieux vaut supprimer les clusters quand ils ne sont pas utilisés.

Pour supprimer un cluster, consultez Supprimer un cluster HDInsight à l’aide de votre navigateur, de PowerShell ou d’Azure CLI.

Étapes suivantes

Dans ce guide de démarrage rapide, vous avez appris à utiliser Apache Zeppelin pour exécuter des requêtes Apache Hive dans Azure HDInsight. Pour en savoir plus sur les requêtes Hive, l’article suivant vous montre comment exécuter des requêtes avec Visual Studio.