Χρήση σημειωματάριων Fabric με δεδομένα από μια βάση δεδομένων KQL
Τα σημειωματάρια είναι ευανάγνωστα έγγραφα που περιέχουν περιγραφές ανάλυσης δεδομένων και αποτελέσματα και εκτελέσιμα έγγραφα που μπορούν να εκτελεστούν για την εκτέλεση ανάλυσης δεδομένων. Σε αυτό το άρθρο, θα μάθετε πώς μπορείτε να χρησιμοποιήσετε ένα σημειωματάριο Fabric για να συνδεθείτε σε δεδομένα σε μια βάση δεδομένων KQL και να εκτελέσετε ερωτήματα χρησιμοποιώντας εγγενή KQL (Γλώσσα ερωτημάτων Kusto). Για περισσότερες πληροφορίες σχετικά με τα σημειωματάρια, ανατρέξτε στο θέμα Τρόπος χρήσης σημειωματάριων Microsoft Fabric.
Υπάρχουν δύο τρόποι για να χρησιμοποιήσετε σημειωματάρια Fabric με δεδομένα από τη βάση δεδομένων KQL:
- Χρήση τμημάτων κώδικα Kusto σε σημειωματάριο
- Δημιουργία σημειωματάριου από μια βάσης δεδομένων KQL
Προϋποθέσεις
- Ένας χώρος εργασίας με εκχωρημένους πόρους με δυνατότητα Microsoft Fabric
- Μια βάσης δεδομένων KQL με τουλάχιστον δικαιώματα προβολής
Χρήση τμημάτων κώδικα Kusto σε σημειωματάριο
Τα σημειωματάρια Fabric παρέχουν τμήματα κώδικα που σας βοηθούν να γράφετε εύκολα μοτίβα κώδικα που χρησιμοποιούνται συχνά. Μπορείτε να χρησιμοποιήσετε τμήματα κώδικα για την εγγραφή ή ανάγνωση δεδομένων σε μια βάση δεδομένων KQL χρησιμοποιώντας KQL.
Μεταβείτε σε ένα υπάρχον σημειωματάριο ή δημιουργήστε ένα νέο.
Σε ένα κελί κώδικα, αρχίστε να πληκτρολογείτε kusto.
Επιλέξτε το τμήμα κώδικα που αντιστοιχεί στη λειτουργία που θέλετε να εκτελέσετε: Εγγραφή δεδομένων σε βάσης δεδομένων KQL ή Ανάγνωση δεδομένων από μια βάση δεδομένων KQL.
Το παρακάτω τμήμα κώδικα εμφανίζει το παράδειγμα λειτουργίας ανάγνωσης δεδομένων:
# 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()
Το παρακάτω τμήμα κώδικα εμφανίζει το παράδειγμα λειτουργίας εγγραφής δεδομένων:
# 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()
Εισαγάγετε τις απαιτούμενες πληροφορίες στα εισαγωγικά κάθε πεδίου στο κελί δεδομένων:
Αγρός Περιγραφή Σχετικές συνδέσεις kustoQuery Το ερώτημα KQL προς αξιολόγηση. επισκόπησης KQL KustoUri Το URI ερωτήματος της βάσης δεδομένων KQL. Αντιγραφή URI βάσης δεδομένων KQL βάση δεδομένων Το όνομα της βάσης δεδομένων KQL. Πρόσβαση σε μια υπάρχουσα βάσης δεδομένων KQL δεδομένα Τα δεδομένα που θα εγγραφούν στον πίνακα. Εκτελέστε το κελί κώδικα.
Δημιουργία σημειωματάριου από βάση δεδομένων KQL
Όταν δημιουργείτε ένα σημειωματάριο ως σχετικό στοιχείο σε μια βάση δεδομένων KQL, το σημειωματάριο λαμβάνει το ίδιο όνομα με τη βάση δεδομένων KQL και προ-συμπυκνώνεται με πληροφορίες σύνδεσης.
Μεταβείτε στη βάση δεδομένων KQL.
Επιλέξτε Νέο σχετικό στοιχείο>Σημειωματάριο.
Δημιουργείται ένα σημειωματάριο με προσυμπλημένες τις λεπτομέρειες του KustoUri και της βάσης δεδομένων.
Εισαγάγετε το ερώτημα KQL που θα αξιολογηθεί στο πεδίο kustoQuery.
Εκτελέστε το κελί κώδικα.