Stream Postgres changes to RabbitMQ in minutes. Build real-time data pipelines with RabbitMQ and Postgres change data capture (CDC).
Open RabbitMQ Management UI
Create an exchange
Create a queue
Create a binding
sequin.sequin_playground.public.products.*
sequin.<database_name>.<table_schema>.<table_name>.<action>
Create directory and start services
Alternative: Download with curl
Alternative: Clone the repository
Verify services are running
docker ps
:Up
).Open the web console
Login with default credentials
sequin_playground
with a sample dataset in the public.products
table.Let’s take a look:Navigate to Databases
Select playground database
sequin-playground
database:View contents of the products table
products
table. Run the following command:psql
command.products
table:products
table to your RabbitMQ exchange:Navigate to Sinks
Select sink type
Note "Source" configuration
sequin-playground
database is selected and all schemas and tables are included. Leave these defaults:Setup a backfill
Inital backfill
card, select the public.products
table to initate a backfill when the sink is created.Configure "RabbitMQ Configuration"
host.docker.internal
sequin
)Test the connection
Create the sink
products
table. Then, you’ll receive all changes to the products
table in real-time.Click “Create Sink” to finish setting up your RabbitMQ sink.Messages tab
products
table to RabbitMQ.View in RabbitMQ
read
events from the initial backfill of the products
table:Make some changes
products
table and see them flow through RabbitMQ.In your terminal, run the following command to insert a new row into the products
table:Update a product's price
Change a product's name
Delete a product
products
table