From 2669d0e0a93e06983dade724146bd0e1b6da6ba7 Mon Sep 17 00:00:00 2001 From: zhaoqingang <zhaoqg0118@163.com> Date: 星期二, 12 十一月 2024 18:42:05 +0800 Subject: [PATCH] 增加接口 --- app/service/ragflow.py | 56 +++++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 45 insertions(+), 11 deletions(-) diff --git a/app/service/ragflow.py b/app/service/ragflow.py index b5c5dd1..d5d4726 100644 --- a/app/service/ragflow.py +++ b/app/service/ragflow.py @@ -1,5 +1,8 @@ import httpx from typing import Union, Dict, List +from fastapi import HTTPException +from starlette import status + from app.config.config import settings from app.utils.rsa_crypto import RagflowCrypto @@ -8,12 +11,17 @@ def __init__(self, base_url: str): self.base_url = base_url - async def _handle_response(self, response: httpx.Response) -> Union[Dict, List]: + def _handle_response(self, response: httpx.Response) -> Union[Dict, List]: if response.status_code != 200: return {} data = response.json() ret_code = data.get("retcode") + if ret_code == 401: + raise HTTPException( + status_code=status.HTTP_401_UNAUTHORIZED, + detail="鐧诲綍杩囨湡", + ) if ret_code != 0: return {} @@ -31,10 +39,11 @@ response = await client.post( f"{self.base_url}/v1/user/register", headers={'Content-Type': 'application/json'}, - json={"nickname": username, "email": f"{username}@example.com", "password": password} + json={"nickname": username, "email": f"{username}@example.com", "password": password} ) if response.status_code != 200: raise Exception(f"Ragflow registration failed: {response.text}") + return self._handle_response(response) async def login(self, username: str, password: str) -> str: password = RagflowCrypto(settings.PUBLIC_KEY, settings.PRIVATE_KEY).encrypt(password) @@ -56,8 +65,11 @@ "conversation_id": chat_id, "messages": chat_history } + + print(f"send to ragflow chat: {data}") + target_url = f"{self.base_url}/v1/conversation/completion" - async with httpx.AsyncClient() as client: + async with httpx.AsyncClient(timeout=300.0) as client: headers = { 'Content-Type': 'application/json', 'Authorization': token @@ -66,6 +78,7 @@ if response.status_code == 200: try: async for answer in response.aiter_text(): + print(f"response of ragflow chat: {answer}") yield answer except GeneratorExit as e: print(e) @@ -78,7 +91,7 @@ headers = {"Authorization": token} async with httpx.AsyncClient() as client: response = await client.get(url, headers=headers) - data = await self._handle_response(response) + data = self._handle_response(response) result = [ { "id": item["id"], @@ -89,26 +102,26 @@ ] return result - async def set_session(self, token: str, dialog_id: str, name: str, chat_id: str, is_new: bool) -> list: + async def set_session(self, token: str, dialog_id: str, message: dict, chat_id: str, is_new: bool) -> list: url = f"{self.base_url}/v1/conversation/set?dialog_id={dialog_id}" headers = {"Authorization": token} data = { "dialog_id": dialog_id, - "name": name, + "name": message["message"], "is_new": is_new, "conversation_id": chat_id, } async with httpx.AsyncClient() as client: response = await client.post(url, headers=headers, json=data) - data = await self._handle_response(response) + data = self._handle_response(response) return [ { "content": "浣犲ソ锛� 鎴戞槸浣犵殑鍔╃悊锛屾湁浠�涔堝彲浠ュ府鍒颁綘鐨勫悧锛�", "role": "assistant" }, { - "content": name, - "doc_ids": [], + "content": message["message"], + "doc_ids":message.get("doc_ids", []), "role": "user" } ] if data else [] @@ -118,5 +131,26 @@ headers = {"Authorization": token} async with httpx.AsyncClient() as client: response = await client.get(url, headers=headers) - data = await self._handle_response(response) - return data.get("message", []) \ No newline at end of file + data = self._handle_response(response) + return data.get("message", []) + + async def upload_and_parse(self, token: str, chat_id: str, filename: str, file: bytes) -> str: + url = f"{self.base_url}/v1/document/upload_and_parse" + headers = {"Authorization": token} + data = {"conversation_id": chat_id} + + # 鍒涘缓琛ㄥ崟鏁版嵁锛屽寘鍚枃浠� + files = {"file": (filename, file)} + async with httpx.AsyncClient(timeout=60) as client: + response = await client.post(url, headers=headers, files=files, data=data) + data = self._handle_response(response) + return data + + async def add_user_tenant(self, token: str, tenant_id: str, email: str, user_id: str) -> str: + url = f"{self.base_url}/v1/tenant/{tenant_id}/user" + headers = {"Authorization": token} + data = {"email": email, "user_id": user_id} + async with httpx.AsyncClient(timeout=60) as client: + response = await client.post(url, headers=headers, json=data) + if response.status_code != 200: + raise Exception(f"Ragflow add user to tenant failed: {response.text}") -- Gitblit v1.8.0