Använda Fabric-notebook-filer med data från en KQL-databas
Notebook-filer är både läsbara dokument som innehåller beskrivningar av dataanalys och resultat och körbara dokument som kan köras för att utföra dataanalys. I den här artikeln lär du dig hur du använder en Fabric-notebook-fil för att ansluta till data i en KQL Database och köra frågor med hjälp av interna KQL (Kusto Query Language). För mer information om anteckningsböcker, se Hur man använder Microsoft Fabric-anteckningsböcker.
Det finns två sätt att använda Fabric Notebooks med data från din KQL-databas:
Förutsättningar
- En arbetsyta med en Microsoft Fabric-aktiverad kapacitet
- En KQL-databas med minst visningsbehörighet
Använd Kusto-kodfragment i en notebook
Fabric-anteckningsböcker tillhandahåller kodexempel som hjälper dig att enkelt skriva vanliga kodmönster. Du kan använda kodfragment för att skriva eller läsa data i en KQL-databas med hjälp av KQL.
Navigera till en befintlig anteckningsbok eller skapa en ny.
I en kodcell börjar du skriva kusto.
Välj det kodfragment som motsvarar den åtgärd som du vill utföra: Skriva data till en KQL-databas eller Läsa data från en KQL-databas.
Följande kodfragment visar exempelåtgärden för dataläsning:
# 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öljande kodfragment visar exemplet för skrivdataoperation:
# 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()
Ange nödvändig information inom citattecknen för varje fält i datacellen:
Fält Beskrivning Relaterade länkar kustoQuery KQL-frågan som ska utvärderas. KQL-översikt KustoUri Fråge-URI:n för din KQL-databas. Kopiera en KQL-databas-URI databas Namnet på din KQL-databas. Komma åt en befintlig KQL-databas data De data som ska skrivas till tabellen. Kör kodcellen.
Skapa en anteckningsbok från en KQL-databas
När du skapar en notebook-fil som ett relaterat objekt i en KQL-databas får notebook-filen samma namn som KQL-databasen och fylls i med anslutningsinformation.
Bläddra till din KQL-databas.
Välj Nytt relaterat objekt>Anteckningsbok.
En anteckningsbok skapas med KustoUri och databasinformation förifyllda.
Ange den KQL-fråga som ska utvärderas i fältet kustoQuery.
Kör kodcellen.