Κοινή χρήση μέσω


Χρήση σημειωματάριων Fabric με δεδομένα από μια βάση δεδομένων KQL

Τα σημειωματάρια είναι ευανάγνωστα έγγραφα που περιέχουν περιγραφές ανάλυσης δεδομένων και αποτελέσματα και εκτελέσιμα έγγραφα που μπορούν να εκτελεστούν για την εκτέλεση ανάλυσης δεδομένων. Σε αυτό το άρθρο, θα μάθετε πώς μπορείτε να χρησιμοποιήσετε ένα σημειωματάριο Fabric για να συνδεθείτε σε δεδομένα σε μια βάση δεδομένων KQL και να εκτελέσετε ερωτήματα χρησιμοποιώντας εγγενή KQL (Γλώσσα ερωτήματος Kusto). Για περισσότερες πληροφορίες σχετικά με τα σημειωματάρια, ανατρέξτε στο θέμα Τρόπος χρήσης σημειωματάριων Microsoft Fabric.

Υπάρχουν δύο τρόποι για να χρησιμοποιήσετε σημειωματάρια Fabric με δεδομένα από τη βάση δεδομένων KQL:

Προαπαιτούμενα στοιχεία

Χρήση τμημάτων κώδικα Kusto σε σημειωματάριο

Τα σημειωματάρια Fabric παρέχουν τμήματα κώδικα που σας βοηθούν να γράφετε εύκολα μοτίβα κώδικα που χρησιμοποιούνται συχνά. Μπορείτε να χρησιμοποιήσετε τμήματα κώδικα για την εγγραφή ή ανάγνωση δεδομένων σε μια βάση δεδομένων KQL χρησιμοποιώντας KQL.

  1. Μεταβείτε σε ένα υπάρχον σημειωματάριο ή δημιουργήστε ένα νέο.

  2. Σε ένα κελί κώδικα, αρχίστε να πληκτρολογείτε kusto.

    Καταγραφή οθόνης της χρήσης τμήματος κώδικα kusto για χρήση του KQL σε ένα σημειωματάριο Fabric.

  3. Επιλέξτε το τμήμα κώδικα που αντιστοιχεί στη λειτουργία που θέλετε να εκτελέσετε: Εγγραφή δεδομένων σε μια βάση δεδομένων 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()
    
  4. Εισαγάγετε τις απαιτούμενες πληροφορίες στα εισαγωγικά κάθε πεδίου στο κελί δεδομένων:

    Πεδίο Περιγραφή Σχετικές συνδέσεις
    kustoQuery Το ερώτημα KQL προς αξιολόγηση. Επισκόπηση KQL
    KustoUri Το URI ερωτήματος της βάσης δεδομένων KQL. Αντιγραφή URI βάσης δεδομένων KQL
    βάση δεδομένων Το όνομα της βάσης δεδομένων KQL. Πρόσβαση σε μια υπάρχουσα βάση δεδομένων KQL
    δεδομένων Τα δεδομένα που θα εγγραφούν στον πίνακα.
  5. Εκτελέστε το κελί κώδικα.

Δημιουργία σημειωματάριου από βάση δεδομένων KQL

Όταν δημιουργείτε ένα σημειωματάριο ως σχετικό στοιχείο σε μια βάση δεδομένων KQL, το σημειωματάριο λαμβάνει το ίδιο όνομα με τη βάση δεδομένων KQL και προ-συμπυκνώνεται με πληροφορίες σύνδεσης.

  1. Μεταβείτε στη βάση δεδομένων KQL.

  2. Επιλέξτε Νέο σχετικό στοιχείο>Σημειωματάριο.

    Στιγμιότυπο οθόνης δημιουργίας ενός σημειωματάριου ως σχετικού στοιχείου σε μια βάση δεδομένων KQL.

    Δημιουργείται ένα σημειωματάριο με προσυμπλημένες τις λεπτομέρειες του KustoUri και της βάσης δεδομένων.

  3. Εισαγάγετε το ερώτημα KQL που θα αξιολογηθεί στο πεδίο kustoQuery .

    Στιγμιότυπο οθόνης του σημειωματάριου που δημιουργείται από μια βάση δεδομένων KQL.

  4. Εκτελέστε το κελί κώδικα.