XADD
Postgres changes to Redis Streams in minutes. Build real-time data pipelines with Redis and Postgres change data capture (CDC).
XADD
to build a stream. If you are want to use Redis key/values, see our Redis String quickstart.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 Redis stream: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 "Redis Configuration"
host.docker.internal
products-stream
)Test the connection
Create the sink
products
table. Then, it will receive all changes to the products
table in real-time.Click “Create Sink” to finish setting up your Redis Stream sink.Messages tab
products
table to your Redis stream.View in Redis CLI
read
events from the initial backfill of the products
table.Make some changes
products
table and see them flow to your stream.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