480+ Blueprints, ready to build.

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

Data

AI Business Cloud Core Data Infrastructure

175 Blueprints

Sort by:

Automate daily e-commerce reporting by syncing Shopify orders and Stripe balance to Notion and Slack

Pull Stripe balance and Shopify orders every morning, write them to a Notion page, and ping Slack.

Build a Chat-With-Your-Data System Using Elasticsearch and OpenAI (RAG)

Build a RAG chat-with-your-data flow that retrieves answers from Elasticsearch and generates grounded responses with OpenAI.

Build an ETL Pipeline from Cassandra to BigQuery Using CSV Export

Extract Cassandra data with CQL, serialize it to CSV, and load it into Google BigQuery for analytics.

Build governed analytics assets with DuckDB using data lineage, staging, and mart layers

Build governed staging and mart data assets with DuckDB while Kestra captures end-to-end lineage automatically.

Bulk Load CSV Data into PostgreSQL Using COPY for Fast ETL Ingestion

Bulk load a CSV file into PostgreSQL with the native COPY protocol for fast, reliable ETL ingestion.

Cache a computationally expensive task in an ETL pipeline using the taskCache property

Cache an expensive extract task with taskCache and join the data in DuckDB to compute profit per transaction.

Chained dbt Cloud Jobs with Dependencies

Chain dbt Cloud staging, marts, and exposures jobs into one dependency-aware pipeline with Slack alerts.

ClickHouse real-time event ingestion with TTL-driven cleanup

Bulk-load real-time events into ClickHouse with asynchronous inserts, keep an hourly rollup current via a materialized view, and force TTL-based cleanup on every run.

Data Engineering Pipeline example, Getting started with Kestra

An end-to-end extract, transform, load pipeline that pulls JSON from an API, cleans it in Python, and aggregates it with DuckDB.

Dbt Cloud Production Run with an Approval Gate

Run the dbt Cloud CI job, pause for human approval, then run the production job and report to Slack.

Dbt Core Production Build with an Approval Gate

Build and test dbt Core on a CI target, pause for human approval, then build the production target only after sign-off.

Download a CSV from a URL and Bulk-Load It into PostgreSQL with COPY

Download a CSV from any public URL and bulk-load it into PostgreSQL using the fast native COPY protocol.

Extract Data from Couchbase and Transform It with Pandas for Analytics

Query a Couchbase NoSQL bucket with N1QL and reshape the results in Python with Pandas, all in one orchestrated flow.

Gate a Dataproc PySpark Batch on Data Readiness

Check BigQuery for fresh source rows and submit a Dataproc Serverless PySpark batch only when the data is ready.

GCS to Dataproc to BigQuery Lakehouse Refresh

Orchestrate the GCS to Dataproc to BigQuery lakehouse chain in one flow, with a serverless PySpark transform and a gold table load.

Generate mock JSON data and send the file to MongoDB

Generate realistic mock JSON records with DataGen and bulk-load them straight into a MongoDB collection.

Ingest AWS Resource Metadata into Postgres Using CloudQuery for Security and Governance Analysis

Sync AWS resource metadata into Postgres with CloudQuery, then flag public S3 buckets with SQL.

Nightly Competitor Pricing Monitor with Puppeteer

Scrape JS-rendered competitor pricing pages nightly with headless Chrome via Puppeteer, diff against a KV-stored snapshot, and alert Slack only when a price changes.

Query Databricks SQL and process lakehouse data with Python and Pandas

Run a Databricks SQL query against your lakehouse, export the results to CSV, and analyze them in Python with Pandas.

Run a Spark Batch on Dataproc Serverless

Submit a Spark job to Dataproc Serverless on a schedule, with no cluster to manage and cost that tracks the work.

Run dbt transformations on Google BigQuery from Git for analytics ETL

Clone a dbt project from Git and run dbt build against Google BigQuery inside a container, with full logging and version control.

Run scheduled sales analytics on CSV data with DuckDB and post results to Slack

Query a remote CSV with DuckDB on a weekly schedule and post the sales metrics straight to Slack.

Schedule CloudQuery Data Ingestion into DuckDB for Analytics and Exploration

Run a daily CloudQuery sync that extracts external API data and loads it into DuckDB for analytics, with built-in scheduling and retries.

Trigger a Dagster Job

Trigger a Dagster job from Kestra, wait for completion, and stamp every run with Kestra lineage tags.