46 lines
1.6 KiB
Python
46 lines
1.6 KiB
Python
"""
|
|
API для RAG: индексация документов и ответы на вопросы
|
|
"""
|
|
from fastapi import APIRouter, status
|
|
from dishka.integrations.fastapi import FromDishka
|
|
from src.presentation.schemas.rag_schemas import (
|
|
QuestionRequest,
|
|
RAGAnswer,
|
|
IndexDocumentRequest,
|
|
IndexDocumentResponse,
|
|
)
|
|
from src.application.use_cases.rag_use_cases import RAGUseCases
|
|
from src.domain.entities.user import User
|
|
|
|
|
|
router = APIRouter(prefix="/rag", tags=["rag"])
|
|
|
|
|
|
@router.post("/index", response_model=IndexDocumentResponse, status_code=status.HTTP_200_OK)
|
|
async def index_document(
|
|
body: IndexDocumentRequest,
|
|
use_cases: FromDishka[RAGUseCases] = FromDishka(),
|
|
current_user: FromDishka[User] = FromDishka(),
|
|
):
|
|
"""Индексирование идет через чанкирование, далее эмбеддинг и загрузка в векторную бд"""
|
|
result = await use_cases.index_document(body.document_id)
|
|
return IndexDocumentResponse(**result)
|
|
|
|
|
|
@router.post("/question", response_model=RAGAnswer, status_code=status.HTTP_200_OK)
|
|
async def ask_question(
|
|
body: QuestionRequest,
|
|
use_cases: FromDishka[RAGUseCases] = FromDishka(),
|
|
current_user: FromDishka[User] = FromDishka(),
|
|
):
|
|
"""Отвечает на вопрос, используя RAG в рамках беседы"""
|
|
result = await use_cases.ask_question(
|
|
conversation_id=body.conversation_id,
|
|
user_id=current_user.user_id,
|
|
question=body.question,
|
|
top_k=body.top_k,
|
|
rerank_top_n=body.rerank_top_n,
|
|
)
|
|
return RAGAnswer(**result)
|
|
|