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úšťať dotazy pomocou natívneho KQL (Kusto Query Language). Ďalšie informácie o poznámkových blokoch nájdete v 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:

Predpoklady

Použitie úryvkov Kusto v poznámkovom bloku

Poznámkové bloky služby Fabric 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.

    obrazovky zachytáva pomocou kusto úryvok kódu na použitie KQL v notebooku fabric.

  3. Vyberte úryvok kódu, ktorý zodpovedá operácii, ktorú chcete vykonať: zapisovať údaje do databázy KQL alebo čítať údaje 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('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()
    

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

    Pole Popis Súvisiace prepojenia
    kustoQuery Dotaz KQL, ktorý sa má vyhodnotiť. prehľad KQL
    KustoUri Identifikátor URI dotazu vašej databázy KQL. Skopírovanie identifikátorov 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žky Nová súvisiaca položka>poznámkovom bloke.

    Snímka obrazovky vytvorenia 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.