480+ Blueprints, ready to build.

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

17 Data

AI Business Cloud Core Data Infrastructure

175 Blueprints

Sort by:

Add a list of strings to Redis

Reset a Redis list and push a fresh set of string values in one declarative Kestra flow.

Add multiple Redis keys in parallel from JSON input

Write many Redis keys in parallel from a single JSON input, fanning out one SET per entry.

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.

Anomaly detection using DuckDB SQL query and S3 file event trigger

Detect data anomalies in new S3 files with DuckDB SQL and email a CSV of the bad rows.

Batch-Enrich BigQuery Rows with Vertex AI

Scheduled BigQuery row enrichment with a Gemini model on Vertex AI, with concurrency control, write-back, and email alerts.

Dbt Test Gate Before Hightouch Activation with PagerDuty Alert

Build dbt models, gate on dbt test, then activate a Hightouch sync only when tests pass, paging PagerDuty when they fail.

Detect New Files in S3 and process them in Python

Trigger a Python data pipeline automatically whenever a new file lands in an Amazon S3 bucket.

Export a SAP HANA analytics view to an S3 data lake

Export a SAP HANA analytics view to CSV in an S3 data lake on a daily schedule.

Hightouch Staging-to-Production Promotion with Approval Gate

Run a staging Hightouch sync, notify Microsoft Teams, pause for human approval, then fire the production sync with a full reviewer audit trail.

Ingest data to and query data from ClickHouse

Bootstrap a ClickHouse database and table, insert rows, and run a SQL query that stores results, all in one Kestra flow.

Load a CSV into Vertica and run a columnar analytics query

Download a CSV, truncate-and-reload it into Vertica with a batch insert, then run a columnar aggregation query.

Nightly RAG Ingestion with Gemini Embeddings

Re-ingest documents nightly, embed them with Gemini, and store the vectors so a RAG app retrieves grounded context.

Process partitions in parallel in Python, report outputs and metrics

Fan out a list of data partitions and process each one in parallel with isolated Python scripts in Docker, capturing row-count and timing metrics.

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.

Register S3 JSON files as governed datasets and curate them with DuckDB

Ingest JSON from Amazon S3, unify and curate it with DuckDB, and register every step as governed dataset assets with full lineage.

Run a Python script and generate outputs, metrics and files specified with a variable

Run a parametrized Python script in Kestra that emits downloadable files, named outputs, and custom metrics.

S3 File Trigger to Postgres with dbt Transformations

Trigger on new S3 files, batch load each one into Postgres in parallel, transform with dbt, and alert Slack on failure.

Set a single mock user JSON in Redis

Generate a mock user record and write it to Redis as JSON in one declarative flow.

Store and retrieve JSON data using Redis

Set and retrieve a JSON value in Redis from a Kestra workflow using runtime inputs.

Transactional idempotent in-database ETL on SAP HANA with a row-count check

Run a transactional, idempotent SAP HANA partition reload, then verify source and target row counts match.

Transform data from CSV files with Pandas in Python containers (in parallel)

Process a list of CSV files in parallel, each in its own isolated Python and Pandas container.

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.