Data Engineer | Data Platform Engineering | Streaming & Lakehouse

Sasidhar Mopuru

Building reliable data platforms, real-time pipelines, and AI-ready data products with Python, PySpark, Kafka, Databricks and Delta Lake.

PySpark Apache Kafka Delta Lake Databricks Python CI/CD
Sasidhar Mopuru
Databricks Certified
2+
Years Production Experience
14+
OSS Contributions
Databricks
Certified
Microsoft
Fabric Certified
Kafka
Streaming
PySpark
Delta Lake
About

Engineering Data Platforms at Scale

I specialize in turning high-velocity event streams into reliable, AI-ready data products. With hands-on experience across the full data lifecycle, I design, build, and support production-grade data platforms.

I am a Data Engineer with production experience at Accenture, building configuration-driven data pipelines, streaming systems, and lakehouse platforms. I focus on the engineering discipline that makes production systems reliable — testing, CI/CD, observability, and data quality.

My work spans real-time streaming with Kafka and PySpark, lakehouse architecture with Databricks and Delta Lake, and AI-ready data foundations for RAG applications. I contribute to open-source projects and build developer tools like the DataOps Toolkit.

# Platform in a nutshell
data_source = "Kafka"
processing = "PySpark Structured Streaming"
storage = "Delta Lake"
ci_cd = "GitLab CI/CD"
testing = "pytest, comprehensive coverage"

platform = "AI-ready, scalable, secure"

Data Platforms

Configuration-driven pipelines, lakehouse architecture, enterprise data products

Streaming

Kafka, PySpark Structured Streaming, exactly-once processing, real-time ETL

Lakehouse

Databricks, Delta Lake, schema enforcement, time travel, ACID transactions

Data Quality

Schema validation, reconciliation, testing, error handling, monitoring

Automation

CI/CD, configuration-driven code, reusable utilities, developer tooling

AI / RAG

Vector databases, embeddings, retrieval-augmented generation, data foundations

Cloud Infrastructure

Azure, Terraform, Event Hubs, ADLS Gen2, deployment automation

Developer Tooling

DataOps Toolkit, CLI tools, testing frameworks, documentation practices

Experience

Accenture — Enterprise Data Engineering

Hands-on development and validation of configuration-driven data pipelines serving enterprise data products.

Data Engineer, Management and Governance Analyst

Accenture · Feb 2024 – Present (Associate to Analyst, Feb 2026, effective March 2026) · Bengaluru, India

Production Data Engineering

  • Delivered numerous production ETL jobs across multiple business domains through Python development, JSON configuration, and DDL development
  • Managed full lifecycle of data products: PySpark/Python scripts, JSON configs, unit tests, production database tables, Delta Lake lakehouse tables, enterprise scheduling tools, job orchestration platforms, and monitoring solutions
  • Developed data products from design documents and built downstream datasets from source schemas, applying transformation queries when multiple source data products feed a single dataset

Streaming & Data Platforms

  • Worked with Kafka-based data pipelines and validation workflows, DDL scripts, and validation/reconciliation queries for real-time data processing
  • Monitored and troubleshot production pipelines for streaming data processing
  • Maintained per-schema exception tables to capture invalid records with target table reference, error log, and timestamp

Data Quality & Validation

  • Owned end-to-end data quality and platform validation for 3–4 sprint releases, validating schemas, tags, record counts, primary keys, business hash keys, and duplicate records across source-to-target data layers
  • Prepared SQL-based reconciliation evidence for clean production sign-off
  • Led change requests across data products and completed validations by comparing design documents, source messages, and data across multiple environments

Automation & Reusable Tooling

  • Improved deployment efficiency by developing configuration-driven pipeline definitions and reusable Python utilities used by the data platform and consumed by existing CI/CD workflows
  • Maintained comprehensive test coverage across pytest suites with mocked components and integration patterns

Production Operations

  • Maintained high pipeline availability through modular PySpark pipelines with error handling, retry logic, schema validation, and data quality checks
  • Optimized pipeline performance through partitioning, caching, and performance tuning on production pipelines
  • Used Jira dashboards to track sprint tasks, incidents, and maintenance activities for data products
  • Worked in cross-functional data engineering teams covering multiple business domains; owned data pipeline domains while supporting live monitoring
PySparkKafkaDelta LakeDatabricksProduction DatabasesJob OrchestrationMonitoringGitLab CI/CDJiraPython
Engineering Patterns

Engineering Patterns I Work With

The data platform patterns I work with to build reliable, scalable systems.

Data Sources
Kafka / APIs / Enterprise Systems
→
Processing
PySpark / Structured Streaming
→
Storage
Delta Lake / Databricks
→
Quality
Validation / Reconciliation
→
Products
AI / Analytics / Consumers
Projects

Production-Grade Data Platforms

Real-world solutions with measurable business impact and production-grade reliability.

Dagster OSS Contribution ⭐

Problem: Fixed critical bug in Dagster's AssetNode parent_keys handling affecting data pipeline reliability.

Outcome: PR #34143 submitted, regression tests added, improving reliability for thousands of users.

PythonDagsterpytestGitHub Actions

Kafka-PySpark-Delta Pipeline

Problem: Build scalable real-time streaming pipelines with exactly-once delivery guarantees.

Outcome: High-throughput data processing with exactly-once delivery and Delta checkpointing.

KafkaPySparkDelta LakePython

Cloud-Native Streaming Platform

Problem: Build multi-environment cloud infrastructure for real-time data processing.

Outcome: IaC-managed platform with exactly-once streaming and Delta Lake checkpointing.

AzureTerraformDatabricksDelta Lake

SasiHub — Full-Stack Product Engineering

Problem: Build a personal media platform for organizing movies, anime, series, games and music with external metadata integrations.

Outcome: Next.js application with TMDB/AniList/IGDB integrations, catalog management, collections, favorites, and responsive design.

Next.jsReactTypeScriptAPI Integration

RAG Document QA Chatbot

Problem: Build intelligent document Q&A with retrieval-augmented generation.

Outcome: FastAPI + Streamlit app with vector search and configurable LLM backends.

FastAPIChromaDBRAGOpenAI
ETL Jobs

Enterprise Configuration-Driven Platform

Problem: Scale data pipeline development across enterprise business domains.

Outcome: Delivered numerous production jobs, improved deployment efficiency, maintained high availability, achieved comprehensive test coverage.

PySparkKafkaDelta LakeJSON Configs
Career Signal

At a Glance

Key signals about my engineering profile and career direction.

🏭

Production

Enterprise Data Engineering at Accenture with production pipeline ownership and live monitoring

🌐

Open Source

14+ public contributions to Dagster, urllib3, axios, fastify, and other major projects

🎓

Certifications

Databricks Data Engineer Associate, Microsoft DP-700 Fabric, Google Data Analytics

🎯

Specialization

Streaming pipelines, lakehouse architecture, data quality, and AI-ready data platforms

🚀

Current Direction

Data Platform Engineering with focus on streaming, lakehouse, and AI-ready data foundations

Open Source Engineering

Production OSS Contributions

14+ Public Pull Requests across major open-source projects. I don't just build projects — I contribute to production software used by millions.

View GitHub Profile

Featured Contributions

Open

dagster/dagster #34143

Problem: Critical bug in AssetNode parent_keys handling affecting data pipeline reliability

Solution: Fixed mutation bug with defensive copy and added regression tests

Technology: Python, pytest

View PR →
Merged

fastify/fastify #6880

Problem: TypeScript documentation referenced outdated Fastify version

Solution: Updated docs to reference Fastify 5.x

Technology: TypeScript, Documentation

View PR →
Merged

axios/axios #11113

Problem: README stream example missing fs import

Solution: Added missing fs import to fix the example

Technology: JavaScript, Documentation

View PR →
Merged

Topicspot/skillfrisk #9

Problem: No way to filter findings by severity

Solution: Added --min-severity flag for severity filtering

Technology: Python, CLI

View PR →
Active

trpc/trpc #7452

Problem: Missing secure error reporting documentation

Solution: Added secure error reporting section to docs

Technology: TypeScript, Documentation

View PR →
Active

jsdoc/jsdoc #2176

Problem: README Node.js requirement misaligned with package.json

Solution: Aligned README requirement with actual package.json

Technology: Documentation

View PR →
Skills

Engineering Domains

Core technologies organized by the engineering domains I work in.

Data Engineering

PythonSQLPySparkApache SparkETL/ELTData ModelingData QualitySchema Validation

Streaming

Apache KafkaStructured StreamingEvent HubsExactly-OnceWatermarking

Lakehouse / Cloud

DatabricksDelta LakeMicrosoft FabricAzure Event HubsADLS Gen2

AI Engineering

RAGLLMsVector DatabasesOpenAIChromaDBFastAPIStreamlit

DevOps / Engineering

GitGitHub ActionsGitLab CI/CDDockerTerraformLinuxpytestJira

Testing & Quality

pytestunittestMockingData ValidationReconciliationCI/CD
Certifications

Validated Technical Expertise

Industry-recognized credentials that back the skills and projects displayed here.

Databricks PySpark Streaming Training

Accenture

December 2023 - February 2024

Google Data Analytics Professional

Coursera

2023

Verify Credential →

NPTEL Management Information System (MIS)

IIT Kharagpur

Elite · 73% · July–October 2022

Verify Credential →
Blog

Engineering Notes

Deep dives into data platform engineering, streaming patterns, and career learnings.

Streaming Data Engineering 8 min read

Building a Kafka → PySpark → Delta Pipeline

Hands-on guide to production PySpark Structured Streaming with Kafka, Delta Lake, and cloud deployment.

Read Article →
RAG & LLM 6 min read

Building a RAG QA System with FastAPI and ChromaDB

How to build a retrieval-augmented generation chatbot with document ingestion, vector search, and LLM generation.

Read Article →
Certification 5 min read

How I Passed the Databricks DE Associate Exam

My study plan, resources, tips, and what actually helped me pass the Databricks Data Engineer Associate exam.

Read Article →
Education

Academic Background

B.Tech in Computer Science and Technology

Madanapalle Institute of Technology & Science, Madanapalle, AP
2019–2023 · 7.97 CGPA · First Class Distinction

Intermediate

Sri Vivekananda Junior College, Chittoor, AP
2017–2019 · 9.67 CGPA

10th Grade

Z.P.H.S Kanipkam, Chittoor, AP
2016–2017 · 9.3 CGPA

JEE Mains

94.17 Percentile · 2019

Why Work With Me

Proven Production Impact

Quantifiable results and engineering discipline that delivers reliable data systems.

Python
Development
Automation
Engineering
Databricks
Certified Professional
14+
OSS Contributions
System
Integration
Production
Operations Experience
Contact

Let's Build Reliable Data Systems

I'm open to Data Engineer, Data Platform Engineering, and Streaming roles. Reach out if you're hiring or want to collaborate on data platforms.

Email Me LinkedIn GitHub Resume
📍 Bengaluru, India 🌐 Open to Remote ⏱️ Response within 24 hours