diff --git a/core/routes/api.py b/core/routes/api.py
index fca09e6..075d642 100644
--- a/core/routes/api.py
+++ b/core/routes/api.py
@@ -27,6 +27,7 @@
 from core.routes.social_auth import router as social_api_router
 from core.routes.stream_api import router as stream_api_router
 from core.routes.workspace_api import router as workspace_api_router
+from core.routes.shopify_api import router as shopify_api_router
 from valmi_app_backend.utils import BearerAuthentication
 
 from core.models import User
@@ -154,3 +155,4 @@ def list_spaces(request):
 router.add_router("", prompt_api_router, tags=["prompts"])
 router.add_router("", explore_api_router, tags=["explores"])
 router.add_router("", connector_api_router, tags=["connectors"])
+router.add_router("", shopify_api_router, tags=["shopify"])
diff --git a/core/routes/shopify_api.py b/core/routes/shopify_api.py
new file mode 100644
index 0000000..290c612
--- /dev/null
+++ b/core/routes/shopify_api.py
@@ -0,0 +1,18 @@
+import logging
+
+from ninja import Router
+from pydantic import Json
+import requests
+
+router = Router()
+
+# Get an instance of a logger
+logger = logging.getLogger(__name__)
+
+
+@router.get("/products/{product_id}/recommendations", response={200: dict, 500: Json})
+def get_prompts(request, product_id):
+    response = requests.get(
+        f'https://thebleulabel.myshopify.com/recommendations/products.json?product_id={product_id}&intent=related')
+    logger.debug(response)
+    return response.json()