Aracılığıyla paylaş

Azure HDInsight'ta Apache HBase üzerinden Apache Phoenix sorguları çalıştırmak için Apache Zeppelin kullanma

Apache Phoenix, HBase üzerinde oluşturulmuş açık kaynak, yüksek düzeyde paralel bir ilişkisel veritabanı katmanıdır. Phoenix, HBase üzerinden sorgular gibi SQL kullanmanıza olanak tanır. Phoenix, SQL tablolarını, dizinlerini, görünümlerini ve dizilerini oluşturmanızı, silmenizi, değiştirmenizi sağlamak için altında JDBC sürücülerini kullanır. Phoenix'i kullanarak satırları tek tek ve toplu olarak güncelleştirebilirsiniz. Phoenix, sorguları derlemek için MapReduce kullanmak yerine NOSQL yerel derlemesi kullanarak HBase üzerinde düşük gecikmeli uygulamalar oluşturulmasını sağlar.

Apache Zeppelin, etkileşimli veri analizi ve SQL ve Scala gibi dilleri kullanarak veri odaklı, işbirliğine dayalı belgeler oluşturmanıza olanak tanıyan açık kaynak web tabanlı bir not defteridir. Veri geliştiricilerinin ve veri bilimcilerinin veri işleme için kod geliştirmelerine, düzenlemelerine, yürütmelerine ve paylaşmalarına yardımcı olur. Komut satırına başvurmadan veya küme ayrıntılarına gerek duymadan sonuçları görselleştirmenize olanak tanır.

HDInsight kullanıcıları Phoenix tablolarını sorgulamak için Apache Zeppelin kullanabilir. Apache Zeppelin, HDInsight kümesiyle tümleşiktir ve bunu kullanmak için ek bir adım yoktur. JDBC yorumlayıcısı ile bir Zeppelin Not Defteri oluşturun ve Phoenix SQL sorgularınızı yazmaya başlayın

Önkoşullar

HDInsight üzerinde apache HBase kümesi. Bkz. Apache HBase'i kullanmaya başlama.

Bir Apache Zeppelin Notu oluşturma

  1. Aşağıdaki URL'deki CLUSTERNAME değerini kümelerinizin adıyla değiştirin https://CLUSTERNAME.azurehdinsight.net/zeppelin. Ardından URL'yi bir web tarayıcısına girin. Küme oturum açma kullanıcı adınızı ve parolanızı girin.

  2. Zeppelin sayfasında Yeni not oluştur'u seçin.

    HDInsight Etkileşimli Sorgu Zeppelin.

  3. Yeni not oluştur iletişim kutusunda aşağıdaki değerleri yazın veya seçin:

    • Not Adı: Not için bir ad girin.
    • Varsayılan yorumlayıcı: Açılan listeden jdbc'yi seçin.

    Ardından Not Oluştur'u seçin.

  4. Not defteri başlığının bağlı olduğunu gösterdiğinden emin olun. Sağ üst köşedeki yeşil noktayla gösterilir.

    Zeppelin defter durumu.

  5. Bir HBase tablosu oluşturun. Aşağıdaki komutu girin ve Shift + Enter tuşlarına basın:

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

    Başlangıçtaki %jdbc(phoenix) ifadesi, not defterine Phoenix JDBC yorumlayıcısını kullanmasını söyler.

  6. Oluşturulan tabloları görüntüleyin.

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

  7. Tabloya değer ekleyin.

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

  8. Tabloyu sorgula.

    %jdbc(phoenix)
SELECT * FROM Company;

  9. Kaydı silme.

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

  10. Tabloyu kaldırın.

    %jdbc(phoenix)
DROP TABLE Company;

Sonraki adımlar