SWYM projects
SWYM / RECOMMENDATION SYSTEMSProduction experience

Recommendation Pipelines at Scale with Databricks & Spark

Production data and ML pipelines that turn customer interactions into personalized product recommendations.

PythonDatabricksSparkRecommendersML pipelines
SYSTEM OVERVIEW
the pieces, connected.
Customer interactions (Commerce behavior) → Process interaction data (Python + Spark) → Recommendation pipeline (Databricks + Recommenders) → Personalized feeds (Product recommendations)

A public sketch of the documented components and workflow. Internal interfaces are omitted.

Download full-resolution SVG
THE PROBLEM

Where the work started.

Merchants need product recommendations informed by customer behavior. Interaction data must move through reliable processing and ML pipelines before it can support personalized feeds.

MY CONTRIBUTION

What I built.

  • Developed a production recommendation system on Databricks.
  • Built pipelines to process customer interaction data for personalized product feeds.
  • Worked across Python, Spark and ML workflows to connect data processing with recommendation delivery.
THE RESULT
1M+user interactions processed daily

Delivered personalized product recommendations through production data and ML pipelines.

Selected work from my engineering role at SWYM. Impact figures are reported from this work; the companion examples below use synthetic data.

CODE & EVALUATION

Inspect the work behind the explanation.

Library used in this project

The open-source recommendation library used in this work. This link points to the upstream library.

Recommenders library on GitHub
SYNTHETIC COMPANION EXAMPLE

Ranking quality for recommended products

A new, runnable example that scores saved predictions against expected outputs. It uses fictional data and illustrates evaluation mechanics; it does not reproduce the production system or substantiate the impact figures above.

python3 evaluate_outputs.py recommendations.json report.json

Python 3.10+ · Standard library only · Includes fixtures, metric definitions and tests

Explore more projects Discuss this project