Skip to main content

Real-Time Data Platform

Crypto Intelligence Platform

Real-time market intelligence with streaming data ingestion, ML regime detection, on-chain whale tracking, and interactive 3D visualizations. Self-hosted on Proxmox.

15
Symbols tracked
< 50ms
Latency p99
21.6K
Candles / day
78%
Regime accuracy

Architecture

Binance WebSocket feeds flow through FastAPI into TimescaleDB and Redis, with ML regime detection running on a 5-minute cycle. Results stream to the Next.js frontend via WebSocket.

Visualizations

Candlestick Chart

D3.js with real-time WebSocket updates

Correlation Matrix

24h rolling cross-asset correlations

Key Components

01

Streaming Ingestion

Binance WebSocket consumer processing 15 symbol pairs. Kline and trade events persisted to TimescaleDB hypertables with continuous aggregates.

02

ML Regime Detection

Gaussian Hidden Markov Model trained on rolling 7-day windows of log returns, volatility, and volume features. Identifies accumulation, markup, distribution, and markdown phases.

03

Whale Tracker

Etherscan API polling for large ETH transfers. D3.js force-directed graph showing address relationships and transaction flow.

04

3D Market Treemap

Three.js rendered blocks sized by volume, colored by 24h change, with height representing volatility. Auto-rotating with hover interaction.

Stack

PythonFastAPIWebSocketPostgreSQLTimescaleDBRedisBinance APIEtherscanscikit-learnHMMNext.js 14TypeScriptThree.jsD3.jsDocker