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