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

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

High-Performance Computing, Run Parallel Python Workloads on AWS Batch with ECS Fargate

Provision AWS Batch on ECS Fargate with Terraform, then run parallel Python workloads on it from one Kestra flow.

CloudCoreInfrastructure

Glue ETL, Athena Validation, DynamoDB Cache

Run a Glue ETL job, validate the output with Athena, then cache the headline KPI in DynamoDB.

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

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

More Core Blueprints

Convert Natural Language Prompts to Structured Todoist Tasks with Deepseek AI

Turn plain-English to-do prompts into structured Todoist tasks using DeepSeek AI structured output and a ForEach HTTP loop.

AIBusinessCore

Advanced Scheduling Automation, Run Tasks Only on Business Days by Country

Run scheduled tasks only on business days using a Python calendar check that skips weekends and country-specific public holidays.

Core

Export Kestra audit logs as a CSV file and send out via Email.

Ship Kestra audit logs on a weekly schedule, convert them to CSV, and email the report automatically.

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

Single-tenant Argo CD rollout with waves, guarded sync strategy, and Status-based readiness gates

Roll out Argo CD Application updates across a single-tenant fleet in safe, sequential waves gated on real sync and health status.

CoreInfrastructure

Auto Resubmit Failed Executions with Loop Protection

Automatically re-execute FAILED or WARNING executions via a Flow trigger and Subflow, with label based loop protection.

Core

New to Kestra?

Use blueprints to kickstart your first workflows.

Get Started