480+ Blueprints, ready to build.

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

Data Warehouses

AI Business Cloud Core Data Infrastructure

19 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.

ClickHouse real-time event ingestion with TTL-driven cleanup

Bulk-load real-time events into ClickHouse with asynchronous inserts, keep an hourly rollup current via a materialized view, and force TTL-based cleanup on every run.

Event-Driven SQL Server Queue Processing

Poll a SQL Server queue-style table for pending rows, flip them to processed in the same transaction, and fan out to a per-row task the moment work appears.

Event-driven workflow based on a Snowflake query condition

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

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.

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.

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.

Query data in Snowflake

Run a SQL query against your Snowflake data warehouse and capture the results in Kestra.

Query Databricks SQL and process lakehouse data with Python and Pandas

Run a Databricks SQL query against your lakehouse, export the results to CSV, and analyze them in Python with Pandas.

Scheduled SQL Server Report Emailed as a CSV Attachment

Run a daily SQL Server aggregate query, convert it to CSV, and email it as an attachment, skipping empty days and alerting Slack on failure.

Scheduled Vertica rollup exported to Amazon S3

Run a daily Vertica aggregation, guard against empty results, convert to CSV, and ship it to an S3 reporting bucket.

Snowflake ETL: load files to internal stage, copy from stage to a table and run analytical SQL queries

End-to-end Snowflake ETL with Kestra: create a database and table, stage a CSV, COPY INTO Snowflake, and run analytical SQL.

Snowflake Incremental MERGE Upsert with a Transactional Load

Stage a delta file, COPY into a staging table, and MERGE into the Snowflake target as one atomic transaction for an idempotent upsert.

Snowflake Stream Trigger to Postgres with dbt Transformations

Poll a Snowflake stream for new rows, load each batch into Postgres in parallel, run dbt transformations, and alert Slack on failure.

SQL Server CDC to Microsoft Teams via Debezium

Stream SQL Server row-level changes in real time with the Debezium SQL Server connector and alert Microsoft Teams on high-value changes, no Kafka Connect required.

SQL Server Incremental Batch Sync Between Instances

Extract changed rows from a source SQL Server table since the last KV-tracked watermark and bulk-insert them into a destination instance with chunked JDBC batches.

SQL Server Transactional MERGE Upsert with Watermark

Stage changed rows since a KV-tracked watermark, MERGE them into a target table with dedup, and advance the watermark, all inside one SQL Server transaction.

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.