Basin Pipelines

Last updated Oct 1, 2026 Ingest, transform, and load streaming data into Apache Iceberg or Parquet in R2.

Available on Workers Paid plan

Basin Pipelines is now Generally Available

Basin Pipelines, formerly known as Cloudflare Pipelines, is now Generally Available. Existing resources and configurations will continue to work.

To report bugs or give feedback, go to the #basin-pipelines Discord channel ↗︎. If you are having issues with Wrangler, report issues in the Wrangler GitHub repository ↗︎.

Basin Pipelines ingests events, transforms them with SQL, and delivers them to R2 as Iceberg tables or as Parquet and JSON files.

Whether you are processing server logs, mobile application events, IoT telemetry, or clickstream data, Basin Pipelines provides durable ingestion via HTTP endpoints or Worker bindings, SQL-based transformations, and exactly-once delivery to R2. This makes it easy to build analytics-ready data warehouses and lakehouses without managing streaming infrastructure.

Create your first pipeline by following the getting started guide or running this Wrangler command:

npmyarnpnpm

npx wrangler basin pipelines setup

yarn wrangler basin pipelines setup

pnpm wrangler basin pipelines setup

Features

Create your first pipeline

Build your first pipeline to ingest data via HTTP or Workers, apply SQL transformations, and deliver to R2 as Iceberg tables or Parquet files.

Get started

Streams

Durable, buffered queues that receive events via HTTP endpoints or Worker bindings.

Learn about Streams

Pipelines

Connect streams to sinks with SQL transformations that validate, filter, transform, and enrich your data at ingestion time.

Learn about Pipelines

Sinks

Configure destinations for your data. Write Apache Iceberg tables to Basin Catalog or export as Parquet and JSON files.

Learn about Sinks

Examples

Follow end-to-end examples, including how to fan one stream out into multiple Iceberg tables.

Browse examples

R2

Cloudflare R2 Object Storage allows developers to store large amounts of unstructured data without the costly egress bandwidth fees associated with typical cloud storage services.

Workers

Cloudflare Workers allows developers to build serverless applications and deploy instantly across the globe for exceptional performance, reliability, and scale.

More resources

Limits

Learn about pipelines limits.

@CloudflareDev

Follow @CloudflareDev on Twitter to learn about product announcements, and what is new in Cloudflare Workers.

Developer Discord

Connect with the Workers community on Discord to ask questions, show what you are building, and discuss the platform with other developers.

Was this helpful?

YesNo

On this page

Basin Pipelines - 图1Docs

{"@context":"https://schema.org","@type":"WebPage","@id":"https://developers.cloudflare.com/basin-pipelines/#page","headline":"Basin Pipelines","description":"Ingest, transform, and deliver streaming data to R2 as Apache Iceberg tables or Parquet and JSON files.","url":"https://developers.cloudflare.com/basin-pipelines/","inLanguage":"en","image":"https://developers.cloudflare.com/basin-pipelines/og.png?v=51bf2fd0ad41c63b","dateModified":"2026-10-01","publisher":{"@type":"Organization","name":"Cloudflare","description":"One platform for your apps, agents, and workforce. Build, secure, and scale without managing infrastructure","url":"https://www.cloudflare.com/","sameAs":["https://github.com/cloudflare","https://www.linkedin.com/company/cloudflare","https://x.com/cloudflare"],"logo":{"@type":"ImageObject","url":"https://developers.cloudflare.com/logo.svg"},"address":{"@type":"PostalAddress","streetAddress":"101 Townsend St","addressLocality":"San Francisco","addressRegion":"CA","postalCode":"94107","addressCountry":"US"},"contactPoint":[{"@type":"ContactPoint","contactType":"Customer Support","url":"https://support.cloudflare.com/","availableLanguage":["English"]},{"@type":"ContactPoint","contactType":"Sales","url":"https://www.cloudflare.com/contact/","availableLanguage":["English"]}]},"isPartOf":{"@type":"WebSite","@id":"https://developers.cloudflare.com/#website","name":"Cloudflare Docs","url":"https://developers.cloudflare.com/"}}

description: A managed Apache Iceberg data catalog built directly into R2 buckets. title: Basin Catalog image: https://developers.cloudflare.com/basin-catalog/og.png?v=c6a88a025de15231

Skip to content

Documentation Index
Fetch the complete documentation index at: https://developers.cloudflare.com/basin-catalog/llms.txt
Use this file to discover all available pages before exploring further.