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
REPLICATIONiBYPASSRLS— odczytuje wszystkie wiersze replikowanych tabel z pominięciem polityk RLS. Traktuj jej hasło jak kluczservice_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.