Cloudflare Pipelines

cloudflareStream processorcloudflare-pipelines

Streaming ingestion with SQL transformations and exactly-once delivery into R2.

Provider
cloudflare
Category
Messaging
Properties · 3 set by this component
propertytypevaluesrequiredkind defaultthis component
checkpointIntervalSecondsinteger—no—inherited
exactlyOnceboolean—nofalse▸ true
ingestSource · component propertyenumhttp-endpoint | worker-bindingnohttp-endpointinherited
instancesinteger—no—inherited
lateDataPolicyenumdrop | shift | sidelineno—inherited
managedboolean—nofalse▸ true
sinkFormat · component propertyenumapache-iceberg | parquet | jsonno—inherited
sqlTransformations · component propertyboolean—notrueinherited
stateBackendenummemory | rocksdb | externalnomemoryinherited
watermarkSecondsinteger—no—inherited
windowingenumnone | event-time | processing-timenonone▸ none
Rules that apply · 1

Every rule whose selector covers this component's kind or its category. Whether a rule fires depends on the design: its properties, its edges and its groups.

windowed-aggregation-without-watermark

Event-time windows need a watermark to know when a window is complete. Without one the processor either waits forever or closes windows early and silently drops late events.

  • — all of these hold:
  • — the node's `windowing` is "event-time"
  • — the node's `watermarkSeconds` has no value
Use it in a design
nodes:
  - { id: "pipelines", component: "cloudflare-pipelines" }
Other Stream processor products · 33
Realtime Compute for Apache Flinkalibaba-flinkalibabacloudstream-processorAmazon EventBridge Pipesaws-eventbridge-pipesawsstream-processorAmazon Data Firehoseaws-firehoseawsstream-processorAmazon Managed Service for Apache Flinkaws-managed-flinkawsstream-processorAmazon OpenSearch Ingestionaws-opensearch-ingestionawsstream-processorAzure Stream Analyticsazure-stream-analyticsazurestream-processorCloudflare Logpushcloudflare-logpushcloudflarestream-processorArroyoarroyostream-processorApache Beambeamstream-processorBytewaxbytewaxstream-processorDrasidrasistream-processorApache Flinkflinkstream-processorKafka Streamskafka-streamsstream-processorksqlDBksqldbstream-processorLogstashlogstashstream-processorMaterializematerializestream-processorApache NiFinifistream-processorNorikranorikrastream-processorRedpanda Connectredpanda-connectstream-processorRisingWaverisingwavestream-processorApache Samzasamzastream-processorSnowplowsnowplowstream-processorSpark Structured Streamingspark-streamingstream-processorApache Stormstormstream-processorGeneric stream processorstream-processorstream-processorTremortremorstream-processorGoogle Cloud Dataflowgoogle-dataflowgcpstream-processorManufacturing Data Enginegoogle-manufacturing-data-enginegcpstream-processorActivity Tracker Event Routingibm-activity-tracker-event-routingibmstream-processorIBM Cloud Logs Routingibm-logs-routingibmstream-processorIBM Cloud Metrics Routingibm-metrics-routingibmstream-processorOCI Connector Huboci-connector-hubocistream-processorOCI GoldenGate Stream Analyticsoci-goldengate-stream-analyticsocistream-processor
Source
# yaml-language-server: $schema=../../schema/component.schema.json
# Cloudflare Pipelines: streams buffer events from an HTTP endpoint or a Worker binding, a SQL
# pipeline transforms them, and a sink writes Iceberg tables or Parquet and JSON files to R2.
# "Pipelines" states it provides exactly-once delivery to R2. Currently open beta, Workers Paid only.
schemaVersion: "1"
type: "component"
id: "cloudflare-pipelines"
kind: "stream-processor"
provider: "cloudflare"
docs: "https://developers.cloudflare.com/pipelines/"
defaults:
  managed: true
  exactlyOnce: true
  windowing: "none"
properties:
  ingestSource:
    type: "enum"
    values: ["http-endpoint", "worker-binding"]
    default: "http-endpoint"
  sinkFormat:
    type: "enum"
    values: ["apache-iceberg", "parquet", "json"]
  sqlTransformations:
    type: "boolean"
    default: true

The same page as markdown, for an agent: /catalogue/components/cloudflare-pipelines.md