Ingest streaming events over HTTP or Worker bindings, validate and transform them with SQL, and write the results to Basin Catalog as Apache Iceberg tables or to R2 as Parquet/JSON files. Formerly Cloudflare Pipelines; generally available since October 2026.
FluffyStack toolsJurisdictional exposure
Attributes
- Ga Year
- 2026
Sub-services (3)
Streams
Durable buffered queues receiving events over HTTP or Worker bindings
SQL Transforms
SQL-defined transformations between streams and sinks
Sinks
R2 destinations as Apache Iceberg tables or Parquet/JSON files
Compliance & Certifications
This service is attested for the following frameworks. Always verify with the provider before relying on a specific compliance posture.
Where this runs
Commercial regions (29)
Europe (10)
- Paris
- Frankfurt
- Dublin
- Milan
- Amsterdam
- Warsaw
- Madrid
- Stockholm
- Zurich
- London
North America (4)
- Toronto
- Ashburn
- Chicago
- San Jose
South America (2)
- Buenos Aires
- São Paulo
Asia (6)
- Hong Kong
- Mumbai
- Tokyo
- Singapore
- Seoul
- Taipei
Oceania (2)
- Sydney
- Auckland
Middle East (2)
- Tel Aviv
- Dubai
Africa (3)
- Lagos
- Cape Town
- Johannesburg
Tags
Equivalent services on other platforms
Managed streaming ETL that captures data from Kinesis / Kafka / DirectPUT clients, buffers + optionally transforms it via Lambda, and writes to S3 / Redshift / OpenSearch / third-party sinks — no operators to manage. Formerly branded Amazon Kinesis Data Firehose
Big data streaming platform and event ingestion service capable of millions of events per second with Kafka compatibility, Capture to Blob or Data Lake, and partition-based scaling
Moves data between OCI services, e.g. logs, metrics and stream messages to Object Storage, Streaming, Functions, Monitoring or third-party SIEMs, with optional filtering and function tasks.
Continuous data ingestion into Snowflake from cloud storage (file-based Snowpipe) or directly from row-level streams (Snowpipe Streaming) with sub-10s latency and serverless compute
Managed data integration service built on Apache NiFi for batch and streaming movement of structured and unstructured data into Snowflake, deployable inside Snowflake (all clouds) or in the customer VPC (BYOC, AWS only).