Del via

Inntak av data i OneLake og analyser med Azure Databricks

I denne veiledningen gjør du følgende:

  • Opprett et datasamlebånd i et arbeidsområde og inntak av data i OneLake i Delta-format.

  • Les og endre en Delta-tabell i OneLake med Azure Databricks.

Forutsetning

Før du begynner, må du ha:

  • Et arbeidsområde med et Lakehouse-element.

  • Et premium Azure Databricks-arbeidsområde. Bare premium Azure Databricks-arbeidsområder støtter videresending av Microsoft Entra-legitimasjon. Når du oppretter klyngen, kan du aktivere legitimasjonsoversigelse for Azure Data Lake Storage i avanserte alternativer.

  • Et eksempeldatasett.

Innta data og endre Delta-tabellen

  1. Gå til innsjøen i Power BI-tjenesten, og velg Hent data , og velg deretter Ny datasamlebånd.

    Skjermbilde som viser hvordan du navigerer til nytt pipeline-alternativ fra brukergrensesnittet.

  2. Skriv inn et navn på det nye datasamlebåndet i ledeteksten Nytt datasamlebånd , og velg deretter Opprett.

  3. I denne øvelsen velger du eksempeldataene NYC Taxi – Grønn som datakilde.

    Skjermbilde som viser hvordan du velger NYC eksempel semantisk modell.

  4. Velg Neste på forhåndsvisningsskjermbildet.

  5. For datamål velger du navnet på lakehouse du vil bruke til å lagre onelake delta-tabelldataene. Du kan velge et eksisterende lakehouse eller opprette et nytt.

    Skjermbilde som viser hvordan du velger destination lakehouse.

  6. Velg hvor du vil lagre utdataene. Velg Tabeller som rotmappe. Skriv inn "nycsample" som tabellnavn og velg Neste.

  7. Velg Start dataoverføring umiddelbart på skjermbildet Se gjennom + Lagre, og velg deretter Lagre + Kjør.

    Skjermbilde som viser hvordan du skriver inn tabellnavn.

  8. Når jobben er fullført, går du til lakehouse og viser deltatabellen oppført under /Tables-mappen.

  9. Høyreklikk på navnet på den opprettede tabellen, velg Egenskaper, og kopier Azure Blob Filesystem (ABFS)-banen.

  10. Åpne Azure Databricks-notatblokken. Les Delta-tabellen på 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. Oppdater tabelldataene for Delta ved å endre en feltverdi.

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

Relatert innhold

  • Last updated on