480+ Blueprints, ready to build.

The first step is always the hardest. Search or browse to kick-start your next flow.

Realtime & Streaming

AI Business Cloud Core Data Infrastructure

14 Blueprints

Sort by:

Alert finance in Slack on new high-value SAP HANA transactions

Poll SAP HANA for new high-value transactions and alert the finance team in Slack in near real time.

Event-driven workflow based on a Snowflake query condition

Run a Kestra workflow automatically whenever a Snowflake query returns matching rows.

Extract data from a REST API and send it to a Kafka topic using the Kafka

Fetch data from a REST API and publish it to a Kafka topic with Kestra.

Fan Out Pipeline Completion Events to NATS Subscribers

Refresh a daily sales aggregate in Postgres, then publish three differently-shaped completion events to independent NATS subjects for fulfillment, analytics, and audit teams.

Incremental Oracle order sync with a polling trigger

Poll Oracle for new orders, enrich them with customer data, claim the exact batch, and MERGE it into a mart table so replays never duplicate.

Monitor MySQL DELETE events in real time with Debezium and send Slack alerts

Stream MySQL change data capture events with Debezium and fire a Slack alert the instant a row is deleted.

Notify Slack on new Vertica rows

Watch a Vertica table for new rows, post one batched Slack alert, then mark only the alerted ids processed.

Process Pub/Sub Messages into Postgres in Real Time

Stream Google Cloud Pub/Sub messages into Postgres in real time, one governed Kestra execution per message, with safe upserts and Teams alerts.

Publish Pipeline Completion Events to Pub/Sub

After a scheduled BigQuery aggregation, publish a completion event to a Google Cloud Pub/Sub topic so downstream consumers and flows react.

Read a CSV file and load each row into RabbitMQ

Publish each row of a CSV file as a message to a RabbitMQ exchange with Kestra.

Real-Time Kafka Record Processing with Per-Record Executions

A realtime Kafka trigger starts one execution per record, branches on the payload, and alerts Slack on anomalies.

Use Debezium to trigger a flow whenever new entries hit a Postgres

Capture Postgres row changes with Debezium CDC, then notify Slack and process the new data in Python automatically.

Use Pulsar Realtime Trigger to push events into MySQL

Stream Apache Pulsar messages straight into MySQL in real time, one row per event.

Use Redis List Realtime Trigger to push events into Cassandra

React to every Redis List push in real time and stream the event straight into Apache Cassandra.