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.

OpenSnowcat Amplitude real-time

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).

RegionEndpoint
Standardhttps://api2.amplitude.com/2/httpapi
EU residency serverhttps://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
},