469K events per second.
Every sensor. Every reading.
High-throughput ingestion with WAL durability for industrial IoT, connected vehicles, and device fleets. Time-series queries and anomaly detection projections — no separate TSDB needed.
Built for the firehose
469K Events/sec Ingestion
Purpose-built for high-throughput sensor data. Ingest hundreds of thousands of readings per second from device fleets, factory floors, and connected vehicles without backpressure.
WAL Durability — Zero Data Loss
Every sensor reading is written to the Write-Ahead Log with CRC32 checksums and configurable fsync. Power failures, crashes, network partitions — no reading is ever lost.
Time-Series Event Queries
Query sensor readings by time range, device ID, reading type, or any combination. Sub-microsecond indexed lookups make real-time dashboards trivial.
Batch Ingestion API
Send thousands of readings in a single HTTP request. Edge gateways can buffer offline readings and sync in bulk when connectivity returns. Idempotent by design.
Schema Validation per Device Type
Define schemas for each sensor type — temperature, pressure, vibration, GPS. Invalid readings are rejected at ingestion, not discovered days later in a dashboard.
Anomaly Detection Projections
Define projections that track rolling averages, standard deviations, and threshold breaches. Get real-time alerts when a sensor reading deviates from expected ranges.
Batch ingest sensor readings
Send thousands of readings in a single request from edge gateways
# Batch ingest sensor readings from an edge gateway
curl -s -X POST https://api.all-source.xyz/api/v1/events \
-H "Authorization: Bearer $API_KEY" \
-H "Content-Type: application/json" \
-d '{
"events": [
{
"event_type": "sensor.temperature",
"entity_id": "factory-12/line-3/motor-7",
"data": {"celsius": 87.3, "unit": "C"},
"timestamp": "2026-04-16T14:30:01.123Z"
},
{
"event_type": "sensor.vibration",
"entity_id": "factory-12/line-3/motor-7",
"data": {"mm_per_sec": 4.7, "axis": "x"},
"timestamp": "2026-04-16T14:30:01.124Z"
},
{
"event_type": "sensor.temperature",
"entity_id": "factory-12/line-3/motor-8",
"data": {"celsius": 42.1, "unit": "C"},
"timestamp": "2026-04-16T14:30:01.125Z"
}
]
}'
# {"accepted": 3, "rejected": 0}
# Query temperature readings for a specific motor over the last hour
curl -s https://api.all-source.xyz/api/v1/events/query \
-H "Authorization: Bearer $API_KEY" \
-d '{
"entity_id": "factory-12/line-3/motor-7",
"event_type": "sensor.temperature",
"start_time": "2026-04-16T13:30:00Z",
"end_time": "2026-04-16T14:30:00Z"
}'
# {"events": [...], "count": 3600} — one reading per second, all durableYour sensors deserve a real event store
Stop shoehorning telemetry into time-series databases that were not built for event sourcing. Get durability, time-travel, and anomaly detection in one engine.