|
|
|
@ -65,10 +65,13 @@ async def rag(request: fastapi.Request):
|
|
|
|
|
print("Initializing RAG...")
|
|
|
|
|
rag = await initialize_rag(working_dir="./Test/Math")
|
|
|
|
|
print("RAG initialized, starting query...")
|
|
|
|
|
resp = await rag.aquery(query=query, stream=True)
|
|
|
|
|
resp = await rag.aquery(
|
|
|
|
|
query=query,
|
|
|
|
|
param=QueryParam(mode="hybrid", stream=True))
|
|
|
|
|
print("Query started, streaming response...")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
async for chunk in resp:
|
|
|
|
|
#print(f"Processing chunk: {chunk[:50]}...") # 打印前50个字符
|
|
|
|
|
if not chunk:
|
|
|
|
|
continue
|
|
|
|
|
|
|
|
|
|