Verileri OneLake'e alma ve Azure Databricks ile analiz etme

Bu kılavuzda şunları yapacaksınız:

  • Bir çalışma alanında işlem hattı oluşturun ve Verileri Delta biçiminde OneLake'inize alın.

  • Azure Databricks ile OneLake'te Delta tablosunu okuyun ve değiştirin.

Önkoşullar

Başlamadan önce şunları yapmış olmanız gerekir:

  • Göl evi öğesi içeren bir çalışma alanı.

  • Premium bir Azure Databricks çalışma alanı. Yalnızca premium Azure Databricks çalışma alanları Microsoft Entra kimlik bilgisi geçişlerini destekler. Kümenizi oluştururken Gelişmiş Seçenekler'de Azure Data Lake Storage kimlik bilgisi geçişini etkinleştirin.

Verileri alma ve Delta tablosunu değiştirme

  1. Power BI hizmetinde lakehouse'unuza gidin, Veri al'ı seçin ve ardından Yeni işlem hattı'nı seçin.

    Kullanıcı arabiriminin içinden yeni işlem hattı seçeneğine nasıl gidilir gösteren ekran görüntüsü.

  2. Yeni İşlem Hattı isteminde yeni işlem hattı için bir ad girin ve Oluştur'u seçin.

  3. Bu alıştırmada, veri kaynağı olarak NYC Taxi - Yeşil örnek verilerini seçin.

    NYC örnek anlam modelini seçme işlemini gösteren ekran görüntüsü.

  4. Önizleme ekranında İleri'yi seçin.

  5. Veri hedefi olarak, OneLake Delta tablo verilerini depolamak için kullanmak istediğiniz göl evi adını seçin. Mevcut bir göl evi seçebilir veya yeni bir tane oluşturabilirsiniz.

    Hedef lakehouse'un nasıl seçileceklerini gösteren ekran görüntüsü.

  6. Çıkışı depolamak istediğiniz yeri seçin. Kök klasör olarak Tablolar'ı seçin. Tablo adı olarak "nycsample" yazın ve İleri'yi seçin.

  7. Gözden Geçir + Kaydet ekranında Veri aktarımını hemen başlat'ı ve ardından Kaydet + Çalıştır'ı seçin.

    Tablo adını girme adımlarını gösteren ekran görüntüsü.

  8. İş tamamlandığında lakehouse'unuza gidin ve /Tables klasörü altında listelenen Delta tablosunu görüntüleyin.

  9. Oluşturulan tablo adına sağ tıklayın, Özellikler'i seçin ve Azure Blob Dosya Sistemi (ABFS) yolunu kopyalayın.

  10. Azure Databricks not defterinizi açın. OneLake'de Delta tablosunu okuyun.

    olsPath = "abfss://<replace with workspace name>@onelake.dfs.fabric.microsoft.com/<replace with item name>.Lakehouse/Tables/nycsample" 
df=spark.read.format('delta').option("inferSchema","true").load(olsPath)
df.show(5)

  11. Alan değerini değiştirerek Delta tablosu verilerini güncelleştirin.

    %sql
update delta.`abfss://<replace with workspace name>@onelake.dfs.fabric.microsoft.com/<replace with item name>.Lakehouse/Tables/nycsample` set vendorID = 99999 where vendorID = 1;

İlgili içerik

  • Last updated on