Dodawanie źródła cdC bazy danych PostgreSQL do strumienia zdarzeń

W tym artykule pokazano, jak dodać źródło przechwytywania zmian danych bazy danych PostgreSQL (CDC) do strumienia zdarzeń.

Łącznik źródłowy przechwytywania zmian danych bazy danych PostgreSQL (CDC) dla strumieni zdarzeń usługi Microsoft Fabric umożliwia przechwycenie migawki bieżących danych w bazie danych PostgreSQL. Następnie łącznik monitoruje i rejestruje wszelkie przyszłe zmiany na poziomie wiersza w tych danych. Po przechwyceniu zmian w strumieniu zdarzeń można przetwarzać te dane CDC w czasie rzeczywistym i wysyłać je do różnych miejsc docelowych w sieci szkieletowej w celu dalszego przetwarzania lub analizy.

Uwaga

To źródło nie jest obsługiwane w następujących regionach pojemności obszaru roboczego: Zachodnie stany USA3, Szwajcaria Zachodnia.

Wymagania wstępne

• Dostęp do obszaru roboczego w trybie licencji pojemności sieci szkieletowej (lub) w trybie licencji próbnej z uprawnieniami współautora lub wyższymi uprawnieniami.

• Zarejestrowany dostęp użytkownika w bazie danych PostgreSQL.

• Baza danych PostgreSQL musi być publicznie dostępna i nie znajdować się za zaporą lub być zabezpieczona w sieci wirtualnej.

• Usługa CDC włączona w bazie danych PostgreSQL i tabelach.

  Jeśli masz usługę Azure Database for PostgreSQL, wykonaj kroki opisane w następnej sekcji, aby włączyć usługę CDC. Aby uzyskać szczegółowe informacje, zobacz Replikacja logiczna i dekodowanie logiczne — Azure Database for PostgreSQL — serwer elastyczny.

  Inne bazy danych PostgreSQL można znaleźć w temacie Debezium connector for PostgreSQL :: Debezium Documentation (Łącznik debezium dla bazy danych PostgreSQL:: Dokumentacja rozwiązania Debezium).

• Jeśli nie masz strumienia zdarzeń, utwórz strumień zdarzeń.

Włączanie usługi CDC w usłudze Azure Database for PostgreSQL

Aby włączyć usługę CDC na serwerze elastycznym usługi Azure Database for PostgreSQL, wykonaj następujące kroki:

1. Na stronie Azure Database for PostgreSQL — serwer elastyczny w witrynie Azure Portal wybierz pozycję Parametry serwera w menu nawigacji.

2. Na stronie Parametry serwera:

   • Ustaw wal_level na wartość logiczną.
   • Zaktualizuj max_worker_processes do co najmniej 16.

   

3. Zapisz zmiany i uruchom ponownie serwer.

4. Upewnij się, że wystąpienie serwera elastycznego usługi Azure Database for PostgreSQL zezwala na ruch sieciowy publiczny.

5. Udziel uprawnień replikacji użytkownika administratora, uruchamiając następującą instrukcję SQL. Jeśli chcesz użyć innego konta użytkownika, aby połączyć bazę danych PostgreSQL w celu pobrania usługi CDC, upewnij się, że użytkownik jest właścicielem tabeli.

   ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
   

Uruchamianie kreatora Wybieranie źródła danych

Jeśli jeszcze nie dodano żadnego źródła do strumienia zdarzeń, wybierz pozycję Użyj kafelka zewnętrznego źródła .

Jeśli dodasz źródło do już opublikowanego strumienia zdarzeń, przełącz się do trybu edycji , wybierz pozycję Dodaj źródło na wstążce, a następnie wybierz pozycję Źródła zewnętrzne.

 

Na stronie Wybieranie źródła danych wyszukaj i wybierz pozycję Połącz na kafelku Azure DB for PostgreSQL (CDC).

Konfigurowanie i nawiązywanie połączenia z usługą Azure Database for PostgreSQL CDC

1. Na stronie Łączenie wybierz pozycję Nowe połączenie.

   

2. W sekcji Ustawienia połączenia wprowadź następujące informacje.

   • Serwer: adres serwera bazy danych PostgreSQL, na przykład my-pgsql-server.postgres.database.azure.com.

   • Baza danych: nazwa bazy danych, na przykład my_database.

     

3. Przewiń w dół i w sekcji Poświadczenia połączenia wykonaj następujące kroki.

   1. W polu Nazwa połączenia wprowadź nazwę połączenia.

   2. W polu Rodzaj uwierzytelniania wybierz pozycję Podstawowa.

      Uwaga

      Obecnie strumienie zdarzeń sieci szkieletowej obsługują tylko uwierzytelnianie podstawowe .

   3. Wprowadź nazwę użytkownika i hasło dla bazy danych.

   4. Wybierz pozycję Połącz.

      

4. Teraz na stronie Połącz wykonaj następujące kroki:

   1. W przypadku tabeli wprowadź nazwę tabeli.

   2. W polu Port wprowadź numer portu lub pozostaw wartość domyślną: 5432.

   3. Wybierz pozycję Dalej w dolnej części strony.

      

5. Na stronie Przeglądanie i łączenie przejrzyj podsumowanie, a następnie wybierz pozycję Dodaj.

   

Uwaga

Maksymalna liczba źródeł i miejsc docelowych dla jednego strumienia zdarzeń wynosi 11.

Wyświetlanie zaktualizowanego strumienia zdarzeń

1. Źródło CDC bazy danych PostgreSQL zostało dodane do strumienia zdarzeń w trybie edycji.

   

2. Aby zaimplementować to nowo dodane źródło CDC bazy danych PostgreSQL, wybierz pozycję Publikuj. Po wykonaniu tych kroków źródło CDC bazy danych PostgreSQL jest dostępne do wizualizacji w widoku na żywo.

   

Powiązana zawartość

Inne łączniki:

• Strumienie danych Amazon Kinesis
• Azure Cosmos DB
• Azure Event Hubs
• Azure Service Bus
• Azure IoT Hub
• Przechwytywanie zmian danych w usłudze Azure SQL Database (CDC)
• Confluent Kafka
• Niestandardowy punkt końcowy
• Google Cloud Pub/Sub
• Usługa CDC bazy danych MySQL
• CdC bazy danych PostgreSQL
• Dane przykładowe
• Zdarzenia usługi Azure Blob Storage
• Zdarzenie obszaru roboczego sieci szkieletowej