Daniel Malungu

Dec 2021 – Present · Nairobi, Kenya

• Designed and administer PostgreSQL 17 production clusters with hybrid master-replica topology using repmgr HA and PgBouncer connection pooling
• Scaled cluster throughput from 1,000 TPS to 10,000 TPS through architectural redesign and query optimization
• Hardened production databases with SCRAM-SHA-256 authentication, audit triggers, and automated backup scripts across 31+ databases
• Built and maintain ETL/ELT pipelines in Python, Apache Airflow, and SQL for land transaction and records data
• Implemented PeerDB change data capture replication from production OLTP to data warehouse with custom schema mapping
• Led digitization of 5 million+ land records through a custom EDMS including a bulk document ingestion ETL tool
• Designed and implemented CI/CD pipelines with GitHub Actions for automated data pipeline testing and production deployments
• Served as Scrum Master for the data engineering team — sprint planning, backlog grooming, and agile coaching

• PostgreSQL 17
• PeerDB
• Airflow
• Python
• dbt
• Airbyte
• MinIO
• Docker Compose
• GitHub Actions
• Rocky Linux
• nginx
• Nagios
• ELK Stack

Oct 2024 – Present · Independent Project

• Shortlisted from 2,467 proposals across 5,656 national registrants — NIRU National AI Hackathon 2025, Governance & Policy track
• Architected a 3-node Ollama GPU inference cluster (RTX 3050s) running Qwen2.5:7b — fully self-hosted with no external API dependency
• Built a LangGraph agentic RAG pipeline: Planner → Retriever → Responder with IRAC legal prompting and streaming NDJSON responses
• Implemented semantic caching (Qdrant + Redis, cosine > 0.95, 30-day TTL) to reduce redundant inference
• Qdrant vector search across Kenya Law Reports with a Neo4j citation graph (CITES, OVERRULES, DISTINGUISHES relationships)
• FastAPI microservices with JWT RBAC, Prometheus metrics, and OpenTelemetry tracing
• M-Pesa STK Push payments via Safaricom Daraja API with a FastAPI callback on Railway
• Next.js streaming frontend with admin panel, ingestion job monitor, and health dashboard

• Python
• FastAPI
• LangGraph
• Ollama
• Qdrant
• Neo4j
• PostgreSQL
• MinIO
• Next.js
• Docker Compose
• Redis

Mar 2022 – Nov 2022 · Kenya (concurrent with ArdhiSasa engagement)

• Led full migration of all data pipelines from Xplenty to Prefect orchestration on AWS EC2 — achieving centralized logging and significant cost reduction
• Wrote dbt transformations following the Kimball dimensional modelling approach for an enterprise Snowflake data warehouse
• Built a CI pipeline from scratch in GitHub Actions for automated dbt model testing and fast feedback for contributors
• Introduced SQLFluff for automated SQL quality enforcement, improving team delivery speed by 80%

• dbt
• Snowflake
• Prefect
• Python
• SQL
• GitHub Actions
• AWS EC2
• SQLFluff

Jan 2016 – Dec 2018 · Nairobi, Kenya

• Built a chatbot system for back-office customer support using TensorFlow, deployed on a microservices architecture
• Developed and launched an online academic marketplace, growing it to 200+ active users from zero
• Designed deployment architecture using microservices principles for scalability and maintainability

• Python
• TensorFlow
• SQL
• Microservices

Nov 2015 – Sep 2016 · Nairobi, Kenya

• Built a smart water meter system on an IoT/NB-IoT platform with bi-directional communication between field sensors and back-office
• Reduced water losses for two water utility companies by 30% through real-time sensor-based incident detection

• Python
• Django REST Framework
• PyQt
• NB-IoT