Spaces:
Sleeping
Sleeping
File size: 4,048 Bytes
a031bc7 e77086b a031bc7 e6b2892 a031bc7 e77086b a031bc7 e6b2892 a031bc7 e6b2892 a031bc7 e6b2892 a031bc7 e6b2892 a031bc7 e6b2892 a031bc7 e6b2892 a031bc7 e6b2892 a031bc7 e6b2892 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 | import os
import json
import logging
from datetime import datetime, timedelta
from flask import Flask, request, jsonify
from recommender import recommend_products
from flask_cors import CORS
# --- Configure Logging ---
logging.basicConfig(
level=logging.INFO,
format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
handlers=[
logging.FileHandler('app.log'),
logging.StreamHandler()
]
)
logger = logging.getLogger(__name__)
# --- Initialize Flask App and CORS ---
app = Flask(__name__)
CORS(app, resources={r"/api/*": {"origins": "*"}})
@app.route('/recommend/<int:user_id>', methods=['GET'])
def get_recommendations(user_id):
logger.info(f"=== RECOMMENDATION REQUEST START ===")
logger.info(f"Input - User ID: {user_id}")
logger.info(f"Request method: {request.method}")
logger.info(f"Request headers: {dict(request.headers)}")
logger.info(f"Request args: {dict(request.args)}")
try:
# Get optional parameters
top_n = request.args.get('top_n', default=5, type=int)
logger.info(f"Parameters - top_n: {top_n}")
logger.info("Calling recommend_products function...")
recommendations = recommend_products(user_id, top_n)
response_data = {
"user_id": user_id,
"recommendations": recommendations,
"total_recommendations": len(recommendations),
"timestamp": datetime.now().isoformat()
}
logger.info(f"Success - Generated {len(recommendations)} recommendations for user {user_id}")
logger.info(f"Output - Response data keys: {list(response_data.keys())}")
logger.info(f"Output - Recommendation IDs: {[r.get('id') for r in recommendations if isinstance(r, dict)]}")
logger.info(f"=== RECOMMENDATION REQUEST END ===")
return jsonify(response_data)
except Exception as e:
logger.error(f"=== RECOMMENDATION REQUEST FAILED ===")
logger.error(f"Error type: {type(e).__name__}")
logger.error(f"Error message: {str(e)}")
logger.exception("Full traceback:")
error_response = {
"error": str(e),
"user_id": user_id,
"timestamp": datetime.now().isoformat()
}
logger.error(f"Returning error response: {error_response}")
return jsonify(error_response), 500
@app.route('/health', methods=['GET'])
def health_check():
logger.info("=== HEALTH CHECK REQUEST ===")
response = {
"status": "healthy",
"timestamp": datetime.now().isoformat(),
"service": "recommendation-api"
}
logger.info(f"Health check response: {response}")
return jsonify(response)
@app.errorhandler(404)
def not_found(error):
logger.warning(f"404 Error - Path: {request.path}, Method: {request.method}")
return jsonify({"error": "Endpoint not found"}), 404
@app.errorhandler(500)
def internal_error(error):
logger.error(f"500 Error - Path: {request.path}, Method: {request.method}")
logger.exception("Internal server error:")
return jsonify({"error": "Internal server error"}), 500
# -----------------------------------------------------------------------------
# SERVER EXECUTION
# -----------------------------------------------------------------------------
if __name__ == '__main__':
port = int(os.environ.get("PORT", 7860))
debug_mode = os.environ.get("FLASK_DEBUG", "False").lower() == "true"
logger.info(f"=== STARTING RECOMMENDATION SERVER ===")
logger.info(f"Debug mode: {debug_mode}")
logger.info(f"Port: {port}")
logger.info(f"Environment variables: PORT={os.environ.get('PORT')}, FLASK_DEBUG={os.environ.get('FLASK_DEBUG')}")
if not debug_mode:
logger.info("Using Waitress server for production")
from waitress import serve
serve(app, host="0.0.0.0", port=port)
else:
logger.info("Using Flask development server")
app.run(debug=True, host="0.0.0.0", port=port) |