Sdílet prostřednictvím


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:

Požadavky

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.

  1. Přejděte do existujícího poznámkového bloku nebo vytvořte nový.

  2. V buňce kódu začněte psát "kusto".

    Snímek obrazovky použití úryvku kusto pro KQL v poznámkovém bloku Fabric.

  3. 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()
    
  4. 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.
  5. 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í.

  1. Procházejte databázi KQL.

  2. Vyberte novou související položku poznámkového bloku>.

    snímek obrazovky s vytvořením poznámkového bloku jako související položky v databázi KQL

    Vytvoří se poznámkový blok s předem vyplněnými podrobnostmi o KustoUri a databázi.

  3. Do pole kustoQuery zadejte dotaz KQL, který se má vyhodnotit.

    snímek obrazovky s poznámkovým blokem vytvořeným z databáze KQL

  4. Spusťte buňku kódu.