About Me
Data Engineer with hands-on experience designing and deploying production-grade ELT pipelines, real-time streaming systems, and cloud data platforms. Proven expertise in Airflow (DAG orchestration), dbt (dimensional mode…
Data Engineer with hands-on experience designing and deploying production-grade ELT pipelines, real-time streaming systems, and cloud data platforms. Proven expertise in Airflow (DAG orchestration), dbt (dimensional modeling), Snowflake (warehouse optimization), and Kafka (event streaming). Successfully delivered 4+ end-to-end data engineering projects processing 100K+ records daily, reducing pipeline latency by 60%, and enabling real-time analytics for business intelligence. Strong foundation in Python, SQL, AWS, and modern data stack tools. Actively seeking opportunities to build scalable, high-performance data infrastructure.
Experience
Fully Automated ELT Platform
Architected fully automated ELT pipeline processing 50K+ daily transactions from AWS S3 to Snowflake, reducing manual processing by 90%
Designed 3-layer dbt transformation architecture (staging->intermediate->marts) with 25+ models implementing star schema for analytics
Orchestrated workflows using Apache Airflow with 12+ DAGs, implementing task dependencies, retry logic, and SLA monitoring
Kafka + FastAPI + PostgreSQL
Engineered high-throughput Kafka pipeline processing 10K+ flight telemetry records per minute with sub-100ms latency
Designed Kafka topic architecture with 8-partition strategy achieving parallel processing and improving throughput by 300%
Implemented real-time data enrichment (geocoding, airline mapping) using Python consumer groups, transforming raw data to analytics-ready
FastAPI, PostgreSQL, SQLAlchemy, Docker, WebSockets, Cloud Storage (R2)
Architected production data infrastructure supporting 1000+ concurrent users with comprehensive 20+ table relational schema
Implemented database optimization: connection pooling (PgBouncer), strategic indexing (B-tree, GIN), query optimization - reducing API response times from 2s to 200ms
Engineered cascade deletion workflows across 20+ foreign key relationships ensuring referential integrity and GDPR-compliant data removal
OCR + LLM – Data Extraction Pipeline
Designed multi-stage automated pipeline (ingestion->OCR->cleaning->LLM parsing->validation) processing 500+ documents daily, reducing manual entry by 85%
Leveraged LLM APIs (GPT-4) with engineered prompts to extract structured fields from unstructured OCR text with 92% field-level accuracy
Standardized extracted data into normalized PostgreSQL schemas, enabling downstream analytics on property trends and ownership patterns
Data Engineer
Architected fully automated ELT pipeline processing 50K+ daily transactions from AWS S3 to Snowflake, reducing manual processing by 90%, Designed 3-layer dbt transformation architecture (staging->intermediate->marts) with 25+ models implementing star schema for analytics, Orchestrated workflows using Apache Airflow with 12+ DAGs, implementing task dependencies, retry logic, and SLA monitoring
Data Engineer
Designed multi-stage automated pipeline (ingestion->OCR->cleaning->LLM parsing->validation) processing 500+ documents daily, reducing manual entry by 85%, Leveraged LLM APIs (GPT-4) with engineered prompts to extract structured fields from unstructured OCR text with 92% field-level accuracy, Standardized extracted data into normalized PostgreSQL schemas, enabling downstream analytics on property trends and ownership patterns
Data Engineer
Architected production data infrastructure supporting 1000+ concurrent users with comprehensive 20+ table relational schema, Implemented database optimization: connection pooling (PgBouncer), strategic indexing (B-tree, GIN), query optimization - reducing API response times from 2s to 200ms, Engineered cascade deletion workflows across 20+ foreign key relationships ensuring referential integrity and GDPR-compliant data removal
Data Engineer
Engineered high-throughput Kafka pipeline processing 10K+ flight telemetry records per minute with sub-100ms latency, Designed Kafka topic architecture with 8-partition strategy achieving parallel processing and improving throughput by 300%, Implemented real-time data enrichment (geocoding, airline mapping) using Python consumer groups, transforming raw data to analytics-ready