Enterprise AI Platform API & Agentic Systems
ServiceNow · since 2024
I architected a unified, governed backend platform API around Snowflake
Cortex Analyst and Cortex Agent, and run it for 8 internal engineering teams with strict
latency, authentication, and throughput controls. I also integrated enterprise agentic workflows and
Microsoft Teams, with secure payload validation, role-based access, and rate limiting.
Impact: handles ~50,000 requests/day and expanded automated domain
coverage across 5 new business areas.
Go, Python, Snowflake Cortex, Agentic Workflows, Evals, REST, Microsoft Teams
Real-Time CDC Event Streaming (Kafka + Debezium)
Thoughtworks · data platform
I built and ran an event-driven Change Data Capture pipeline on an HDInsight Kafka
cluster with Debezium connectors. It picks up transactional changes from the source databases as they
happen and pushes them to downstream analytics engines and data catalogs, without adding lock contention
on the primary OLTP tables.
Impact: handled ~2,000,000 CDC events/day with sub-second event
propagation, supporting both continuous streaming and ~5 TB/day batch Spark pipelines.
Apache Kafka, Debezium, Event-Driven Architecture, Apache Airflow, HDInsight, Python
Kubernetes Calico Micro-Segmentation & CD4ML Pipeline
Thoughtworks · healthcare and Daimler
I locked down production Kubernetes clusters with Calico network
policies, isolating namespace traffic and shrinking the pod-to-pod attack surface. On the
Daimler DataOps work, I built a standard Continuous Delivery for Machine Learning pipeline with MLflow,
DVC, and Jenkins so model training and deployments were reproducible and versioned.
Impact: cut the ML model deployment cycle from ~3 days to under 3 hours
and resolved 12 critical security findings in the data-catalog applications.
Kubernetes, Calico, CD4ML, MLflow, DVC, Jenkins, HDFS
High-Velocity Notification Engine & GCP Automation
BeautifulCode · Sojern, travel ad-tech
I designed a scalable notification engine in Go and gRPC that
streamed high-throughput campaign and booking updates across the travel ad-tech services. I also
automated test-environment provisioning on Google Cloud Platform with infrastructure as code.
Impact: cut staging setup from ~4 hours to ~15 minutes and kept
campaign and booking updates flowing at high throughput.
Go, gRPC, Python, Django, React, Google Cloud, Docker