Delen via

Fabric-notebooks gebruiken met gegevens uit een KQL-database

  • Artikel

Notebooks zijn zowel leesbare documenten met beschrijvingen van gegevensanalyses en resultaten als uitvoerbare documenten die kunnen worden uitgevoerd om gegevensanalyse uit te voeren. In dit artikel leert u hoe u een Fabric-notebook gebruikt om verbinding te maken met gegevens in een KQL-database en query's uit te voeren met behulp van systeemeigen KQL (Kusto-querytaal). Zie Microsoft Fabric-notebooks gebruiken voor meer informatie over notebooks.

Er zijn twee manieren om Fabric-notebooks te gebruiken met gegevens uit uw KQL-database:

Vereisten

Kusto-fragmenten gebruiken in een notebook

Fabric-notebooks bieden codefragmenten waarmee u eenvoudig veelgebruikte codepatronen kunt schrijven. U kunt codefragmenten gebruiken om gegevens in een KQL-database te schrijven of te lezen met behulp van KQL.

  1. Navigeer naar een bestaand notitieblok of maak een nieuw notitieblok.

  2. Begin in een codecel kusto te typen.

    Schermopname van het gebruik van een kusto-fragment voor het gebruik van KQL in een Fabric-notebook.

  3. Selecteer het fragment dat overeenkomt met de bewerking die u wilt uitvoeren: gegevens schrijven naar een KQL-database of gegevens lezen uit een KQL-database.

    In het volgende codefragment ziet u de voorbeeldbewerking voor het lezen van gegevens:

    # 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(kustoUri)
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()

    In het volgende codefragment ziet u de voorbeeldbewerking voor het schrijven van gegevens:

    # 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(kustoUri)

# 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. Voer de vereiste gegevens in tussen de aanhalingstekens van elk veld in de gegevenscel:

    Veld Beschrijving Verwante koppelingen
    kustoQuery De KQL-query die moet worden geëvalueerd. KQL-overzicht
    KustoUri De query-URI van uw KQL-database. Een KQL-database-URI kopiëren
    database De naam van uw KQL-database. Toegang tot een bestaande KQL-database
    gegevens De gegevens die naar de tabel moeten worden geschreven.

  5. Voer de codecel uit.

Een notebook maken op basis van een KQL-database

Wanneer u een notebook maakt als een gerelateerd item in een KQL-database, krijgt het notebook dezelfde naam als de KQL-database en wordt het vooraf ingevuld met verbindingsgegevens.

  1. Blader naar uw KQL-database.

  2. Selecteer Nieuw gerelateerd itemNotitieblok>.

    Schermopname van het maken van een notebook als een gerelateerd item in een KQL-database.

    Er wordt een notebook gemaakt met de KustoUri- en databasegegevens vooraf ingevuld.

  3. Voer de KQL-query in die moet worden geëvalueerd in het kustoQuery-veld .

    Schermopname van notebook die is gemaakt op basis van een KQL-database.

  4. Voer de codecel uit.

Gerelateerde inhoud