Ingestovanie údajov do OneLake a ich analýza pomocou služby Azure Databricks

V tejto príručke:

  • Vytvorte kanál v pracovnom priestore a ingestujte údaje do svojej služby OneLake vo formáte Delta.

  • Prečítajte a upravte tabuľku Delta v službe OneLake pomocou služby Azure Databricks.

Požiadavky

Skôr než začnete, musíte mať:

  • Pracovný priestor s predmetom z jazerného domu.

  • Prémiový pracovný priestor Azure Databricks. Iba prémiové pracovné priestory Azure Databricks podporujú odovzdávanie poverení Microsoft Entra. Pri vytváraní klastra povoľte odovzdávanie poverení pre Azure Data Lake Storage v časti Rozšírené možnosti.

Údaje Ingestu a úprava tabuľky Delta

  1. Prejdite do svojho jazerného domu v službe Power BI, vyberte položku Získať údaje a potom vyberte položku Nový kanál.

    Snímka obrazovky znázorňujúca, ako prejsť na novú možnosť kanála z používateľského rozhrania.

  2. V výzve Nový kanál zadajte názov nového kanála a potom vyberte položku Vytvoriť.

  3. V tomto cvičení vyberte ako zdroj údajov vzorové údaje NYC Taxi – Green .

    Snímka obrazovky zobrazujúca výber sémantického modelu vzorky NYC.

  4. Na obrazovke s ukážkou vyberte položku Ďalej.

  5. Pre cieľové umiestnenie údajov vyberte názov jazera, ktorý chcete použiť na uloženie údajov tabuľky OneLake Delta. Môžete si vybrať existujúci lakehouse alebo vytvoriť nový.

    Snímka obrazovky zobrazujúca spôsob výberu cieľového jazera.

  6. Vyberte miesto, kam chcete uložiť výstup. Ako koreňový priečinok vyberte položku Tabuľky . Ako názov tabuľky zadajte "nycsample" a vyberte položku Ďalej.

  7. Na obrazovke Skontrolovať a uložiť vyberte položku Začať prenos údajov okamžite a potom vyberte položku Uložiť + Spustiť.

    Snímka obrazovky znázorňujúca spôsob zadávania názvu tabuľky.

  8. Keď je práca dokončená, prejdite do svojho jazerného domu a pozrite si tabuľku Delta uvedenú v priečinku /Tables.

  9. Kliknite pravým tlačidlom myši na názov vytvorenej tabuľky, vyberte položku Vlastnosti a skopírujte cestu k systému súborov Azure Blob (ABFS).

  10. Otvorte poznámkový blok Azure Databricks. Prečítajte si tabuľku Delta na OneLake.

    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. Zmenou hodnoty poľa aktualizujte údaje tabuľky Delta.

    %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;

Súvisiaci obsah

  • Last updated on