Bruke Fabric-notatblokker med data fra en KQL-database
Notatblokker er både lesbare dokumenter som inneholder beskrivelser av dataanalyse og resultater og kjørbare dokumenter som kan kjøres for å utføre dataanalyse. I denne artikkelen lærer du hvordan du bruker en Fabric-notatblokk til å koble til data i en KQL-database og kjøre spørringer ved hjelp av opprinnelige KQL (Kusto Query Language). Hvis du vil ha mer informasjon om notatblokker, kan du se Slik bruker du Microsoft Fabric-notatblokker.
Det finnes to måter å bruke Fabric-notatblokker på med data fra KQL-databasen:
Forutsetninger
- Et arbeidsområde med en Microsoft Fabric-aktivert kapasitet
- En KQL-database med minst visningstillatelser
Bruke Kusto-snutter i en notatblokk
Stoffnotatblokker gir kodesnutter som gjør det enkelt å skrive vanlige kodemønstre. Du kan bruke snutter til å skrive eller lese data i en KQL-database ved hjelp av KQL.
Gå til en eksisterende notatblokk, eller opprett en ny.
Begynn å skrive kustoi en kodecelle.
Velg snutten som tilsvarer operasjonen du vil utføre: Skriv data til en KQL-database eller Lese data fra en KQL-database.
Følgende kodesnutt viser eksempeldatalesingsoperasjonen:
# Example of query for reading data from Kusto. Replace T with your <tablename>. kustoQuery = "['T'] | take 10" # The query URI for reading the data e.g. https://<>.kusto.data.microsoft.com. kustoUri = "https://<yourKQLdatabaseURI>.z0.kusto.data.microsoft.com" # The database with data to be read. database = "DocsDatabase" # The access credentials. accessToken = mssparkutils.credentials.getToken('kusto') kustoDf = spark.read\ .format("com.microsoft.kusto.spark.synapse.datasource")\ .option("accessToken", accessToken)\ .option("kustoCluster", kustoUri)\ .option("kustoDatabase", database)\ .option("kustoQuery", kustoQuery).load() # Example that uses the result data frame. kustoDf.show()
Følgende kodesnutt viser eksempelet på skrivedataoperasjon:
# The Kusto cluster uri to write the data. The query Uri is of the form https://<>.kusto.data.microsoft.com kustoUri = "" # The database to write the data database = "" # The table to write the data table = "" # The access credentials for the write accessToken = mssparkutils.credentials.getToken('kusto') # Generate a range of 5 rows with Id's 5 to 9 data = spark.range(5,10) # Write data to a Kusto table data.write.\ format("com.microsoft.kusto.spark.synapse.datasource").\ option("kustoCluster",kustoUri).\ option("kustoDatabase",database).\ option("kustoTable", table).\ option("accessToken", accessToken ).\ option("tableCreateOptions", "CreateIfNotExist").mode("Append").save()
Skriv inn den nødvendige informasjonen i anførselstegnene for hvert felt i datacellen:
Felt Beskrivelse Relaterte koblinger kustoQuery KQL-spørringen som skal evalueres. KQL-oversikt KustoUri Spørrings-URI-en for KQL-databasen. Kopiere en URI- for KQL-database database Navnet på KQL-databasen. Få tilgang til en eksisterende KQL-database data Dataene som skal skrives til tabellen. Kjør kodecellen.
Opprette en notatblokk fra en KQL-database
Når du oppretter en notatblokk som et relatert element i en KQL-database, får notatblokken samme navn som KQL-databasen og er forhåndsutfyllet med tilkoblingsinformasjon.
Bla til KQL-databasen.
Velg Nytt relatert element>notatblokk.
En notatblokk opprettes med KustoUri- og databasedetaljene forhåndsutfyllet.
Skriv inn KQL-spørringen som skal evalueres i kustoQuery-feltet.
Kjør kodecellen.