mirror of
https://github.com/infiniflow/ragflow.git
synced 2025-10-31 01:40:20 +00:00
c5a3146a8c
### What problem does this PR solve? Modify the response of metadata in Dify retrieval api resolve #2914 ### Type of change - [x] Bug Fix (non-breaking change which fixes an issue)
78 lines
2.8 KiB
Python
78 lines
2.8 KiB
Python
#
|
|
# Copyright 2024 The InfiniFlow Authors. All Rights Reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
#
|
|
from flask import request, jsonify
|
|
|
|
from api.db import LLMType, ParserType
|
|
from api.db.services.knowledgebase_service import KnowledgebaseService
|
|
from api.db.services.llm_service import LLMBundle
|
|
from api.settings import retrievaler, kg_retrievaler, RetCode
|
|
from api.utils.api_utils import validate_request, build_error_result, apikey_required
|
|
|
|
|
|
@manager.route('/dify/retrieval', methods=['POST'])
|
|
@apikey_required
|
|
@validate_request("knowledge_id", "query")
|
|
def retrieval(tenant_id):
|
|
req = request.json
|
|
question = req["query"]
|
|
kb_id = req["knowledge_id"]
|
|
retrieval_setting = req.get("retrieval_setting", {})
|
|
similarity_threshold = float(retrieval_setting.get("score_threshold", 0.0))
|
|
top = int(retrieval_setting.get("top_k", 1024))
|
|
|
|
try:
|
|
|
|
e, kb = KnowledgebaseService.get_by_id(kb_id)
|
|
if not e:
|
|
return build_error_result(error_msg="Knowledgebase not found!", retcode=RetCode.NOT_FOUND)
|
|
|
|
if kb.tenant_id != tenant_id:
|
|
return build_error_result(error_msg="Knowledgebase not found!", retcode=RetCode.NOT_FOUND)
|
|
|
|
embd_mdl = LLMBundle(kb.tenant_id, LLMType.EMBEDDING.value, llm_name=kb.embd_id)
|
|
|
|
retr = retrievaler if kb.parser_id != ParserType.KG else kg_retrievaler
|
|
ranks = retr.retrieval(
|
|
question,
|
|
embd_mdl,
|
|
kb.tenant_id,
|
|
[kb_id],
|
|
page=1,
|
|
page_size=top,
|
|
similarity_threshold=similarity_threshold,
|
|
vector_similarity_weight=0.3,
|
|
top=top
|
|
)
|
|
records = []
|
|
for c in ranks["chunks"]:
|
|
if "vector" in c:
|
|
del c["vector"]
|
|
records.append({
|
|
"content": c["content_ltks"],
|
|
"score": c["similarity"],
|
|
"title": c["docnm_kwd"],
|
|
"metadata": {}
|
|
})
|
|
|
|
return jsonify({"records": records})
|
|
except Exception as e:
|
|
if str(e).find("not_found") > 0:
|
|
return build_error_result(
|
|
error_msg=f'No chunk found! Check the chunk status please!',
|
|
retcode=RetCode.NOT_FOUND
|
|
)
|
|
return build_error_result(error_msg=str(e), retcode=RetCode.SERVER_ERROR)
|