Partager via

Utiliser Apache Zeppelin pour exécuter des requêtes Apache Phoenix sur Apache HBase dans Azure HDInsight

  • Article

Apache Phoenix est une couche de base de données relationnelle massivement parallèle open source créée sur HBase. Phoenix vous donne les moyens d’utiliser des requêtes de type SQL sur HBase. Phoenix utilise en dessous des pilotes JDBC pour vous permettre de créer, supprimer et modifier des tables SQL, des index, des vues et des séquences. Vous pouvez également utiliser Phoenix pour mettre à jour des lignes individuellement et en bloc. Phoenix utilise une compilation native NOSQL au lieu de MapReduce pour compiler les requêtes, ce qui permet de créer des applications à faible latence sur HBase.

Apache Zeppelin est un notebook Web open source qui vous permet de créer des documents basés sur des données et collaboratifs à l’aide d’analyses de données interactives et de langages tels que SQL et Scala. Il permet aux développeurs de données et aux scientifiques des données de développer, d’organiser, d’exécuter et de partager du code pour la manipulation des données. Il vous permet de visualiser les résultats sans faire référence à la ligne de commande ou nécessiter les détails de cluster.

Les utilisateurs de HDInsight peuvent utiliser Apache Zeppelin pour interroger des tables Phoenix. Apache Zeppelin est intégré au cluster HDInsight et aucune étape supplémentaire n’est nécessaire pour l’utiliser. Créez un Notebook Zeppelin avec un interpréteur JDBC et commencez à écrire vos requêtes SQL Phoenix

Prérequis

Un cluster Apache HBase sur HDInsight. Consultez Bien démarrer avec Apache HBase.

Créer une note Apache Zeppelin

  1. Remplacez CLUSTERNAME par le nom de votre cluster dans l’URL suivante https://CLUSTERNAME.azurehdinsight.net/zeppelin. Entrez ensuite l’URL dans un navigateur web. Entrez le nom d’utilisateur et le mot de passe de connexion pour votre cluster.

  2. Dans la page Zeppelin, sélectionnez Créer une note.

    HDInsight Interactive Query zeppelin.

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

    • Note Name : entrez un nom pour la note.
    • Default interpreter : sélectionnez jdbc dans la liste déroulante.

    Sélectionnez ensuite Créer une note.

  4. Vérifiez que l'en-tête du bloc-notes indique un état connecté. Il est indiqué par un point vert dans le coin supérieur droit.

    Zeppelin notebook status.

  5. Créez une table HBase. Entrez la commande suivante, puis appuyez sur Maj + Entrée :

    %jdbc(phoenix)
CREATE TABLE Company (
    company_id INTEGER PRIMARY KEY,
    name VARCHAR(225)
);

    L’instruction %jdbc(phoenix) en première ligne instruit le notebook d’utiliser l’interpréteur Phoenix JDBC.

  6. Affichez les tables créées.

    %jdbc(phoenix)
SELECT DISTINCT table_name
FROM SYSTEM.CATALOG
WHERE table_schem is null or table_schem <> 'SYSTEM';

  7. Insérer les valeurs dans le tableau.

    %jdbc(phoenix)
UPSERT INTO Company VALUES(1, 'Microsoft');
UPSERT INTO Company (name, company_id) VALUES('Apache', 2);

  8. Interroger la table.

    %jdbc(phoenix)
SELECT * FROM Company;

  9. Supprimer un enregistrement.

    %jdbc(phoenix)
DELETE FROM Company WHERE COMPANY_ID=1;

  10. Déposer la table.

    %jdbc(phoenix)
DROP TABLE Company;

Étapes suivantes