🚀 New! Kestra raises $3 million to grow Learn more

Home / Solutions / Blueprints

Use Debezium to trigger a flow whenever new entries hit a Postgres database, then send notification to Slack and process data in Python

Plugins Used in this Blueprints

About this blueprint

Use Debezium to trigger a flow whenever new entries hit a Postgres database, then send notification to Slack and process data in Python

This blueprint showcases how you can trigger a Flow based on Debezium data-capture pattern. Every time new entries reach the database, the flow is triggered. It sends a notification through Slack with the number of rows ingested and then execute a Python script that read the corresponding data in json.

This blueprint can be reproduced with the following docker-compose.yml setup

services:

  db:
    image: debezium/postgres:latest
    restart: always
    environment:
      POSTGRES_PASSWORD: example
    ports:
      - 5433:5432

  adminer:
    image: adminer
    restart: always
    ports:
      - 8082:8080

You can access localhost:8082 to create and edit databases or tables via the adminer interface. The database is accessible on 5433 port.

Note that depending of your database installation, you might need to change the pluginName property of the debezium plugin. Other options can be seen in corresponding documentation.

New to Kestra?

Use blueprints to kickstart your first workflows.