Doku not defterlerini KQL veritabanındaki verilerle kullanma
Not defterleri hem veri analizi açıklamalarını içeren okunabilir belgeler hem de veri analizi gerçekleştirmek için çalıştırılabilir belgelerdir. Bu makalede, KQL Veritabanındaki verilere bağlanmak ve yerel KQL (Kusto Sorgu Dili) kullanarak sorgu çalıştırmak için Doku not defteri kullanmayı öğreneceksiniz. Not defterleri hakkında daha fazla bilgi için bkz . Microsoft Fabric not defterlerini kullanma.
Doku not defterlerini KQL veritabanınızdaki verilerle kullanmanın iki yolu vardır:
Önkoşullar
- Microsoft Fabric özellikli kapasiteye sahip bir çalışma alanı
- En azından görüntüleme izinlerine sahip bir KQL veritabanı
Not defterinde Kusto parçacıklarını kullanma
Doku not defterleri, yaygın olarak kullanılan kod desenlerini kolayca yazmanıza yardımcı olan kod parçacıkları sağlar. KQL kullanarak KQL veritabanında veri yazmak veya okumak için kod parçacıkları kullanabilirsiniz.
Mevcut bir not defterine gidin veya yeni bir not defteri oluşturun.
Kod hücresinde kusto yazmaya başlayın.
Gerçekleştirmek istediğiniz işleme karşılık gelen kod parçacığını seçin: KQL veritabanına veri yazma veya KQL veritabanından verileri okuma.
Aşağıdaki kod parçacığı örnek veri okuma işlemini gösterir:
# 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()
Aşağıdaki kod parçacığı örnek yazma veri işlemini gösterir:
# 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()
Veri hücresindeki her alanın tırnak işaretleri içinde gerekli bilgileri girin:
Alan Açıklama İlgili bağlantılar kustoQuery Değerlendirilecek KQL sorgusu. KQL'e Genel Bakış KustoUri KQL veritabanınızın sorgu URI'si. KQL veritabanı URI'lerini kopyalama database KQL veritabanınızın adı. Mevcut bir KQL veritabanına erişme veriler Tabloya yazılacak veriler. Kod hücresini çalıştırın.
KQL veritabanından not defteri oluşturma
KQL veritabanında ilgili bir öğe olarak bir not defteri oluşturduğunuzda, not defterine KQL veritabanıyla aynı ad verilir ve bağlantı bilgileriyle önceden doldurulur.
KQL veritabanınıza göz atın.
Yeni ilgili öğe Not Defteri'ni> seçin.
KustoUri ve veritabanı ayrıntıları önceden doldurulmuş bir not defteri oluşturulur.
KustoQuery alanına değerlendirilecek KQL sorgusunu girin.
Kod hücresini çalıştırın.