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

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

  • Άρθρο

Αυτό το άρθρο σάς δείχνει πώς μπορείτε να προσθέσετε μια προέλευση PostgreSQL Database Change Data Capture (CDC) σε μια ροή συμβάντων.

Η σύνδεση προέλευσης PostgreSQL Database Change Data Capture (CDC) για τις ροές συμβάντων Microsoft Fabric σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων PostgreSQL. Προς το παρόν, η Καταγραφή δεδομένων αλλαγής βάσης δεδομένων PostgreSQL (CDC) υποστηρίζεται από τις ακόλουθες υπηρεσίες όπου είναι δυνατή η δημόσια πρόσβαση στις βάσεις δεδομένων:

  • Βάση δεδομένων Azure για PostgreSQL
  • Amazon RDS για PostgreSQL
  • Amazon Aurora PostgreSQL
  • GOOGLE Cloud SQL για PostgreSQL

Μόλις προστεθεί η προέλευση CDC της βάσης δεδομένων PostgreSQL στο eventstream, καταγράφει τις αλλαγές σε επίπεδο γραμμών στους καθορισμένους πίνακες. Αυτές οι αλλαγές μπορούν, στη συνέχεια, να υποβληθούν σε επεξεργασία σε πραγματικό χρόνο και να σταλούν σε διαφορετικούς προορισμούς για περαιτέρω ανάλυση.

Σημείωμα

Αυτή η προέλευση δεν υποστηρίζεται στις ακόλουθες περιοχές των εκχωρημένων πόρων του χώρου εργασίας σας: Δυτικές Η.Π.Α.3, Δυτική Ελβετία.

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

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

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

  • Η βάση δεδομένων PostgreSQL πρέπει να είναι προσβάσιμη στο κοινό και να μην βρίσκεται πίσω από ένα τείχος προστασίας ή να είναι ασφαλής σε ένα εικονικό δίκτυο.

  • Το CDC έχει ενεργοποιηθεί στη βάση δεδομένων Και τους πίνακες PostgreSQL.

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

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

  • Εάν δεν έχετε ένα eventstream, δημιουργήστε ένα eventstream.

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

Αυτή η ενότητα χρησιμοποιεί βάση δεδομένων Azure για PostgreSQL ως παράδειγμα.

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

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

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

    • Ορίστε wal_level σε λογική.
    • Ενημερώστε το max_worker_processes σε τουλάχιστον 16.

    Ένα στιγμιότυπο οθόνης ενεργοποίησης του CDC για μια ευέλικτη ανάπτυξη διακομιστή.

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

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

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

    ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;

Εκκίνηση του Οδηγού επιλογής προέλευσης δεδομένων

Εάν δεν έχετε προσθέσει ακόμα κάποια προέλευση στο eventstream, επιλέξτε Χρήση πλακιδίου εξωτερικής προέλευσης .

Στιγμιότυπο οθόνης που εμφανίζει την επιλογή

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

Στιγμιότυπο οθόνης που εμφανίζει την επιλογή του μενού  

Στη σελίδα Επιλογή προέλευσης δεδομένων, αναζητήστε και επιλέξτε Σύνδεση στο πλακίδιο PostgreSQL DB (CDC).

Στιγμιότυπο οθόνης που εμφανίζει την επιλογή του Azure DB για PostgreSQL (CDC) ως τύπο προέλευσης στον Οδηγό λήψης συμβάντων.

Ρύθμιση παραμέτρων και σύνδεση στο CDC βάσης δεδομένων PostgreSQL

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

    Στιγμιότυπο οθόνης που εμφανίζει τη σελίδα Σύνδεση για μια βάση δεδομένων Azure PostgreSQL με επισημασμένη τη Νέα σύνδεση σύνδεσης.

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

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

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

      Στιγμιότυπο οθόνης που εμφανίζει την ενότητα Ρυθμίσεις σύνδεσης για τη σύνδεση βάσης δεδομένων Azure PostgreSQL.

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

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

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

      Σημείωμα

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

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

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

      Στιγμιότυπο οθόνης που εμφανίζει την ενότητα Διαπιστευτήρια σύνδεσης για τη σύνδεση βάσης δεδομένων Azure PostgreSQL.

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

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

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

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

      Στιγμιότυπο οθόνης που εμφανίζει τη σελίδα Σύνδεση συμπληρωμένη για τη σύνδεση βάσης δεδομένων Azure PostgreSQL.

  5. Στη σελίδα Αναθεώρηση + σύνδεση, εξετάστε τη σύνοψη και, στη συνέχεια, επιλέξτε Προσθήκη.

    Στιγμιότυπο οθόνης που εμφανίζει τη σελίδα

Σημείωμα

Ο μέγιστος αριθμός των προελεύσεων και προορισμών για ένα eventstream είναι 11.

Προβολή ενημερωμένης ροής συμβάντων

  1. Μπορείτε να δείτε την προέλευση του CDC βάσης δεδομένων PostgreSQL να προστίθεται στη ροή συμβάντων σας σε λειτουργία επεξεργασίας.

    Ένα στιγμιότυπο οθόνης της προέλευσης ροής PostgreSQL DB CDC σε προβολή επεξεργασίας.

  2. Για να υλοποιήσετε αυτή την προέλευση PostgreSQL DB CDC που προστέθηκε πρόσφατα, επιλέξτε Δημοσίευση. Αφού ολοκληρώσετε αυτά τα βήματα, η προέλευση PostgreSQL DB CDC είναι διαθέσιμη για απεικόνιση σε ζωντανή προβολή.

    Ένα στιγμιότυπο οθόνης της προέλευσης ροής PostgreSQL DB CDC σε ζωντανή προβολή.

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

Άλλες συνδέσεις: