Dodawanie źródła cdC bazy danych PostgreSQL do strumienia zdarzeń (wersja zapoznawcza)

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.

Ważne

Ulepszone możliwości strumieni zdarzeń sieci Szkieletowej są obecnie dostępne w wersji zapoznawczej.

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 Sieć szkieletowa Premium 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).

Uwaga

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

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;
   

Dodawanie usługi Azure Database for PostgreSQL CDC jako źródła

1. Wybierz pozycję Strumień zdarzeń , aby utworzyć nowy strumień zdarzeń. Upewnij się, że opcja Rozszerzone możliwości (wersja zapoznawcza) jest włączona.

   

2. Na następnym ekranie wybierz pozycję Dodaj źródło zewnętrzne.

   

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

1. Na ekranie Wybieranie źródła danych wybierz pozycję Azure DB for PostgreSQL (CDC).

   

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

   

3. 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.

     

4. 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.

      

5. 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.

      

6. Na ekranie Przeglądanie i tworzenie przejrzyj podsumowanie, a następnie wybierz pozycję Dodaj.

   

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

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 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