Home
Blueprints

Run DDL queries and load data to Postgres

Build a CSV-to-Postgres ETL pipeline with Kestra. Download a remote file, run DDL to create the table, and bulk load rows with CopyIn, all in declarative YAML.

More Core Blueprints

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

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

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

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

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

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

More Data Blueprints

Build an ETL Pipeline with Airbyte Cloud and dbt Cloud for SaaS Analytics

Run Airbyte Cloud syncs in parallel, then trigger a dbt Cloud transformation job once the data lands.

Data

Generate and Execute SQL Queries from Natural Language Using OpenAI GPT-4o

Turn plain-English questions into PostgreSQL queries with OpenAI GPT-4o, grounded on schema only so no row data ever leaves your database.

AIData

AI Document Data Extraction: Parse PDFs and Web Pages into Structured JSON with OpenAI

Turn any PDF, web page, or text document into structured JSON with OpenAI GPT-4o, then store the results in PostgreSQL and Slack.

AIData

Run a Scheduled ETL Sync with Airbyte Cloud

Trigger an Airbyte Cloud connection sync on a recurring schedule so your data lands fresh without manual runs.

Data

AI-Powered Inventory Demand Forecasting, Auto-Generate Purchase Orders with OpenAI

Forecast 7-day demand with OpenAI GPT-4o, auto-generate purchase orders for stockout-risk SKUs, and log them to PostgreSQL every 6 hours.

AIBusinessData

Build an ETL Pipeline with Airbyte Cloud and dbt Core for SaaS Analytics

Ingest Salesforce, Google Analytics, and Facebook Ads in parallel with Airbyte Cloud, then transform with dbt in one orchestrated ELT pipeline.

Data

New to Kestra?

Use blueprints to kickstart your first workflows.

Get Started