π Currently working on Lakehouse Catalog and Governance, Query Engines, and Cloud
π± Learning Rust
Multi-Region Sales Data Pipeline (UnifiedSalesReportingPipeline)
Designed and implemented an end-to-end Azure lakehouse pipeline to consolidate ~12M daily sales records from each regional branch into a unified dataset.
- Orchestration: Built modular, fault-tolerant workflows in ADF with centralized logging, retry logic, and restart-from-failure handling.
- Transformation: Developed parameterized notebooks in Databricks for cleaning, normalization, and metadata enrichment.
- Governance: Implemented data quality checks by quarantining invalid records and enforcing NOT NULL/CHECK constraints.
- Storage: Wrote optimized, ACID-compliant Delta Lake tables on ADLS Gen.
Agricultural Commodity Price Arbitrage Pipeline (agri-price-arbitrage-adf-pipeline)
Built an ADF-driven pipeline to ingest and process daily agricultural commodity price data from external APIs.
- Architecture: Utilized a Medallion (Bronze-Silver-Gold) architecture for structured data processing.
- Data Flow: Cleaned and standardized nested JSON data using ADF Data Flows to ensure consistent schema and quality.
- Analytics: Implemented business logic to identify in-state price arbitrage opportunities for actionable trading insights.
I enjoy documenting my Data Engineering learnings in simple, digestible explanations to improve my understanding. Posts Website: DEDigest
