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

Τρόπος: Η πρόσβαση κατοπτρικά δεδομένα του Azure Cosmos DB στο Lakehouse και σημειωματάρια από το Microsoft Fabric (Προεπισκόπηση)

  • Άρθρο

Σε αυτόν τον οδηγό, θα μάθετε πώς μπορείτε να αποκτήσετε πρόσβαση με κατοπτρικά δεδομένα του Azure Cosmos DB στο Lakehouse και σημειωματάρια από το Microsoft Fabric (Προεπισκόπηση).

Σημαντικό

Το κατοπτρικό αντίγραφο για το Azure Cosmos DB είναι αυτήν τη στιγμή σε προεπισκόπηση. Οι φόρτοι εργασίας παραγωγής δεν υποστηρίζονται κατά τη διάρκεια της προεπισκόπησης. Προς το παρόν, υποστηρίζονται μόνο οι λογαριασμοί Azure Cosmos DB για NoSQL.

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

Φιλοδώρημα

Κατά τη διάρκεια της δημόσιας προεπισκόπησης, συνιστάται να χρησιμοποιήσετε ένα αντίγραφο δοκιμής ή ανάπτυξης των υπαρχόντων δεδομένων σας Azure Cosmos DB που μπορούν να ανακτηθούν γρήγορα από ένα αντίγραφο ασφαλείας.

Ρύθμιση κατοπτρισμού και προαπαιτούμενων

Ρυθμίστε τις παραμέτρους κατοπτρισμού για τη βάση δεδομένων Azure Cosmos DB for NoSQL. Εάν δεν είστε βέβαιοι για τον τρόπο ρύθμισης παραμέτρων κατοπτρισμού, ανατρέξτε στο εκπαιδευτικό βοήθημα ρύθμισης παραμέτρων βάσης δεδομένων κατοπτρισμού.

  1. Μεταβείτε στην πύλη Fabric.

  2. Δημιουργήστε μια νέα σύνδεση και κατοπτρικό βάση δεδομένων χρησιμοποιώντας τα διαπιστευτήρια του λογαριασμού σας Azure Cosmos DB.

  3. Περιμένετε μέχρι την αναπαραγωγή να ολοκληρωθεί το αρχικό στιγμιότυπο δεδομένων.

Πρόσβαση με κατοπτρισμού δεδομένα στο Lakehouse και σημειωματάρια

Χρησιμοποιήστε το Lakehouse για να επεκτείνετε περαιτέρω τον αριθμό των εργαλείων που μπορείτε να χρησιμοποιήσετε για να αναλύσετε τα κατοπτρικά δεδομένα Azure Cosmos DB για NoSQL. Εδώ, χρησιμοποιείτε το Lakehouse για να δημιουργήσετε ένα σημειωματάριο Spark για να υποβάλετε ερωτήματα για τα δεδομένα σας.

  1. Μεταβείτε ξανά στην αρχική σελίδα της πύλης Fabric.

  2. Στο μενού πλοήγησης, επιλέξτε Δημιουργία.

  3. Επιλέξτε Δημιουργία, εντοπίστε την ενότητα Διαχείριση δεδομένων και, στη συνέχεια, επιλέξτε Lakehouse.

  4. Εισαγάγετε ένα όνομα για το Lakehouse και, στη συνέχεια, επιλέξτε Δημιουργία.

  5. Στη συνέχεια, επιλέξτε Λήψη δεδομένων και, στη συνέχεια , Νέα συντόμευση. Από τη λίστα επιλογών συντόμευσης, επιλέξτε Microsoft OneLake.

  6. Επιλέξτε τη βάση δεδομένων Azure Cosmos DB με κατοπτρικό αντίγραφο για noSQL από τη λίστα των βάσεων δεδομένων κατοπτρισμού στον χώρο εργασίας Fabric σας. Επιλέξτε τους πίνακες που θα χρησιμοποιήσετε με το Lakehouse, επιλέξτε Επόμενο και, στη συνέχεια, επιλέξτε Δημιουργία.

  7. Ανοίξτε το μενού περιβάλλοντος για τον πίνακα στο Lakehouse και επιλέξτε Νέο ή υπάρχον σημειωματάριο.

  8. Ένα νέο σημειωματάριο ανοίγει αυτόματα και φορτώνει ένα πλαίσιο δεδομένων χρησιμοποιώντας το SELECT LIMIT 1000.

  9. Εκτελέστε ερωτήματα όπως SELECT * χρησιμοποιώντας το Spark.

    df = spark.sql("SELECT * FROM Lakehouse.OrdersDB_customers LIMIT 1000")
display(df)

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

    Σημείωμα

    Αυτό το παράδειγμα προϋποθέτει το όνομα του πίνακά σας. Χρησιμοποιήστε τον δικό σας πίνακα κατά τη σύνταξη του ερωτήματος Spark.

Επαναφορά εγγραφής χρησιμοποιώντας το Spark

Τέλος, μπορείτε να χρησιμοποιήσετε κώδικα Spark και Python για να γράψετε δεδομένα στον λογαριασμό σας Azure Cosmos DB προέλευσης από σημειωματάρια στο Fabric. Μπορεί να θέλετε να το κάνετε αυτό για να γράψετε ξανά τα αναλυτικά αποτελέσματα στο Cosmos DB, το οποίο μπορεί έπειτα να χρησιμοποιηθεί ως επίπεδο εξυπηρέτησης για εφαρμογές OLTP.

  1. Δημιουργήστε τέσσερα κελιά κώδικα στο σημειωματάριό σας.

  2. Πρώτα, υποβάλετε ερωτήματα για τα δεδομένα κατοπτρισμού σας.

    fMirror = spark.sql("SELECT * FROM Lakehouse1.OrdersDB_ordercatalog")

    Φιλοδώρημα

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

  3. Τώρα, μετασχηματίστε και συγκεντρώστε τα δεδομένα.

    dfCDB = dfMirror.filter(dfMirror.categoryId.isNotNull()).groupBy("categoryId").agg(max("price").alias("max_price"), max("id").alias("id"))

  4. Στη συνέχεια, ρυθμίστε τις παραμέτρους του Spark για εγγραφή ξανά στον λογαριασμό σας Azure Cosmos DB for NoSQL χρησιμοποιώντας τα διαπιστευτήρια, το όνομα βάσης δεδομένων και το όνομα κοντέινερ.

    writeConfig = {
  "spark.cosmos.accountEndpoint" : "https://xxxx.documents.azure.com:443/",
  "spark.cosmos.accountKey" : "xxxx",
  "spark.cosmos.database" : "xxxx",
  "spark.cosmos.container" : "xxxx"
}

  5. Τέλος, χρησιμοποιήστε το Spark για να γράψετε ξανά στη βάση δεδομένων προέλευσης.

    dfCDB.write.mode("APPEND").format("cosmos.oltp").options(**writeConfig).save()

  6. Εκτελέστε όλα τα κελιά κώδικα.

    Σημαντικό

    Οι λειτουργίες εγγραφής στο Azure Cosmos DB θα καταναλώνουν μονάδες αίτησης (RUs).

Σχετικό περιεχόμενο