Loading Data
Amplitude
Stream OpenSnowcat/Snowplow events into Amplitude in real-time.
The SnowcatCloud Amplitude Loader delivers Snowplow/OpenSnowcat enriched data into Amplitude with low latency, built-in resilience, and full compliance with Amplitude’s API model—without relying on external tools.
Designed for real-time workloads, it ensures continuity under load, throttling, or failure scenarios, without operational overhead.

Features
-
Real-Time Streaming
Stream enriched behavioral data to your applications in real time with minimal latency. -
Snowplow/OpenSnowcat Compatible
Compatible with Snowplow enriched TSV and OpenSnowcat. -
Real-Time Streaming
Stream enriched behavioral data to your applications in real time with minimal latency. -
Batch Control
Configure efficient flush intervals to balance throughput and delivery guarantees. -
Reliable Error Handling
Automatic retries and intelligent failure recovery ensure no data is lost. -
Native Monitoring
Fully integrated with CloudWatch Metrics and Logs for observability and alerting.
Loader Configuration
Define how and where data is streamed using a simple, declarative configuration block: Keep request sizes under 1 MB with fewer than 2000 events per request (per Amplitude API).
Region | Endpoint |
---|---|
Standard | https://api2.amplitude.com/2/httpapi |
EU residency server | https://api.eu.amplitude.com/2/httpapi |
# Output Configuration
output {
service: "amplitude",
endpoint: "https://api2.amplitude.com/2/httpapi",
sharedsecret: "your_amplitude_api_key",
format: "JSON",
batchmode: true
},
# Buffer Configuration
buffer {
bytelimit: 450000,
recordlimit: 45,
timelimit: 5000
},