480+ Blueprints, ready to build.

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

Core Data
or
AI Business Cloud Core Data Infrastructure

10 Blueprints

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.

ForEach icon
Set icon
Core Data
Build governed analytics assets with DuckDB using data lineage, staging, and mart layers

Build governed staging and mart data assets with DuckDB while Kestra captures end-to-end lineage automatically.

Query icon
Table icon
ForEach icon
duckdb icon
Core Data
Cache a computationally expensive task in an ETL pipeline using the taskCache property

Cache an expensive extract task with taskCache and join the data in DuckDB to compute profit per transaction.

Download icon
Query icon
Core Data
Data Engineering Pipeline example, Getting started with Kestra

An end-to-end extract, transform, load pipeline that pulls JSON from an API, cleans it in Python, and aggregates it with DuckDB.

Download icon
Script icon
Queries icon
Core Data
Download a CSV from a URL and Bulk-Load It into PostgreSQL with COPY

Download a CSV from any public URL and bulk-load it into PostgreSQL using the fast native COPY protocol.

Download icon
CsvToIon icon
IonToCsv icon
CopyIn icon
Core Data
Fetch data from Apache Druid and transform it in Python with Pandas

Query Apache Druid with SQL, export to CSV, and analyze the results in Python with Pandas.

Query icon
IonToCsv icon
Script icon
Core Data
GPU-accelerated Python script with Modal

Run a GPU-accelerated Python script on Modal's serverless cloud, orchestrated end to end with Kestra.

WorkingDirectory icon
Clone icon
ModalCLI icon
Core Data
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.

Script icon
Docker icon
ForEach icon
Core Data
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.

Script icon
Core Data
Run DDL queries and load data to Postgres

Download a remote CSV, create the target table with DDL, and bulk load it into Postgres on a single Kestra flow.

Download icon
Query icon
CopyIn icon
Core Data