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.

Apache Beam Distributed Pipeline on Flink (Portable Runner)

Submit a Python Apache Beam pipeline to a distributed Flink portable runner via a JobServer, triggered after upstream ingestion succeeds.

Apache Beam Python YAML CSV Transform

Use the Beam YAML framework with the Python SDK to read, filter, and rewrite a daily orders CSV, backfill-safe and with a non-injectable threshold.

Apache Beam Word Count with the DIRECT Runner

Run the canonical Apache Beam word-count pipeline locally with the DIRECT runner over a real ingested text file.

Automate Cross-Cloud ETL from Azure Blob Storage to BigQuery with dbt Cloud

Event-driven cross-cloud ETL that loads new Azure Blob CSV files into BigQuery and triggers a dbt Cloud transformation job.

Autoscale EMR Serverless Spark on a CloudWatch Backlog

Watch a CloudWatch backlog metric and fire an EMR Serverless Spark job only when work is pending.

BigQuery Partition-Aware Incremental Refresh

Refresh only the BigQuery partitions that changed by loading each day's GCS files into its matching partition with WRITE_TRUNCATE.

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.

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.

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.

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.

Glue ETL, Athena Validation, DynamoDB Cache

Run a Glue ETL job, validate the output with Athena, then cache the headline KPI in DynamoDB.

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.

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.

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 Apify actor and update Notion

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

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.

Stream Pub/Sub Events into BigQuery with Micro-Batching

A Pub/Sub trigger micro-batches streaming messages and appends them to a raw BigQuery table as newline-delimited JSON, staying under DML limits.

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.