Del via


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

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.

  1. Gå til en eksisterende notatblokk, eller opprett en ny.

  2. Begynn å skrive kustoi en kodecelle.

    Skjermbilde av å bruke en kusto-kodesnutt til å bruke KQL i en Fabric-notatblokk.

  3. 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()
    
  4. 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.
  5. 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.

  1. Bla til KQL-databasen.

  2. Velg Nytt relatert element>notatblokk.

    Skjermbilde av oppretting av en notatblokk som et relatert element i en KQL-database.

    En notatblokk opprettes med KustoUri- og databasedetaljene forhåndsutfyllet.

  3. Skriv inn KQL-spørringen som skal evalueres i kustoQuery-feltet.

    Skjermbilde av notatblokken som er opprettet fra en KQL-database.

  4. Kjør kodecellen.