Zdieľať cez


Používanie poznámkových blokov služby Fabric s údajmi z databázy KQL

Poznámkové bloky sú čitateľné dokumenty obsahujúce popisy a výsledky analýzy údajov, ako aj spustiteľné dokumenty, ktoré je možné spustiť na vykonanie analýzy údajov. V tomto článku sa dozviete, ako používať poznámkový blok služby Fabric na pripojenie k údajom v databáze KQL a spúšťanie dotazov pomocou natívneho jazyka KQL (Kusto Query Language). Ďalšie informácie o poznámkových blokoch nájdete v téme Ako používať poznámkové bloky služby Microsoft Fabric.

Existujú dva spôsoby, ako používať poznámkové bloky služby Fabric s údajmi z databázy KQL:

Požiadavky

Použitie úryvkov Kusto v poznámkovom bloku

Poznámkové bloky tkaniny poskytujú úryvky kódu, ktoré vám pomôžu jednoducho písať bežne používané vzory kódu. Úryvky môžete použiť na zápis alebo čítanie údajov v databáze KQL pomocou KQL.

  1. Prejdite do existujúceho poznámkového bloku alebo vytvorte nový.

  2. V bunke kódu začnite písať kusto.

    Snímanie obrazovky pomocou úryvku kusto na použitie kľúčového ukazovateľa výkonu v notebooku služby Fabric.

  3. Vyberte úryvok kódu, ktorý zodpovedá operácii, ktorú chcete vykonať: Zapisovanie údajov do databázy KQL alebo Čítanie údajov z databázy KQL.

    Nasledujúci zlomok kódu zobrazuje príklad operácie čítania údajov:

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

    Nasledujúci zlomok kódu zobrazuje príklad operácie zápisu údajov:

    # 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. Do úvodzoviek každého poľa v údajovej bunke zadajte požadované informácie:

    Pole Description Súvisiace prepojenia
    kustoQuery Dotaz KQL, ktorý sa má vyhodnotiť. Prehľad KQL
    KustoUri Identifikátor URI dotazu vašej databázy KQL. Kopírovanie identifikátora URI databázy KQL
    databáza Názov vašej databázy KQL. Prístup k existujúcej databáze KQL
    údaje Údaje, ktoré sa majú zapísať do tabuľky.
  5. Spustite bunku kódu.

Vytvorenie poznámkového bloku z databázy KQL

Keď v databáze KQL vytvoríte poznámkový blok ako súvisiacu položku, poznámkový blok bude mať rovnaký názov ako databáza KQL a bude obsahovať informácie o pripojení.

  1. Prejdite do svojej databázy KQL.

  2. Vyberte položku Poznámkový blok novej súvisiacej položky>.

    Snímka obrazovky znázorňujúca vytvorenie poznámkového bloku ako súvisiacej položky v databáze KQL.

    Poznámkový blok je vytvorený s vopred vyplnenými údajmi databázy KustoUri.

  3. Zadajte dotaz KQL, ktorý sa má vyhodnotiť v poli kustoQuery .

    Snímka obrazovky poznámkového bloku, ktorý je vytvorený z databázy KQL.

  4. Spustite bunku kódu.