Home
Blueprints

Download a zip file, unzip it and upload all files in parallel to AWS S3

Download a zip archive, unzip it, and upload every extracted file to Amazon S3 concurrently with Kestra. Declarative YAML, parallel tasks, no boilerplate.

More Cloud Blueprints

Autoscale EMR Serverless Spark on a CloudWatch Backlog

Watch a CloudWatch backlog metric and fire an EMR Serverless Spark job only when work is pending.

CloudData

Extract data, mask sensitive columns using DuckDB and load it to BigQuery

Extract CSV data, mask PII columns with DuckDB SQL, then load the anonymized result into BigQuery.

CloudData

Microservice orchestration: invoke multiple AWS Lambda functions in parallel

Invoke multiple AWS Lambda functions in parallel, target specific versions and aliases, pass custom payloads, and parse the JSON results.

Cloud

Stream JSON and Application Events to AWS Kinesis Data Streams at Scale

Publish inline events and API-sourced JSON to AWS Kinesis Data Streams in bulk, with automatic ION conversion.

Cloud

Ansible Scalability, Deploy Configuration Files to Multiple Servers at Scale

Provision AWS EC2 servers and deploy configuration files across all of them at scale with Ansible.

CloudInfrastructure

Stream Kestra audit logs from Kafka to BigQuery

Stream Kestra audit logs from a Kafka topic into Google BigQuery for analytics, monitoring, and compliance reporting.

Cloud

More Core Blueprints

Fetch logs from all pods in a Kubernetes namespace

Collect logs from every pod in a Kubernetes namespace within a time window, plus namespace events, in one run.

CoreInfrastructure

Route AI Requests to the Optimal Model Based on Query Classification

Classify every prompt with OpenAI, then route it to the best-fit LLM across Anthropic, Gemini, Perplexity, and OpenAI for quality and cost.

AICore

Govern cloud infrastructure with Kestra Assets: automated S3 bucket provisioning by team

Provision one Amazon S3 bucket per team and register each as a governed AWS_BUCKET asset in Kestra.

CoreInfrastructure

Infrastructure Automation workflow example: Getting started with Kestra

Build a Docker image, run it, and provision files with Terraform in one declarative Kestra pipeline.

CoreInfrastructure

Layered Error Handling with Retries and KV Context

A deliberately failing flow that demonstrates block level errors, flow level errors, automatic retries, and KV context for alerting flows.

Core

Reduce LLM API Costs with a Redis Semantic Cache for Repeated Questions

Cache LLM answers in Redis so repeated questions are served instantly and OpenAI is only called on a genuine cache miss.

AICore

New to Kestra?

Use blueprints to kickstart your first workflows.

Get Started