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:

AI Document Data Extraction: Parse PDFs and Web Pages into Structured JSON with OpenAI

Turn any PDF, web page, or text document into structured JSON with OpenAI GPT-4o, then store the results in PostgreSQL and Slack.

AI-Powered Inventory Demand Forecasting, Auto-Generate Purchase Orders with OpenAI

Forecast 7-day demand with OpenAI GPT-4o, auto-generate purchase orders for stockout-risk SKUs, and log them to PostgreSQL every 6 hours.

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.

Build an ETL Pipeline with Airbyte Cloud and dbt Cloud for SaaS Analytics

Run Airbyte Cloud syncs in parallel, then trigger a dbt Cloud transformation job once the data lands.

Build an ETL Pipeline with Airbyte Cloud and dbt Core for SaaS Analytics

Ingest Salesforce, Google Analytics, and Facebook Ads in parallel with Airbyte Cloud, then transform with dbt in one orchestrated ELT pipeline.

Build an ETL Pipeline with Parallel Airbyte Syncs and dbt Core Transformations

Run parallel Airbyte syncs, then transform raw data with dbt Core, all in one orchestrated ELT pipeline.

Consume RabbitMQ orders with dead letter queue handling

Stream RabbitMQ order messages into real-time executions, validate and forward them to an API, and route failures to a self-provisioned dead letter exchange.

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.

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.

Generate and Execute SQL Queries from Natural Language Using OpenAI GPT-4o

Turn plain-English questions into PostgreSQL queries with OpenAI GPT-4o, grounded on schema only so no row data ever leaves your database.

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.

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 Scheduled ETL Sync with Airbyte Cloud

Trigger an Airbyte Cloud connection sync on a recurring schedule so your data lands fresh without manual runs.

Run Parallel ETL Ingestion with Airbyte to Sync Multiple Data Sources

Trigger multiple Airbyte connection syncs in parallel from a single Kestra flow to cut total ingestion time.

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.

Sync Postgres records to Algolia index

Incrementally push freshly updated Postgres rows into an Algolia search index every five minutes.

Trigger an Airflow DAG

Trigger an Apache Airflow DAG from Kestra and wait for it to finish.

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.