Basin

Basin is an end-to-end analytics data platform that brings ingestion, table management, and distributed SQL together to Cloudflare's Developer Platform. It receives data from applications, infrastructure, devices, and Cloudflare services, transforms events during ingestion, stores them in open Iceberg tables, and makes it queryable with Basin SQL or compatible external engines.

---
title: Basin data flow
---
flowchart LR
	pipelines["Basin Pipelines"]
	catalog["Basin Catalog<br/>Apache Iceberg tables"]
	sql["Basin SQL &<br/>compatible external engines"]
	pipelines -->|processes and ingests events| catalog
	catalog -->|queried by| sql

With Basin, you can expect to:

• Ingest and transform events without managing streaming infrastructure
• Keep data portable through the open Apache Iceberg standard
• Maintain tables automatically with compaction and snapshot expiration
• Run globally distributed OLAP queries without managing query clusters
• Access tables stored in R2 without egress fees

To build your first request analytics workflow, follow the Basin CLI guide.

Use Basin Pipelines to receive events through HTTP endpoints or Workers bindings. It transforms events with SQL and writes Iceberg tables or files to R2.

Run the setup command to configure a stream, sink, and pipeline:

npx wrangler basin pipelines setup

yarn wrangler basin pipelines setup

pnpm wrangler basin pipelines setup

Use Basin Catalog to manage Iceberg metadata in your R2 bucket. It provides an Iceberg REST catalog and automatic table maintenance.

Enable Basin Catalog on an existing R2 bucket:

npx wrangler basin catalog enable YOUR_BUCKET_NAME

yarn wrangler basin catalog enable YOUR_BUCKET_NAME

pnpm wrangler basin catalog enable YOUR_BUCKET_NAME

Use Basin SQL to run distributed online analytical processing (OLAP) queries across catalog tables. It uses Cloudflare's global network without requiring query clusters.

Query a table in your warehouse with SQL:

npx wrangler basin sql query YOUR_WAREHOUSE_NAME "SELECT * FROM default.events LIMIT 10"

yarn wrangler basin sql query YOUR_WAREHOUSE_NAME "SELECT * FROM default.events LIMIT 10"

pnpm wrangler basin sql query YOUR_WAREHOUSE_NAME "SELECT * FROM default.events LIMIT 10"