Udostępnij za pośrednictwem


Używanie notesów Fabric z danymi z bazy danych KQL

Notesy to zarówno czytelne dokumenty zawierające opisy analizy danych, jak i wyniki oraz dokumenty wykonywalne, które można uruchomić w celu przeprowadzenia analizy danych. Z tego artykułu dowiesz się, jak używać notesu sieci szkieletowej do nawiązywania połączenia z danymi w bazy danych KQL i uruchamiać zapytania przy użyciu natywnych języka KQL (Kusto Query Language). Aby uzyskać więcej informacji na temat notatników, zobacz Jak używać notatników usługi Microsoft Fabric.

Istnieją dwa sposoby używania notebooków Fabric z danymi z bazy danych KQL:

Warunki wstępne

Używanie fragmentów kodu Kusto w notesie

Notesy Fabric zapewniają fragmenty kodu, które ułatwiają pisanie często używanych wzorców kodu. Za pomocą fragmentów kodu można zapisywać lub odczytywać dane w bazie danych KQL przy użyciu języka KQL.

  1. Przejdź do istniejącego notesu lub utwórz nowy.

  2. W komórce kodu rozpocznij wpisywanie kusto.

    Przechwytywanie ekranu przy użyciu fragmentu kodu Kusto do używania języka KQL w notesie Fabric.

  3. Wybierz fragment kodu odpowiadający operacji, którą chcesz wykonać: Zapisywanie danych w bazie danych KQL lub odczytywanie danych z bazy danych KQL.

    Poniższy fragment kodu przedstawia przykładową operację odczytu danych:

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

    Poniższy fragment kodu przedstawia przykładową operację zapisu danych:

    # 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. Wprowadź wymagane informacje w cudzysłowie każdego pola w komórce danych:

    Pole Opis Powiązane linki
    kustoQuery Zapytanie KQL do oceny. omówienie języka KQL
    KustoUri URI zapytania bazy danych KQL. Skopiuj URI bazy danych KQL
    baza danych Nazwa bazy danych KQL. uzyskiwanie dostępu do istniejącej bazy danych KQL
    dane Dane, które mają zostać zapisane w tabeli.
  5. Uruchom komórkę kodu.

Tworzenie notesu na podstawie bazy danych KQL

Podczas tworzenia notesu jako powiązanego elementu w bazie danych KQL, notes otrzymuje taką samą nazwę jak baza danych KQL i jest wstępnie wypełniany danymi do połączenia.

  1. Przejdź do bazy danych KQL.

  2. Wybierz nowy element pokrewny >Notatnik.

    Zrzut ekranu przedstawiający tworzenie notesu jako powiązanego elementu w bazie danych KQL.

    Notatnik jest tworzony z wcześniej wypełnionymi danymi adresu KustoUri i szczegółami bazy danych.

  3. Wprowadź zapytanie KQL, które ma zostać ocenione w polu kustoQuery.

    Zrzut ekranu przedstawiający notes utworzony na podstawie bazy danych KQL.

  4. Uruchom komórkę kodu.