Home
Blueprints

Data Engineering Pipeline example, Getting started with Kestra

Build a complete ETL pipeline in Kestra that downloads JSON from an API, filters fields in Python, and computes average price per brand with DuckDB SQL.

More Getting Started Blueprints

Business Processes workflow example: Getting started with Kestra

A human-in-the-loop vacation approval workflow that pairs a Slack approval request with an automated API submission in Kestra.

BusinessCore

Hello World Example: Getting started with Kestra

Your first Kestra flow: take a user input, pass values between tasks, and log a personalized greeting.

Core

Business Automation workflow example: Getting started with Kestra

Build a SQLite table, query it, and export the results to CSV and Excel for business stakeholders.

BusinessCore

Microservices and APIs workflow example, Getting started with Kestra

Probe an API endpoint on a schedule and fire a Slack alert the moment it stops returning HTTP 200.

Core

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

More Core Blueprints

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

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

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

Business Automation workflow example: Getting started with Kestra

Build a SQLite table, query it, and export the results to CSV and Excel for business stakeholders.

BusinessCore

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

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