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. W tym artykule dowiesz się, jak używać notesu Fabric do łączenia się z danymi w KQL Database i uruchamiać zapytania przy użyciu natywnego 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.

Istnieje kilka sposobów używania notesów Fabric z danymi z bazy danych KQL:

Warunki wstępne

Załaduj dane bazy danych KQL z katalogu OneLake

Bazy danych KQL w katalogu OneLake są dostępne jako źródła danych w środowisku notesnika. Bazę danych KQL można dodać jako źródło danych do notesnika, a następnie odwoływać się do niej w komórkach kodu, aby uruchamiać względem niej zapytania KQL.

  1. W obszarze roboczym przejdź do istniejącego notesu lub utwórz nowy.

  2. W panelu Eksplorator notatnika wybierz pozycję Dodaj elementy danych, a następnie wybierz pozycję Z katalogu OneLake.

    Zrzut ekranu przedstawiający notatnik z otwartym panelem Eksplorator na karcie Elementy danych. Przycisk Dodaj elementy danych jest rozwinięty, a opcja Z katalogu OneLake catatlog jest wyróżniona.

  3. W katalogu OneLake przejdź do bazy danych KQL. Możesz go znaleźć w folderze Eventhouse, do którego należy, możesz filtrować listę według typu i wybrać typ bazy danych KQL lub wyszukać ją według nazwy.

    Zrzut ekranu przedstawiający filtr wykazu OneLake z wyróżnionym filtrem bazy danych KQL.

  4. Baza danych KQL zostaje dodana w sekcji OneLake w okienku eksploratora notesu.

    1. Rozwiń bazę danych, aby wyświetlić w niej tabele.

    2. Zatrzymaj wskaźnik myszy na tabeli, wybierz menu więcej ... , a następnie wybierz pozycję Załaduj dane.

      Zrzut ekranu przedstawiający rozwiniętą bazę danych KQL, aby pokazać jej tabele. Rozwinięto menu Więcej dla tabeli, aby pokazać opcję Załaduj dane.

  5. Dane z tabeli są wczytywane do nowej komórki kodu w notesniku, a połączenie z bazą danych KQL jest automatycznie nawiązywane. Następnie możesz uruchomić komórkę kodu, aby wysłać zapytanie do danych i uzyskać wyniki w notatniku.

    Zrzut ekranu przedstawiający notes po załadowaniu danych z bazy danych KQL. Fragment kodu został wyróżniony.

Aby uzyskać więcej informacji na temat środowiska notesu z danymi KQL i opcjami analizy danych, zobacz xxxxxxx.

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.