|
from fastapi import FastAPI, HTTPException,Query,Request,BackgroundTasks |
|
import json |
|
import os |
|
import requests |
|
from extract_insights import extract_fashion_categories |
|
|
|
app = FastAPI() |
|
|
|
@app.post("/update_fashion_categories") |
|
async def process_document_base64(request: Request,background_tasks: BackgroundTasks): |
|
request_data = await request.json() |
|
user_id = request_data.get('user_id') |
|
message_id = request_data.get('message_id') |
|
email = request_data.get('email') |
|
await extract_fashion_categories(user_id,email,message_id) |
|
|
|
|
|
return {"status":'Processing and Updating the data to db!'} |
