Menggunakan notebook Fabric dengan data dari database KQL
Notebook adalah dokumen yang dapat dibaca yang berisi deskripsi analisis data dan hasil serta dokumen yang dapat dieksekusi yang dapat dijalankan untuk melakukan analisis data. Dalam artikel ini, Anda mempelajari cara menggunakan notebook Fabric untuk menyambungkan ke data dalam KQL Database dan menjalankan kueri menggunakan KQL asli (Bahasa Kueri Kusto). Untuk informasi selengkapnya tentang notebook, lihat Cara menggunakan notebook Microsoft Fabric.
Ada dua cara untuk menggunakan notebook Fabric dengan data dari database KQL Anda:
Prasyarat
- Ruang kerja dengan kapasitas yang didukung Microsoft Fabric
- Database KQL dengan izin melihat setidaknya
Menggunakan cuplikan Kusto dalam buku catatan
Notebook Fabric menyediakan cuplikan kode yang membantu Anda menulis pola kode yang umum digunakan dengan mudah. Anda dapat menggunakan cuplikan untuk menulis atau membaca data dalam database KQL menggunakan KQL.
Navigasikan ke buku catatan yang sudah ada atau buat buku catatan baru.
Dalam sel kode, mulailah mengetik kusto.
Pilih cuplikan yang sesuai dengan operasi yang ingin Anda lakukan: Menulis data ke database KQL atau Membaca data dari database KQL.
Cuplikan kode berikut menunjukkan contoh operasi baca data:
# 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()
Cuplikan kode berikut menunjukkan contoh operasi tulis data:
# 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()
Masukkan informasi yang diperlukan dalam tanda kutip setiap bidang di sel data:
Ladang Deskripsi Tautan terkait kustoQuery Kueri KQL yang akan dievaluasi. tinjauan KQL KustoUri URI dari kueri database KQL Anda. Menyalin URI database KQL database Nama database KQL Anda. Mengakses database KQL yang sudah ada data Data yang akan ditulis ke tabel. Jalankan sel kode.
Membuat buku catatan dari database KQL
Saat Anda membuat buku catatan sebagai item terkait dalam database KQL, buku catatan diberi nama yang sama dengan database KQL dan sudah dilengkapi dengan informasi koneksi.
Akses database KQL Anda.
Pilih Item terkait baru>Notebook.
Buku catatan dibuat dengan KustoUri dan detail database yang sudah diisi sebelumnya.
Masukkan kueri KQL untuk dievaluasi di bidang kustoQuery.
Jalankan sel kode.