From 0d11657e07dff84cfe118eb446efdb645a3c735f Mon Sep 17 00:00:00 2001 From: zhaoqingang <zhaoqg0118@163.com> Date: 星期三, 13 十一月 2024 15:17:04 +0800 Subject: [PATCH] Merge branch 'master' of http://192.168.5.5:10010/r/rag-gateway --- app/service/bisheng.py | 22 ++++++++++++++++++++++ 1 files changed, 22 insertions(+), 0 deletions(-) diff --git a/app/service/bisheng.py b/app/service/bisheng.py index ad5d084..77473f5 100644 --- a/app/service/bisheng.py +++ b/app/service/bisheng.py @@ -73,6 +73,28 @@ ] return result + async def get_session_log(self, token: str, agent_id: str, conversation_id: str): + url = ( + f"{self.base_url}/api/v1/chat/history?" + f"flow_id={agent_id}&" + f"chat_id={conversation_id}&page_size=30&id=" + ) + headers = {'cookie': f"access_token_cookie={token};"} + async with httpx.AsyncClient() as client: + response = await client.get(url, headers=headers) + response.raise_for_status() + data = self._check_response(response) + session_log = { + "session_log": [ + { + "message": message.get("intermediate_steps"), + "role": message.get("category"), + } + for message in data + ], + } + return session_log + async def variable_list(self, token: str, agent_id: str) -> list: url = f"{self.base_url}/api/v1/variable/list?flow_id={agent_id}" headers = {'cookie': f"access_token_cookie={token};"} -- Gitblit v1.8.0