480+ Blueprints, ready to build.

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

AI Business Cloud Core Data Infrastructure

482 Blueprints

Sort by:

Archive Processed Output Files on a Local Filesystem Mount

Watch a local processing directory for finished output files, archive each one into a dated folder as it lands, and sweep stale .tmp scratch files left behind by interrupted runs.

Auto-Remediate a ServiceNow Incident with Ansible

Remediate a ServiceNow incident with an Ansible playbook and close the ticket with resolution notes.

Build a monthly sales report by querying S3 CSVs with DuckDB and emailing the result

Extract sales data to S3, aggregate it with DuckDB, and email a CSV report on the first of every month.

CMDB-Driven Patch Wave from ServiceNow

Query CMDB CIs due for patching, run a patch runbook per CI, and write the result back to ServiceNow.

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.

Extract JSON data from an API and load it as a document to MongoDB

Fetch JSON from a REST API and load it straight into MongoDB as a document, parameterized by a runtime input.

Load multiple CSV files from an HTTP API into Excel Sheets

Download multiple CSV files over HTTP and merge them into a single multi-sheet Excel workbook.

Logging configuration in a Python script using Loguru

Configure structured Python logging with Loguru and surface it natively in Kestra logs.

Manage Aiven resources from the CLI, start and stop services on schedule

Schedule the Aiven CLI to power services and databases off and on, cutting cloud costs without manual clicks.

MariaDB WordPress Housekeeping and Cleanup

Purge expired transients, spam comments, and old post revisions from a MariaDB-backed WordPress database on a schedule, then reclaim disk space with OPTIMIZE TABLE.

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.

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.

Open a ServiceNow Incident on Failure with CMDB Severity

Automatically open a ServiceNow incident when a pipeline fails, with severity pulled from the CMDB and a Slack alert.

Run a Runbook on ServiceNow Change Approval

An approved ServiceNow change request automatically runs an implementation runbook and updates the change record state.

Run Shell Scripts and Shell commands in a working directory using a Process Task Runner

Run multi-step Bash scripts and shell commands that share files in a single working directory.

Scan ServiceNow Incidents and Fan Out Remediation Subflows

Poll ServiceNow for new incidents on a schedule and fan out each one to a remediation subflow.

Scheduled API to Postgres ETL with jq, COPY, and Slack Alerts

Call a REST API on a daily schedule, reshape the JSON with jq, bulk load it into Postgres with COPY, and notify Slack on success or failure.

Scheduled MinIO Bucket Retention Cleanup

Nightly job that lists a self-hosted MinIO bucket, filters objects older than a retention window in Python, and deletes only the expired ones.

Self-Healing Recovery Loop with Retries, Rollback, and an SLA Gate

Four resilience patterns in one flow: automatic retries, rollback on failed smoke tests, a self-healing recovery loop, and an SLA breach that triggers automated RCA.

Send a SendGrid email notification when a workflow fails

Send a SendGrid email alert automatically whenever any workflow in your namespace fails or warns.

Send an alert to Sentry when a flow fails

Push a rich Sentry alert with full execution context the moment a Kestra flow fails.

Send an email and corresponding attachments with Resend

Download a CSV dataset and email it as an attachment through the Resend SMTP API, with the API token kept safe in a Kestra Secret.

Update a custom ServiceNow table

Sync external API data into a custom ServiceNow table with automatic upsert (update or insert) logic.

Webhook to PowerShell Healthcheck to ServiceNow Incident

Validate a webhook payload with Python, run a PowerShell disk healthcheck, and file the results as a ServiceNow incident.