450+ 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:

CRUD operations in SurrealQL: run multiple SurrealDB queries and send the query results via Slack

Run a chain of SurrealDB CRUD queries with Kestra and post the final result to Slack.

Daily Snowflake Digest as a Slack Canvas

Query Snowflake every morning, format the metrics as Markdown, and publish them as an editable Slack Canvas.

Event-Driven SQL Server Queue Processing

Poll a SQL Server queue-style table for pending rows, flip them to processed in the same transaction, and fan out to a per-row task the moment work appears.

Event-driven workflow based on a Snowflake query condition

Run a Kestra workflow automatically whenever a Snowflake query returns matching rows.

Guarded Disk Cleanup Maintenance over SSH

SSH disk cleanup with a host allowlist, pre/post metrics, an approval gate for production hosts, and Slack reporting.

Monitor SSL Certificate Expiry and Alert via Slack and Email Before They Expire

Weekly SSL certificate expiry monitor that checks days remaining for a list of domains and fires Slack and email alerts before they expire, with KV state to suppress duplicate notifications.

Orchestrate SQLMesh and DuckDB engine

Clone a SQLMesh project from Git, run `sqlmesh plan --auto-apply`, and query the resulting DuckDB database with Kestra.

Query data in Snowflake

Run a SQL query against your Snowflake data warehouse and capture the results in Kestra.

Query SurrealDB and store the result as a downloadable artifact

Insert records into SurrealDB and store query results as downloadable artifacts in Kestra internal storage.

Scheduled SQL Server Report Emailed as a CSV Attachment

Run a daily SQL Server aggregate query, convert it to CSV, and email it as an attachment, skipping empty days and alerting Slack on failure.

Send a TCP message to a remote host for network checks and infrastructure automation

Send a raw TCP payload to any host and port from Kestra, with a pre-flight port check and a fail-fast assertion.

Ship Kestra logs to Splunk

Forward Kestra execution logs to Splunk daily via HTTP Event Collector for centralized observability and alerting.

Snowflake ETL: load files to internal stage, copy from stage to a table and run analytical SQL queries

End-to-end Snowflake ETL with Kestra: create a database and table, stage a CSV, COPY INTO Snowflake, and run analytical SQL.

Snowflake Incremental MERGE Upsert with a Transactional Load

Stage a delta file, COPY into a staging table, and MERGE into the Snowflake target as one atomic transaction for an idempotent upsert.

Snowflake Stream Trigger to Postgres with dbt Transformations

Poll a Snowflake stream for new rows, load each batch into Postgres in parallel, run dbt transformations, and alert Slack on failure.

SQL Server CDC to Microsoft Teams via Debezium

Stream SQL Server row-level changes in real time with the Debezium SQL Server connector and alert Microsoft Teams on high-value changes, no Kafka Connect required.

SQL Server Incremental Batch Sync Between Instances

Extract changed rows from a source SQL Server table since the last KV-tracked watermark and bulk-insert them into a destination instance with chunked JDBC batches.

SQL Server Transactional MERGE Upsert with Watermark

Stage changed rows since a KV-tracked watermark, MERGE them into a target table with dedup, and advance the watermark, all inside one SQL Server transaction.

Switch tasks depending on a specific value

Route Kestra workflow execution down different branches based on an input value using the Switch task.

Sync code from Git at regular intervals

Pull flows and namespace files from a Git repository into Kestra every hour for GitOps-driven deployments.

Sync Stripe Payments and Customer Data to a PostgreSQL CRM Database Daily

Fetch Stripe charges and customers, enrich them in Python, and upsert into a PostgreSQL CRM table on a daily schedule with idempotent deduplication.

Using system readOnly label to disable editing the flow from UI

Lock a Kestra flow against UI edits by setting the system.readOnly label, protecting GitOps-managed and production workflows from accidental changes.

VM Patching over SSH with Approval and Automatic Rollback

Patch a VM over SSH, pause for human validation, and automatically roll back to the previous package version on failure or rejection.

Weekly Stand-up Reminder in Slack

Automatically post a structured weekly stand-up prompt to a Slack channel every Monday morning.