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
- pracovného priestoru s kapacitou podporujúcich službu Microsoft Fabric
- Databáza KQL s aspoň zobrazovanými povoleniami
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.
Prejdite do existujúceho poznámkového bloku alebo vytvorte nový.
V bunke kódu začnite písať kusto.
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()
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. 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í.
Prejdite do svojej databázy KQL.
Vyberte položky Nová súvisiaca položka>poznámkovom bloke.
Poznámkový blok je vytvorený s vopred vyplnenými údajmi databázy KustoUri.
Zadajte dotaz KQL, ktorý sa má vyhodnotiť v poli kustoQuery.
Spustite bunku kódu.