RAG-Pipeline mit LangGraph

from langchain_openai import ChatOpenAI
from langchain_core.tools import tool
from langgraph.prebuilt import create_react_agent

@tool
def search_documents(query: str, top_k: int = 5) -> str:
    """Search uploaded documents for relevant content."""
    results = vector_store.similarity_search(query, k=top_k)
    return "\n\n".join(
        f"[{i+1}] {r.metadata.get('source', 'unknown')}: {r.page_content}"
        for i, r in enumerate(results)
    )

agent = create_react_agent(
    ChatOpenAI(model="gpt-4o"),
    tools=[search_documents],
    prompt="You are a document Q&A assistant. Search documents before answering. Cite sources using [1], [2] format.",
)

result = await agent.ainvoke({
    "messages": [("user", "What does the refund policy say about digital products?")]
})
print(result["messages"][-1].content)