Unified batch + streaming market data warehouse. 10 tickers, 25 years of history, 4 data sources, refreshed every 15 seconds.
Live Data
Sources
Architecture
Kafka producers poll 4 sources every 15 seconds
~18 Airflow DAGs schedule batch + streaming jobs
8-table star schema in TimescaleDB
Interactive Dash dashboards with SMA/EMA
7 Docker Services
Dimensional modeling β fact tables for prices, fundamentals, earnings, SEC filings, and macro data with company and date dimensions.