Προσθήκη του My Βάση δεδομένων SQL CDC ως προέλευσης στο Κέντρο σε πραγματικό χρόνο (προεπισκόπηση)

Αυτό το άρθρο περιγράφει τον τρόπο προσθήκης της καταγραφής δεδομένων My Βάση δεδομένων SQL Change Data Capture (CDC) ως προέλευσης συμβάντων στο κέντρο πραγματικού χρόνου Fabric.

Η σύνδεση Azure My Βάση δεδομένων SQL Change Data Capture (CDC) σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων Azure MySQL. Καθορίζετε τους πίνακες που θα παρακολουθούνται και λαμβάνετε ειδοποιήσεις όταν οποιεσδήποτε επόμενες αλλαγές σε επίπεδο γραμμών στους πίνακες. Μόλις οι αλλαγές καταγράφονται σε μια ροή, μπορείτε να επεξεργαστείτε αυτά τα δεδομένα CDC σε πραγματικό χρόνο και να τα στείλετε σε διαφορετικούς προορισμούς εντός του Fabric για περαιτέρω επεξεργασία ή ανάλυση.

Σημείωμα

Ο Διανομέας πραγματικού χρόνου βρίσκεται αυτήν τη στιγμή σε προεπισκόπηση.

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

• Αποκτήστε πρόσβαση στον premium χώρο εργασίας Fabric με δικαιώματα Συμβάλλοντα ή παραπάνω.
• Δημιουργήθηκε μια παρουσία της Βάσης δεδομένων Azure για MySQL – Ευέλικτος διακομιστής.

Ρύθμιση βάσης δεδομένων MySQL

Η σύνδεση βάσης δεδομένων Azure MySQL χρησιμοποιεί τη σύνδεση Debezium MySQL για την καταγραφή αλλαγών στο Βάση δεδομένων SQL μου. Πρέπει να ορίσετε έναν χρήστη MySQL με δικαιώματα σε όλες τις βάσεις δεδομένων που παρακολουθεί η σύνδεση. Για οδηγίες βήμα προς βήμα, ανατρέξτε στο θέμα Ρύθμιση της βάσης δεδομένων MySQL.

Ενεργοποίηση του binlog

Πρέπει να ενεργοποιήσετε τη δυαδική καταγραφή για αναπαραγωγή MySQL. Τα δυαδικά αρχεία καταγραφής καταγράφουν ενημερώσεις συναλλαγών για τα εργαλεία αναπαραγωγής για τη μετάδοση των αλλαγών. Για παράδειγμα, Βάση δεδομένων Azure για MySQL.

1. Στην πύλη Azure, μεταβείτε στη βάση δεδομένων Azure MySQL.

2. Στο αριστερό μενού περιήγησης, επιλέξτε Παράμετροι διακομιστή.

3. Ρυθμίστε τις παραμέτρους του διακομιστή σας MySQL με τις ακόλουθες ιδιότητες.

   • binlog_row_image: Ορίστε την τιμή στο ακέραιο.
   • binlog_expire_logs_seconds: Ο αριθμός των δευτερολέπτων για αυτόματη κατάργηση αρχείου binlog. Ορίστε την τιμή ώστε να ταιριάζει με τις ανάγκες του περιβάλλοντός σας. Για παράδειγμα, 86400.

   

Λήψη συμβάντων από το Azure My Βάση δεδομένων SQL (CDC)

Μπορείτε να λάβετε συμβάντα από ένα Azure My Βάση δεδομένων SQL CDC στο Κέντρο πραγματικού χρόνου με έναν από τους εξής τρόπους:

• Χρήση της εμπειρίας "Λήψη συμβάντων "
• Χρήση της καρτέλας προελεύσεων της Microsoft

Εμπειρία εκκίνησης της λειτουργίας "Λήψη συμβάντων"

1. Μεταβείτε στην εμπειρία ευφυΐας σε πραγματικό χρόνο στο Microsoft Fabric. Επιλέξτε Microsoft Fabric στην αριστερή γραμμή περιήγησης και επιλέξτε Ευφυΐα σε πραγματικό χρόνο.

   

2. Επιλέξτε Διανομέας σε πραγματικό χρόνο στην αριστερή γραμμή περιήγησης.

   

3. Στην κεντρική σελίδα "Πραγματικός χρόνος", επιλέξτε + Λήψη συμβάντων στην επάνω δεξιά γωνία της σελίδας.

   

Χρησιμοποιήστε οδηγίες από την ενότητα Προσθήκη Azure My Βάση δεδομένων SQL CDC ως προέλευσης.

Καρτέλα προελεύσεων της Microsoft

1. Στο Κέντρο πραγματικού χρόνου, μεταβείτε στην καρτέλα προελεύσεων της Microsoft.

2. Στην αναπτυσσόμενη λίστα Προέλευση, επιλέξτε Azure MySQL DB (CDC).

3. Για τη Συνδρομή, επιλέξτε μια συνδρομή Azure που διαθέτει την ομάδα πόρων με τον λογαριασμό σας Azure My Βάση δεδομένων SQL.

4. Για την Ομάδα πόρων, επιλέξτε μια ομάδα πόρων που διαθέτει τη βάση δεδομένων.

5. Στο στοιχείο Περιοχή, επιλέξτε μια θέση όπου βρίσκεται η βάση δεδομένων σας.

6. Τώρα, μετακινήστε το ποντίκι πάνω από το όνομα της προέλευσης Azure MySQL DB CDC που θέλετε να συνδεθείτε στο Κέντρο πραγματικού χρόνου στη λίστα βάσεων δεδομένων και επιλέξτε το κουμπί Σύνδεση, ή επιλέξτε ... (αποσιωπητικά) και, στη συνέχεια, επιλέξτε το κουμπί Σύνδεση.

   

   Για να ρυθμίσετε τις παραμέτρους των πληροφοριών σύνδεσης, χρησιμοποιήστε τα βήματα από την ενότητα Προσθήκη Azure MySQL DB CDC ως προέλευσης . Παραλείψτε το πρώτο βήμα επιλογής του Azure MySQL DB CDC ως τύπο προέλευσης στον οδηγό Λήψη συμβάντων.

Προσθέστε το Azure My Βάση δεδομένων SQL CDC ως προέλευση

1. Στην οθόνη Επιλογή προέλευσης δεδομένων, επιλέξτε MySQL DB (CDC).

   

2. Στη σελίδα Σύνδεση, επιλέξτε Μετάβαση στον πόρο για να μεταβείτε στη βάση δεδομένων Azure PostgreSQL. Σημειώστε το όνομα του διακομιστή στη σελίδα Επισκόπηση . Έχει την ακόλουθη μορφή: mysqlserver.mysql.database.azure.com.

   

3. Στη σελίδα Σύνδεση, επιλέξτε Νέα σύνδεση.

   

4. Στην ενότητα ρυθμίσεις Σύνδεση ion, κάντε τα εξής βήματα:

   1. Στο πεδίο Διακομιστής, εισαγάγετε το URI για τον διακομιστή Azure MySQL.

   2. Στο πεδίο Βάση δεδομένων, εισαγάγετε το όνομα της βάσης δεδομένων σας.

      

5. Στην ενότητα Σύνδεση διαπιστευτηρίων, κάντε τα εξής βήματα:

   1. Για Σύνδεση ion, επιλέξτε εάν υπάρχει μια υπάρχουσα σύνδεση στη βάση δεδομένων MySQL. Εάν όχι, διατηρήστε την προεπιλεγμένη τιμή: Δημιουργία νέας σύνδεσης.

   2. Για το είδος ελέγχου ταυτότητας, επιλέξτε Βασικός. Προς το παρόν, υποστηρίζεται μόνο βασικός έλεγχος ταυτότητας.

   3. Εισαγάγετε τιμές για το Όνομα χρήστη και τον Κωδικό πρόσβασης.

   4. Καθορίστε αν θέλετε να χρησιμοποιήσετε μια κρυπτογραφημένη σύνδεση.

   5. Επιλέξτε Σύνδεση.

      

6. Πίσω στη σελίδα Σύνδεση, κάντε τα εξής βήματα:

   1. Εισαγάγετε το όνομα του πίνακα.
   2. Εισαγάγετε το αναγνωριστικό διακομιστή.
   3. Εισαγάγετε τον αριθμό θύρας ή διατηρήστε την προεπιλεγμένη τιμή.

7. Στην ενότητα Λεπτομέρειες του Stream στα δεξιά, κάντε τα εξής βήματα:

   1. Επιλέξτε Χώρος εργασίας Fabric όπου θέλετε να αποθηκεύσετε αυτήν τη σύνδεση και το eventstream που δημιουργεί ο οδηγός.

   2. Εισαγάγετε ένα όνομα για την κυκλοφορία του συμβάντος.

   3. Το όνομα της ροής στο Κέντρο πραγματικού χρόνου δημιουργείται αυτόματα για εσάς.

      

8. Τώρα, επιλέξτε Επόμενο στο κάτω μέρος της σελίδας.

9. Στην ενότητα Έλεγχος και δημιουργία, εξετάστε τις ρυθμίσεις και επιλέξτε Δημιουργία προέλευσης.

   

Προβολή λεπτομερειών ροής δεδομένων

1. Στη σελίδα Αναθεώρηση και δημιουργία, εάν επιλέξετε Άνοιγμα eventstream, ο οδηγός ανοίγει το eventstream που δημιούργησε για εσάς με το επιλεγμένο Azure MySQL DB CDC ως προέλευση. Για να κλείσετε τον οδηγό, επιλέξτε Κλείσιμο ή X* στην επάνω δεξιά γωνία της σελίδας.

   

2. Στο Κέντρο πραγματικού χρόνου, μεταβείτε στην καρτέλα Ροές δεδομένων του Κέντρου πραγματικού χρόνου. Ανανεώστε τη σελίδα. Θα πρέπει να δείτε τη ροή δεδομένων που δημιουργήθηκε για εσάς. Για λεπτομερή βήματα, ανατρέξτε στο θέμα Προβολή λεπτομερειών των ροών δεδομένων στο Κέντρο πραγματικού χρόνου Fabric.

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

Για να μάθετε σχετικά με την κατανάλωση ροών δεδομένων, ανατρέξτε στα παρακάτω άρθρα:

• Επεξεργασία ροών δεδομένων
• Ανάλυση ροών δεδομένων
• Ορισμός ειδοποιήσεων σε ροές δεδομένων