โ All workers
Anomaly Detection
Coming SoonScore every observation against its own history. Know when something is unusual.
Data StreamStandard
What it does
Maintains a T-Digest per feed source per time window. Each new item gets scored against the model โ percentile and z-score-equivalent โ and the score attaches as an extension field. Constant space, constant time per update.
Example output
JSONFeed extension fields attached to each processed item.
{
"_anomaly": {
"metric": "cloud_cover_oktas",
"value": 7,
"percentile": 0.97,
"z_score": 2.14,
"anomaly": true,
"severity": "high"
}
}Use cases
- Solar energy: flag abnormal cloud cover that will choke production
- Financial: detect volume spikes or price dislocations
- IoT: sensor readings outside normal operating range
- Parametric insurance: automatic trigger evaluation