Udostępnij za pośrednictwem

Uruchamianie zapytań apache Phoenix za pośrednictwem bazy danych Apache HBase w usłudze Azure HDInsight przy użyciu rozwiązania Apache Zeppelin

  • Artykuł

Apache Phoenix to warstwa relacyjnej relacyjnej bazy danych typu open source oparta na bazie HBase. Rozwiązanie Phoenix umożliwia korzystanie z bazy danych SQL, takich jak zapytania w bazie HBase. Firma Phoenix używa sterowników JDBC poniżej, aby umożliwić tworzenie, usuwanie, zmienianie tabel SQL, indeksów, widoków i sekwencji. Za pomocą rozwiązania Phoenix można również aktualizować wiersze pojedynczo i zbiorczo. Firma Phoenix używa natywnej kompilacji NOSQL zamiast kompilowania zapytań przy użyciu usługi MapReduce, umożliwiając tworzenie aplikacji o małych opóźnieniach na bazie HBase.

Apache Zeppelin to internetowy notes typu open source, który umożliwia tworzenie dokumentów opartych na danych, współpracy przy użyciu interaktywnej analizy danych i języków, takich jak SQL i Scala. Pomaga to deweloperom danych i analitykom danych opracowywać, organizować, wykonywać i udostępniać kod na potrzeby manipulowania danymi. Umożliwia ona wizualizowanie wyników bez odwoływania się do wiersza polecenia lub potrzeby szczegółów klastra.

Użytkownicy usługi HDInsight mogą używać platformy Apache Zeppelin do wykonywania zapytań względem tabel Phoenix. Platforma Apache Zeppelin jest zintegrowana z klastrem usługi HDInsight i nie ma dodatkowych kroków do użycia. Tworzenie notesu Zeppelin z interpreterem JDBC i rozpoczynanie pisania zapytań Phoenix SQL

Wymagania wstępne

Klaster Apache HBase w usłudze HDInsight. Zobacz Rozpoczynanie pracy z bazą danych Apache HBase.

Tworzenie notatki platformy Apache Zeppelin

  1. Zastąp CLUSTERNAME ciąg nazwą klastra w następującym adresie URL https://CLUSTERNAME.azurehdinsight.net/zeppelin. Następnie wprowadź adres URL w przeglądarce internetowej. Wprowadź nazwę użytkownika i hasło logowania klastra.

  2. Na stronie Zeppelin wybierz pozycję Utwórz nową notatkę.

    HDInsight Interactive Query zeppelin.

  3. W oknie dialogowym Tworzenie nowej notatki wpisz lub wybierz następujące wartości:

    • Nazwa notatki: wprowadź nazwę notatki.
    • Interpreter domyślny: wybierz pozycję jdbc z listy rozwijanej.

    Następnie wybierz pozycję Utwórz notatkę.

  4. Upewnij się, że nagłówek notesu zawiera stan połączenia. Oznacza to zieloną kropkę w prawym górnym rogu.

    Zeppelin notebook status.

  5. Utwórz tabelę HBase. Wprowadź następujące polecenie, a następnie naciśnij klawisze Shift + Enter:

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

    Instrukcja %jdbc(phoenix) w linii frontu informuje notes o użyciu interpretera JDBC Phoenix.

  6. Wyświetl utworzone tabele.

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

  7. Wstaw wartości w tabeli.

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

  8. Wykonaj zapytanie względem tabeli.

    %jdbc(phoenix)
SELECT * FROM Company;

  9. Usuwanie rekordu.

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

  10. Upuść tabelę.

    %jdbc(phoenix)
DROP TABLE Company;

Następne kroki