Crypto Market Data Pipeline
Medallion lakehouse on Databricks
Loads live and historical market data for the top 20 coins from the CoinGecko API into Delta Lake, and models it into tables a trading dashboard reads.
-
CoinGecko APIsourceMarkets, plus 30 days of 4-hour OHLC candles
-
Bronzeraw, mergedbronze_market_databronze_ohlc_data
-
Silverstar schemadim_coindim_datesilver_market_metricssilver_ohlc_metrics Rows that fail checks go to silver_market_quarantine
-
Goldtrader viewsgold_market_snapshotgold_ohlc_historygold_performance_metricsgold_market_summary
- Ingestion retries with exponential backoff and stays inside CoinGecko's rate limit.
- Loads use Delta
MERGE, so re-running a batch doesn't duplicate rows. - Silver separates dimensions from facts. Rows that fail quality checks are quarantined instead of dropped, and every run is logged with its status and row counts.
- Gold adds support and resistance levels, performance metrics and a recommendation score for a Databricks Lakeview dashboard.
Stack: PySpark, Databricks, Delta Lake, Python, CoinGecko API