Platforma

Pipelines (replikacja logiczna)

Strumieniowanie zmian wybranych tabel do innej bazy Postgres, hurtowni lub Kafki (Debezium).

Baza danych → Pipelines konfiguruje replikację logiczną: zmiany (INSERT/UPDATE/DELETE) wybranych tabel trafiają w czasie rzeczywistym do drugiej bazy Postgres, systemu CDC (Debezium → Kafka) albo hurtowni danych — bez obciążania aplikacji.

Co tworzy pipeline

  • Publikację z wybranymi tabelami.
  • Rolę z uprawnieniami REPLICATION i BYPASSRLS — odczytuje wszystkie wiersze replikowanych tabel z pominięciem polityk RLS. Traktuj jej hasło jak klucz service_role; panel pokaże je tylko raz.

Odbiorca Postgres

-- na docelowej bazie (tabele o tej samej strukturze muszą istnieć)
create subscription hostbase_sub
  connection 'host=db-<ref>.host.ulewicz.space port=5432 dbname=postgres user=<rola> password=<hasło> sslmode=require'
  publication <publikacja>;

Panel podaje też gotową konfigurację konektora Debezium (PostgresConnector, plugin.name=pgoutput).

Sloty replikacji

Slot przechowuje WAL, dopóki odbiorca go nie potwierdzi. Nieużywane sloty usuwaj — inaczej rośnie zajętość dysku projektu. Lista slotów z opóźnieniem jest na tej samej stronie.