Snowplow

Event pipeline that collects, validates and enriches behavioural events.

Provider: default
Kind: Stream processor
Category: Messaging
Official docs: https://docs.snowplow.io/docs/api-reference/stream-collector/

Properties · 2 set by this component

property	type	values	required	kind default	this component
checkpointIntervalSeconds	integer	—	no	—	inherited
cookieExpiryDays · component property	integer	—	no	365	inherited
edition · component property	enum	community-edition \| self-hosted-production \| private-managed-cloud \| cdi-cloud	no	community-edition	inherited
exactlyOnce	boolean	—	no	false	inherited
failedEventStream · component property	boolean	—	no	true	inherited
instances	integer	—	no	—	inherited
lateDataPolicy	enum	drop \| shift \| sideline	no	—	inherited
managed	boolean	—	no	false	▸ false
stateBackend	enum	memory \| rocksdb \| external	no	memory	inherited
streamBackend · component property	enum	kinesis \| pubsub \| kafka \| nsq \| sqs	no	—	inherited
watermarkSeconds	integer	—	no	—	inherited
windowing	enum	none \| event-time \| processing-time	no	none	▸ 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.

Event-time windows without watermarkwarning

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: "snowplow", component: "snowplow" }

Other Stream processor products · 33

Realtime Compute for Apache Flinkalibaba-flinkalibabacloudstream-processor Amazon EventBridge Pipesaws-eventbridge-pipesawsstream-processor Amazon Data Firehoseaws-firehoseawsstream-processor Amazon Managed Service for Apache Flinkaws-managed-flinkawsstream-processor Amazon OpenSearch Ingestionaws-opensearch-ingestionawsstream-processor Azure Stream Analyticsazure-stream-analyticsazurestream-processor Cloudflare Logpushcloudflare-logpushcloudflarestream-processor Cloudflare Pipelinescloudflare-pipelinescloudflarestream-processor Arroyoarroyostream-processor Apache Beambeamstream-processor Bytewaxbytewaxstream-processor Drasidrasistream-processor Apache Flinkflinkstream-processor Kafka Streamskafka-streamsstream-processor ksqlDBksqldbstream-processor Logstashlogstashstream-processor Materializematerializestream-processor Apache NiFinifistream-processor Norikranorikrastream-processor Redpanda Connectredpanda-connectstream-processor RisingWaverisingwavestream-processor Apache Samzasamzastream-processor Spark Structured Streamingspark-streamingstream-processor Apache Stormstormstream-processor Generic stream processorstream-processorstream-processor Tremortremorstream-processor Google Cloud Dataflowgoogle-dataflowgcpstream-processor Manufacturing Data Enginegoogle-manufacturing-data-enginegcpstream-processor Activity Tracker Event Routingibm-activity-tracker-event-routingibmstream-processor IBM Cloud Logs Routingibm-logs-routingibmstream-processor IBM Cloud Metrics Routingibm-metrics-routingibmstream-processor OCI Connector Huboci-connector-hubocistream-processor OCI GoldenGate Stream Analyticsoci-goldengate-stream-analyticsocistream-processor

Source

1# yaml-language-server: $schema=../../schema/component.schema.json
2# Snowplow: event pipeline that collects, validates and enriches behavioural events before loading
3# them into a warehouse, lake or stream. The Stream Collector "receives raw Snowplow events sent
4# over HTTP by trackers or webhooks ... and writes them to a sink" - Kinesis, Pub/Sub, Kafka, NSQ
5# or SQS - and sets a first-party tracking cookie with a one year expiry ("Stream Collector").
6# Enrichment is per event, not windowed; Community Edition is deployed and run by you ("Get started").
7schemaVersion: "1"
8type: "component"
9id: "snowplow"
10kind: "stream-processor"
11provider: "default"
12docs: "https://docs.snowplow.io/docs/api-reference/stream-collector/"
13defaults:
14  managed: false
15  windowing: "none"
16properties:
17  edition:
18    type: "enum"
19    values: ["community-edition", "self-hosted-production", "private-managed-cloud", "cdi-cloud"]
20    default: "community-edition"
21  streamBackend:
22    type: "enum"
23    values: ["kinesis", "pubsub", "kafka", "nsq", "sqs"]
24  failedEventStream:
25    type: "boolean"
26    default: true
27  cookieExpiryDays:
28    type: "integer"
29    default: 365

The same page as markdown, for an agent: /catalogue/components/snowplow.md