480+ Blueprints, ready to build.

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

17 Data

AI Business Cloud Core Data Infrastructure

175 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.

Create a table and load CSV data into MySQL with SQL

Download a remote CSV and bulk-load it into MySQL with a declarative, secret-secured ELT pipeline.

Download from OneLake, Process with Python, and Upload Back

Pull a file from a Microsoft Fabric Lakehouse, transform it with Python, and write the result back to OneLake.

End-to-End Fabric Orchestration: Ingest, Transform, and Validate

Run a Fabric ingestion pipeline, transform data with a Notebook, and validate results in the Warehouse, all from a single Kestra flow.

Event-driven data ingestion to AWS S3 data lake managed by Apache

Event-driven ingestion that lands new S3 files into an Apache Iceberg data lake and merges them with Amazon Athena.

Export a Database Table to Microsoft Fabric OneLake

Query a PostgreSQL table and upload the result as a date-partitioned CSV into a Microsoft Fabric Lakehouse on OneLake.

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.

Fetch JSON from an API in Python and load it into MongoDB

Call a REST API in a Dockerized Python task, save the JSON, and load it straight into a MongoDB collection.

Ingest data to AWS S3 with Git, Python, Apache Iceberg, AWS Glue and Amazon Athena

Detect new files in S3 every hour and ingest them into an Apache Iceberg data lake with Git, Python, and Athena.

Ingest data to AWS S3 with Python, Apache Iceberg, AWS Glue and Athena

Detect new CSV files in S3, clean them with Python, and load them into an Apache Iceberg data lake on AWS Glue and Athena.

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.

Load time series data into InfluxDB

Fetch weather data from an API, reshape it with DuckDB, and load it into InfluxDB as time series points.

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.

Query a Microsoft Fabric Warehouse

Run a scheduled T-SQL query against a Microsoft Fabric Warehouse and store the results in Kestra internal storage.

Real-Time Kafka Record Processing with Per-Record Executions

A realtime Kafka trigger starts one execution per record, branches on the payload, and alerts Slack on anomalies.

Run a Microsoft Fabric Data Pipeline

Trigger a Microsoft Fabric Data Pipeline, pass runtime parameters, and wait for completion.

Run a Microsoft Fabric Notebook

Submit a Microsoft Fabric notebook job with parameters and wait for it to complete.

Run a Microsoft Fabric Spark Job

Submit a Microsoft Fabric Spark Job Definition and wait for it to finish.

Run DDL queries and load data to Postgres

Download a remote CSV, create the target table with DDL, and bulk load it into Postgres on a single Kestra flow.

Sync Hubspot CRM data to BigQuery on a schedule

Sync every HubSpot CRM object into BigQuery on a daily schedule using CloudQuery.

Sync new users from Postgres to HubSpot

Automatically create HubSpot contacts from new and updated rows in your Postgres customers table.

Trigger multiple Fivetran syncs in parallel, then run a dbt Cloud job

Sync multiple Fivetran connectors in parallel, then trigger a dbt Cloud transformation job, all from one Kestra flow.

Use Debezium to trigger a flow whenever new entries hit a Postgres

Capture Postgres row changes with Debezium CDC, then notify Slack and process the new data in Python automatically.

Validate and Reshape a Webhook Order Payload with JSONata

Validate a nested order webhook payload for required fields with JSONata, flatten it into a flat record with computed totals, and only forward it once it passes.