Použití poznámkových bloků Fabric s daty z databáze KQL
Poznámkové bloky jsou čitelné dokumenty obsahující popisy analýzy dat a výsledky a spustitelné dokumenty, které je možné spustit za účelem analýzy dat. V tomto článku se dozvíte, jak pomocí poznámkového bloku Fabric připojit k datům v databázi KQL a spouštět dotazy pomocí nativního KQL (Dotazovací jazyk Kusto). Další informace o poznámkových blocích najdete v tématu Jak používat poznámkové bloky Microsoft Fabric.
Poznámkové bloky Fabric s daty z databáze KQL můžete používat dvěma způsoby:
- Použijte fragmenty kódu Kusto v poznámkovém bloku
- Vytvoření poznámkového bloku z databáze KQL
Požadavky
- Pracovní prostor s kapacitou , která má povolenou funkci Microsoft Fabric
- Databáze KQL s alespoň oprávněními k zobrazení
Použití fragmentů kódu Kusto v poznámkovém bloku
Fabric poznámkové bloky poskytují fragmenty kódu, které vám pomohou snadno psát běžně používané šablony kódu. Fragmenty kódu můžete použít k zápisu nebo čtení dat v databázi KQL pomocí KQL.
Přejděte do existujícího poznámkového bloku nebo vytvořte nový.
V buňce kódu začněte psát "kusto".
Vyberte fragment kódu odpovídající operaci, kterou chcete provést: Zápis dat do databáze KQL nebo Čtení dat z databáze KQL.
Následující fragment kódu ukazuje ukázku operace čtení dat:
# 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()
Následující fragment kódu ukazuje ukázku operace zápisu dat:
# 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 uvozovek každého pole v datové buňce zadejte požadované informace:
Pole Popis Související odkazy KustoQuery Dotaz KQL, který se má vyhodnotit. přehled KQL KustoUri Identifikátor URI dotazu vaší databáze KQL. Zkopírovat URI databáze KQL databáze Název databáze KQL. Přístup k existující databázi KQL údaje Data, která se mají zapsat do tabulky. Spusťte buňku kódu.
Vytvoření poznámkového bloku z databáze KQL
Když vytvoříte poznámkový blok jako související položku v databázi KQL, bude poznámkový blok shodný s názvem databáze KQL a předem vyplněný informacemi o připojení.
Procházejte databázi KQL.
Vyberte novou související položku poznámkového bloku>.
Vytvoří se poznámkový blok s předem vyplněnými podrobnostmi o KustoUri a databázi.
Do pole kustoQuery zadejte dotaz KQL, který se má vyhodnotit.
Spusťte buňku kódu.
Související obsah
- Přehled KQL
- Jak používat poznámkové bloky Microsoft Fabric