480+ Blueprints, ready to build.

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

17 Cloud

AI Business Cloud Core Data Infrastructure

45 Blueprints

Sort by:

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.

Automatically Ship Workflow and System Logs to AWS CloudWatch

Ship Kestra workflow and system logs to AWS CloudWatch on a daily schedule for centralized monitoring, auditing, and observability.

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.

AWS ECR CI/CD Build and Push Docker Images to AWS Elastic Container Registry

Build a Docker image and push it to AWS ECR using short-lived token authentication, all in one Kestra flow.

Azure Batch Cost Guardrail with Storage Lifecycle Cleanup

Query Azure Monitor for idle Batch pool nodes, scale the pool down automatically when it is over-provisioned, and purge cold scratch blobs on the same hourly run.

Chain Blob Storage, an Azure Function, Service Bus, and Data Factory

Chain Blob Storage, an Azure Function, Service Bus, and Data Factory in one execution, from file arrival to warehouse load, with a Teams notification.

Curate GCS Files into BigQuery with Python

Download a file from Google Cloud Storage, clean it with Python and pandas, and load the curated result into BigQuery on a schedule.

Deploy an Azure Function from Git and Chain a Logic App

Clone an Azure Function from Git, deploy it with the Azure CLI, then chain an Azure Logic App and fetch its result.

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.

Fan Out S3 Object Events to Lambda and SNS

React to new Amazon S3 objects and fan out by file type, routing JSON to AWS Lambda and everything else to SNS, with a Slack notification.

Glue ETL, Athena Validation, DynamoDB Cache

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

Google Cloud CI/CD, Build and Push Docker Images to Google Cloud Artifact Registry

Build a Docker image and push it to Google Cloud Artifact Registry using short-lived OAuth credentials.

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.

Load GCS Files into BigQuery on Arrival

Auto-load files into BigQuery the moment they land in a Google Cloud Storage bucket, then archive each object so it never re-triggers.

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.

Monitor Azure Event Hub Volume and Alert on a Silent Drop

Poll an Azure Event Hub on a schedule and page on-call automatically when the event volume in the window drops below the expected floor.

Multi-cloud deployment pipeline with Docker, ngrok, GCP Cloud Run, and Azure Container Apps

Build a Docker image from a GitHub repo and deploy it to local, GCP Cloud Run, or Azure Container Instances from one declarative flow.

Process a file from S3 only if it changed since the last execution

Reprocess an S3 file only when it changed, on a schedule, using Python and boto3.

Publish Application and System Events to AWS EventBridge for Event-Driven Architectures

Publish custom application and system events to AWS EventBridge using inline definitions or bulk JSON payloads.

Purge Cloudflare Cache on Deployment Healthy

Purge the Cloudflare zone cache the moment a deploy goes healthy, verify the site, and notify Slack.

Run a task on an on-demand Databricks cluster

Spin up a Databricks cluster on demand, run a Spark job, then tear the cluster down automatically.

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.

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.

Weekly Azure Blob Backup Archive with Gated Expiry Cleanup

List a container, copy each blob into a dated archive prefix, notify Slack, then pause before deleting anything past retention, so only the destructive step waits on a named reviewer.