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:

Alert a QQ group on flow failures across a namespace

Page on-call responders in QQ (Tencent Cloud IM) whenever any flow in a Kestra namespace ends in FAILED or WARNING.

Assign a TLS Certificate to a VM as a Kestra Asset

Provision a TLS certificate for a VM, auto-discovering its IP asset from the catalog and registering the cert as a typed asset.

Assign an External IP and Register It as a VM Asset

Reserve a static external IP for a VM and register it as a typed IP asset attached to that machine.

Build an ETL Pipeline from a REST API Using Python, Polars, and DuckDB

Extract data from a REST API, reshape it with Python and Polars, then run analytical SQL on it with DuckDB, all in one Kestra flow.

Clean Up License-Dependent VM Assets Automatically

Automatically purge VM assets tied to a deleted software license, triggered by the license deletion flow or a webhook.

Create a VM and Register It as a Kestra Asset

Provision a virtual machine and register it as a governed VM asset in the Kestra asset catalog.

Create a VM Bound to a License Asset

Provision a VM linked to a software license picked from the Kestra asset catalog, recording the dependency as lineage.

Daily pipeline digest to a QQ channel

Post a daily Kestra pipeline status digest with real 24h execution counts to a Tencent Cloud IM / QQ team channel.

Event-Driven Argo CD Sync on CI Completion

A CI-completion webhook triggers an Argo CD sync, verifies application health, and reports the result to Slack.

Extract data, transform it, and load it in parallel to S3 and Postgres

Extract JSON from a REST API, enrich it, and load it in parallel to Postgres and Amazon S3.

Fleet Security Audit and Auto-Remediation with Assets

Audit every VM asset for a security agent, stamp compliance status in metadata, then auto-remediate non-compliant machines.

Guard Apify scrapes with cost caps and an automated quality gate

Run an Apify actor under hard cost and run caps, then branch on the returned item count so a degraded scrape pages the on-call instead of silently shipping bad data.

Human-in-the-loop approval with QQ notifications

Notify a QQ approver group that an approval is pending, pause for a human decision, then post the outcome or an expiry notice.

Install Software on a VM and Track It as an Asset

Install software on a VM and register the installation as a typed ingress asset with version metadata in Kestra.

Load a scheduled Apify web scrape into Postgres

Run an Apify actor on a schedule, fetch its dataset, reshape the records, and bulk-load them into Postgres with cost caps and Slack alerts.

Manage an Argo CD Application with Sync Verification

Create an Argo CD Application, sync it, and capture status before and after reconciliation in one Kestra flow.

Onboard a VM User and Register the Account as an Asset

Onboard a user account on a VM with PowerShell and register it as a typed user asset with role and compliance metadata.

Provision Servers from a Manifest and Register Them as Assets

Provision a server fleet from a JSON manifest and register every machine as a typed VM asset with env, OS, and IP metadata.

Provision with Terraform, Configure with Ansible, Deploy with Argo CD

Chain Terraform provisioning, Ansible configuration, and an Argo CD sync with a final health check.

Run Apify actor and update Notion

Run an Apify actor, pull its dataset, and publish the scraped results straight into a Notion page.

Send a Telegram notification when a workflow fails

System flow that sends a Telegram alert whenever any workflow under the company namespace fails or finishes with a warning.

Single-tenant Argo CD rollout with waves, guarded sync strategy, and Status-based readiness gates

Roll out Argo CD Application updates across a single-tenant fleet in safe, sequential waves gated on real sync and health status.

Sync tenant resources at regular intervals

Continuously sync namespaces, flows, files, and dashboards from a Git repository into your Kestra tenant every 15 minutes.

Turn an Apify web crawl into a fresh RAG vector index

Crawl a site with Apify's Website Content Crawler, embed the cleaned content into a vector store, and answer questions grounded in the freshly scraped data.