{"owner":"Victor-Kipruto-Rop","github":"https://github.com/Victor-Kipruto-Rop","claimed":false,"inventory":[],"indexed":[{"repo":"Victor-Kipruto-Rop/Real_Time_Transaction_Streaming-MPESA-","github":"https://github.com/Victor-Kipruto-Rop/Real_Time_Transaction_Streaming-MPESA-","description":"Real-Time M-Pesa Transaction Streaming Pipeline built using modern data engineering technologies to ingest, process, stream, and analyze transaction data in real time. Demonstrates event-driven architecture, stream processing, data pipelines, and scalable analytics for fintech applications.","language":"Python","stars":28,"topics":["apache","apache-kafka","apache-spark","data-engineering","data-pipeline","data-pipeline-monitoring","etl","etl-pipeline","postgresql","real-time-streaming"],"license":null,"category":"data-pipelines"},{"repo":"Victor-Kipruto-Rop/cloud-etl-pipeline","github":"https://github.com/Victor-Kipruto-Rop/cloud-etl-pipeline","description":"Built a scalable cloud ETL pipeline using Python, PostgreSQL, Pandas, and Docker to efficiently process, clean, and load over 1.6 million records with optimized batch processing, fault tolerance, and automated data validation.","language":"Python","stars":27,"topics":["data-engineering","etl","aws","cloud","postresql","python","terraform","warehouse","grafana","playbook"],"license":"MIT","category":"data-pipelines"},{"repo":"Victor-Kipruto-Rop/mpesa_safaricom-pipeline-","github":"https://github.com/Victor-Kipruto-Rop/mpesa_safaricom-pipeline-","description":"End-to-end M-Pesa data pipeline for extracting, transforming, validating, and storing transaction data using Python, SQL, Airflow, and PostgreSQL.","language":"Python","stars":26,"topics":["data-pipeline","data-processing","workflow-orchestration","mpesa","safaricom-mpesa","safaricom-mpesa-apis"],"license":null,"category":"data-pipelines"},{"repo":"Victor-Kipruto-Rop/SQL-for-Data","github":"https://github.com/Victor-Kipruto-Rop/SQL-for-Data","description":"SQL practice repository covering data analysis, joins, aggregations, window functions, and real-world query solving for data engineering and analytics.","language":"Shell","stars":26,"topics":["data-analysis","data-engineering","data-warehouse","joins","mysql","querying","sql","window-functions"],"license":null,"category":"databases-storage"},{"repo":"Victor-Kipruto-Rop/CAMPUSHUB","github":"https://github.com/Victor-Kipruto-Rop/CAMPUSHUB","description":"Built CAMPUSHUB, a centralized campus management platform that streamlines student collaboration, communication, and resource sharing through a modern full-stack web application with secure authentication and responsive design.","language":"Python","stars":26,"topics":["express","git","github","github-actions","javascript","jwt-authentication","nodejs","postgresql","reactjs","rest-api"],"license":null,"category":"databases-storage"},{"repo":"Victor-Kipruto-Rop/Data-Enginerring-full-project","github":"https://github.com/Victor-Kipruto-Rop/Data-Enginerring-full-project","description":"Designed and implemented a full-scale Data Engineering solution, covering data ingestion, transformation, orchestration, storage, monitoring, and analytics using industry-standard tools and cloud technologies to deliver reliable, scalable, and business-ready data pipelines.","language":"Python","stars":26,"topics":["apache-airflow","apache-kafka","apache-spark","dbt","docker","git","github","github-actions","pandas","postegresql"],"license":null,"category":"data-pipelines"},{"repo":"Victor-Kipruto-Rop/victor-kipruto-rop-portfolio","github":"https://github.com/Victor-Kipruto-Rop/victor-kipruto-rop-portfolio","description":"End-to-end Data Engineering portfolio covering ETL, streaming, fraud detection, and financial analytics across M-Pesa, KCB, Equity Group, Absa, and KRA — with live Streamlit dashboards.","language":"Python","stars":26,"topics":["absa","apache","apache-spark","equity","financial-analysis","financial-data","grafana","k8s","kafka","kcb"],"license":null,"category":"data-pipelines"},{"repo":"Victor-Kipruto-Rop/streaming-pipeline","github":"https://github.com/Victor-Kipruto-Rop/streaming-pipeline","description":"Real-time data streaming pipeline built with modern data engineering tools for scalable ingestion, processing, transformation, and analytics of continuous data streams.","language":"Python","stars":24,"topics":["github","shell","consumers","docker","monitoring","processors","producers","python","data","data-engineering"],"license":null,"category":"data-pipelines"},{"repo":"Victor-Kipruto-Rop/mpesa_safaricom-fraud_anomaly_detection","github":"https://github.com/Victor-Kipruto-Rop/mpesa_safaricom-fraud_anomaly_detection","description":"Real-time fraud detection engine for M-Pesa mobile money — Kafka/Flink streaming, ML-based risk scoring, and explainable multi-signal checks (velocity, SIM swap correlation, mule networks) feeding an interaction-aware decision engine, with a full production pipeline from ingestion through dbt analytics.","language":"Python","stars":12,"topics":["anomaly-detection","daraja-api","fraud-detection","mpesa","mpesa-api","safaricom","apache","apache-flink","apache-kafka","apache-spark"],"license":null,"category":"machine-learning"}],"how_to_buy":"GET /r/Victor-Kipruto-Rop/<repo> (Accept: application/json) for any listed repo here: tree, README, price and the checkout to pay (x402; rehearse first at its test twin, simulated money). Repos under 'indexed' are free: clone them from GitHub."}