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.

Cloudflare Canary Deployment Blueprint

Run a controlled Cloudflare canary deployment with DNS cutover, cache purge, a human validation pause, and automatic rollback.

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.

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.

Gate a Dataproc PySpark Batch on Data Readiness

Check BigQuery for fresh source rows and submit a Dataproc Serverless PySpark batch only when the data is ready.

GCS to Dataproc to BigQuery Lakehouse Refresh

Orchestrate the GCS to Dataproc to BigQuery lakehouse chain in one flow, with a serverless PySpark transform and a gold table load.

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.

Ingest AWS Resource Metadata into Postgres Using CloudQuery for Security and Governance Analysis

Sync AWS resource metadata into Postgres with CloudQuery, then flag public S3 buckets with SQL.

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.

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.

Reconcile Multi-Zone Cloudflare DNS from a Git Manifest

Clone a Git DNS manifest and batch-apply records to each managed Cloudflare zone.

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.

Sync Cloudflare DNS from Terraform Output

Apply Terraform, then upsert the provisioned IP into Cloudflare DNS, purge the cache, and notify Slack.

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.