From a5630f77b3f6c5c6c3018b3fad8fffcf1fc32f73 Mon Sep 17 00:00:00 2001
From: martsforever <martsforever@aliyun.com>
Date: Wed, 29 Oct 2025 17:03:50 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20milvus=E6=A3=80=E7=B4=A2=E7=9A=84?=
 =?UTF-8?q?=E6=97=B6=E5=80=99=E6=89=8B=E5=8A=A8=E8=BF=87=E6=BB=A4=E5=88=86?=
 =?UTF-8?q?=E6=95=B0=E8=BF=87=E4=BD=8E=E7=9A=84=E6=A3=80=E7=B4=A2=E6=96=87?=
 =?UTF-8?q?=E6=A1=A3=E5=9D=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/utils/milvus_utils.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/app/utils/milvus_utils.py b/app/utils/milvus_utils.py
index 62b4adc..ddc333e 100644
--- a/app/utils/milvus_utils.py
+++ b/app/utils/milvus_utils.py
@@ -95,6 +95,7 @@ class MilvusService:
     retriever = vector_index.as_retriever(filters=filters, similarity_top_k=param.top_k)
 
     result_nodes = await retriever.aretrieve(param.question)
+    result_nodes = [node for node in result_nodes if node.score >= 0.3]
 
     chain = ChatPromptTemplate.from_template("""
         你将收到一个用户问题和一组来自LlamaIndex的检索结果。你的任务是：
@@ -124,6 +125,9 @@ class MilvusService:
 
     relative_content = await chain.ainvoke(chain_input)
 
+    # print("milvus search answer", relative_content)
+    # print("milvus search nodes", [node.node.text for node in result_nodes])
+
     return MilvusSearchResponse(
       answer=relative_content,
       nodes=[