Ingest streaming event data over HTTP or from Worker bindings, transform with SQL, and write the result to R2 as Apache Iceberg tables or partitioned Parquet/JSON files for downstream warehouse and analytics tools. Open-beta as of 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
Real-time streaming data collection, processing, and analytics platform with Data Streams, Data Firehose, Video Streams, and Kinesis Data Analytics sub-services
Real-time data stream processing and analytics engine with SQL-based queries, windowing functions, and native inputs from Event Hubs, IoT Hub, and Blob Storage
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
Unified stream and batch data processing service running Apache Beam pipelines with autoscaling, exactly-once semantics, and native sinks to BigQuery and Cloud Storage
Global real-time messaging and event ingestion service with at-least-once delivery, push and pull subscriptions, message ordering, and exactly-once delivery option
Apache Kafka-compatible managed streaming service. Producers and consumers use standard Kafka client libraries; OCI manages partitioning, replication, and retention. Integrates with OCI Functions and Service Connector Hub for processing.
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