Używanie notesów sieci szkieletowej 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 sieci szkieletowej do łączenia się z danymi w bazie danych KQL i uruchamiania zapytań przy użyciu natywnego języka KQL (język zapytań Kusto). Aby uzyskać więcej informacji na temat notesów, zobacz How to use Microsoft Fabric notebooks (Jak używać notesów usługi Microsoft Fabric).
Istnieją dwa sposoby używania notesów sieci Szkieletowej z danymi z bazy danych KQL:
Wymagania wstępne
- Obszar roboczy z pojemnością z włączoną usługą Microsoft Fabric
- Baza danych KQL z co najmniej uprawnieniami do wyświetlania
Używanie fragmentów kodu Kusto w notesie
Notesy sieci szkieletowej udostępniają fragmenty kodu, które ułatwiają łatwe 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.
Przejdź do istniejącego notesu lub utwórz nowy.
W komórce kodu rozpocznij wpisywanie polecenia kusto.
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(kustoUri) 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(kustoUri) # 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()
Wprowadź wymagane informacje w cudzysłowie każdego pola w komórce danych:
Pole opis Pokrewne łącza kustoQuery Zapytanie KQL do oceny. Omówienie języka KQL KustoUri Identyfikator URI zapytania bazy danych KQL. Kopiowanie identyfikatora URI bazy danych KQL database Nazwa bazy danych KQL. Uzyskiwanie dostępu do istniejącej bazy danych KQL dane Dane, które mają zostać zapisane w tabeli. Uruchom komórkę kodu.
Tworzenie notesu na podstawie bazy danych KQL
Podczas tworzenia notesu jako powiązanego elementu w bazie danych KQL notes ma taką samą nazwę jak baza danych KQL i jest wstępnie wypełniany informacjami o połączeniu.
Przejdź do bazy danych KQL.
Wybierz pozycję Nowy powiązany element>Notes.
Notes jest tworzony przy użyciu wstępnie wypełnionego identyfikatora KustoUri i szczegółów bazy danych.
Wprowadź zapytanie KQL, które ma zostać ocenione w polu kustoQuery .
Uruchom komórkę kodu.