Build exactly-once processing pipelines for Postgres changes without additional infrastructure. Learn about Sequin’s native stream with an HTTP interface.
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 a Sequin 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.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 Sequin Stream.Messages tab
products
table to your stream.Receive messages
curl
command. You’ll receive a response with a single message from the initial backfill of the products
table:curl
command again, you’ll receive a different message. That’s because Sequin Stream only re-delivers messages after the visibility timeout expires.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:?batch_size=10
parameter to receive multiple messages at once, like so:Update a product's price
Change a product's name
Delete a product
products
table