Ingest, Catalog & Query

Build analytics-ready data warehouses and lakehouses on R2. Stream events via Pipelines, catalog tables with Apache Iceberg, and query with R2 SQL or any compatible engine—all without egress fees.

Zero egress fees

Query your data from any cloud, data platform, or region without incurring transfer costs. R2 never charges for egress.

Always fast

Automatic table maintenance, such as compaction and snapshot expiration, keeps your data performant without the need for scheduling manual maintenance tasks.

Serverless ingestion

Stream and process events via HTTP endpoints or Workers bindings. No Apache Kafka, no Apache Flink, no infrastructure management.

SQL at the edge

Query Iceberg tables directly with R2 SQL or the wrangler CLI. Distributed compute, automatic file pruning.

No infrastructure

No servers to provision, no clusters to manage. Just define a schema, stream data, and query.

Open table format

Apache Iceberg tables means your data is accessible by your favorite query engines—Apache Spark, Snowflake, Trino, DuckDB, and more—via R2 Data Catalog's standard Iceberg REST API.

Data Platform

A complete, serverless data platform built on R2

Pipelines ingests and transforms your data, R2 stores it as Iceberg tables, and R2 SQL or your preferred query engine analyzes it. No infrastructure to manage, no egress fees to worry about.

Log analytics at scale

Ingest server logs, application events, and telemetry data. Query with SQL to debug issues, track performance, and build operational dashboards.

Business intelligence pipelines

Stream clickstream data, user events, and transactions. Connect your BI tools directly to Iceberg tables for real-time reporting.

ETL without the infrastructure

Transform data with SQL at ingestion time. Filter, enrich, and validate before writing to storage—no separate ETL service required.

Multi-cloud analytics

Store data once in R2, query from anywhere. Run Spark jobs in AWS, Snowflake queries from your data warehouse, or DuckDB locally—all hitting the same tables.

From streaming events to SQL queries in minutes

Define a schema, stream data via Pipelines, and query with R2 SQL or connect your favorite Iceberg-compatible engine.

export default {
  async fetch(request, env, ctx): Promise<Response> {
    // Stream events to Pipelines
    await env.ANALYTICS.send([{
      user_id: "user_12345",
      event_type: "purchase",
      product_id: "widget-001",
      amount: 29.99,
    }]);

    return new Response("Event ingested");
  },
} satisfies ExportedHandler<Env>;