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

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

Η σύνδεση προέλευσης Postgre Βάση δεδομένων SQL Αλλαγή δεδομένων (CDC) για τις ροές συμβάντων Microsoft Fabric σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων PostgreSQL. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα.

Σημείωμα

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

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

• Αποκτήστε πρόσβαση στον premium χώρο εργασίας Fabric με δικαιώματα Συμβάλλοντα ή παραπάνω.

• Καταχωρημένη πρόσβαση χρήστη στη βάση δεδομένων PostgreSQL.

• Το CDC ενεργοποιείται στη βάση δεδομένων PostgreSQL.

  Εάν έχετε τη Βάση δεδομένων Azure για PostgreSQL, ακολουθήστε τα βήματα στην επόμενη ενότητα για να ενεργοποιήσετε το CDC. Για λεπτομερείς πληροφορίες, ανατρέξτε στο θέμα Λογική αναπαραγωγή και λογική αποκωδικοποίηση - Βάση δεδομένων Azure για PostgreSQL - Ευέλικτος διακομιστής.

  Για άλλες βάσεις δεδομένων PostgreSQL, ανατρέξτε στο θέμα Σύνδεση Debezium για PostgreSQL :: Τεκμηρίωση debezium.

Σημείωμα

Δεν υποστηρίζεται cdc πολλών πινάκων.

Ενεργοποίηση του CDC στη βάση δεδομένων Azure για PostgreSQL

Για να ενεργοποιήσετε το CDC στη βάση δεδομένων Azure για PostgreSQL, ακολουθήστε αυτά τα βήματα με βάση τον τύπο ανάπτυξής σας.

Βάση δεδομένων Azure για έναν μόνο διακομιστή PostgreSQL

1. Μεταβείτε στη σελίδα αναπαραγωγής στην πύλη Azure.

2. Αλλάξτε τον κανόνα αναπαραγωγής σε Λογικό.

   

Βάση δεδομένων Azure για Ευέλικτο διακομιστή PostgreSQL

1. Στη βάση δεδομένων Azure για PostgreSQL ευέλικτη σελίδα διακομιστή στην πύλη Azure, επιλέξτε Παράμετροι διακομιστή στο μενού περιήγησης.

2. Στη σελίδα παραμέτρων διακομιστή:

   • Ορίστε wal_level σε λογική.

   • Ενημερώστε το max_worker_processes σε τουλάχιστον 16.

     

3. Αποθηκεύστε τις αλλαγές και επανεκκινήστε τον διακομιστή.

4. Επιβεβαιώστε ότι η βάση δεδομένων Azure για PostgreSQL ευέλικτη παρουσία διακομιστή επιτρέπει την κυκλοφορία δημόσιου δικτύου.

5. Εκχωρήστε δικαιώματα αναπαραγωγής στον διαχειριστή, εκτελώντας την ακόλουθη πρόταση SQL.

   ALTER ROLE <admin user> WITH REPLICATION;
   

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

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

   

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

   

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

   

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

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

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

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

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

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

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

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

   

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

Προσθήκη βάσης δεδομένων Azure για Το CDC PostgreSQL ως προέλευση

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

   

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

   

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

   

4. Στην ενότητα ρυθμίσεις Σύνδεση ion, εισαγάγετε τις ακόλουθες πληροφορίες.

   • Διακομιστής: Η διεύθυνση διακομιστή της βάσης δεδομένων PostgreSQL, για παράδειγμα , my-pgsql-server.postgres.database.azure.com.

   • Βάση δεδομένων: Το όνομα της βάσης δεδομένων, για παράδειγμα , my_database.

     

5. Κάντε κύλιση προς τα κάτω και στην ενότητα διαπιστευτήρια Σύνδεση ion, ακολουθήστε αυτά τα βήματα.

   1. Για το όνομα Σύνδεση ion, πληκτρολογήστε ένα όνομα για τη σύνδεση.

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

      Σημείωμα

      Προς το παρόν, οι ροές συμβάντων Fabric υποστηρίζουν μόνο βασικό έλεγχο ταυτότητας.

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

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

      

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

   1. Για τον πίνακα, εισαγάγετε ένα όνομα πίνακα.

   2. Για τη Θύρα, εισαγάγετε τον αριθμό θύρας ή αφήστε την προεπιλεγμένη τιμή: 5432.

   3. Για όνομα eventstream, πληκτρολογήστε ένα όνομα για το eventstream. Ο οδηγός δημιουργεί μια ροή συμβάντων με το επιλεγμένο Postgre Βάση δεδομένων SQL CDC ως προέλευση.

   4. Το όνομα Stream δημιουργείται αυτόματα για εσάς με την προσάρτηση του -stream στο όνομα της ροής συμβάντος. Αυτή η ροή εμφανίζεται στην καρτέλα Ροές δεδομένων του Κέντρου πραγματικού χρόνου όταν ολοκληρωθεί ο οδηγός.

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

      

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

   

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

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

   

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

   

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

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

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