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
- Obszar roboczy z pojemnością z włączoną usługą Microsoft Fabric
- bazy danych KQL z co najmniej uprawnieniami do wyświetlania
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.
Przejdź do istniejącego notesu lub utwórz nowy.
W komórce kodu rozpocznij wpisywanie 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('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()
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. 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.
Przejdź do bazy danych KQL.
Wybierz nowy element pokrewny >Notatnik.
Notatnik jest tworzony z wcześniej wypełnionymi danymi adresu KustoUri i szczegółami bazy danych.
Wprowadź zapytanie KQL, które ma zostać ocenione w polu kustoQuery.
Uruchom komórkę kodu.