From 28f41fceef54144cf87eaedd18d09a5a8b9cd5e1 Mon Sep 17 00:00:00 2001
From: zhaoqingang <zhaoqg0118@163.com>
Date: 星期三, 27 十一月 2024 09:40:58 +0800
Subject: [PATCH] dify 多次对话问题
---
app/service/difyService.py | 22 +++++++++++++++++-----
1 files changed, 17 insertions(+), 5 deletions(-)
diff --git a/app/service/difyService.py b/app/service/difyService.py
index 9aee918..78daa44 100644
--- a/app/service/difyService.py
+++ b/app/service/difyService.py
@@ -6,7 +6,6 @@
from fastapi import HTTPException
from starlette import status
-from Log import logger
from app.config.config import settings
from app.utils.rsa_crypto import RagflowCrypto
@@ -83,7 +82,7 @@
"inputs": {},
"query": message,
"response_mode": "streaming",
- "conversation_id": "",
+ "conversation_id": conversation_id,
"user": str(user_id),
"files": files
}
@@ -141,14 +140,27 @@
return data
+ async def save_images(self, url: str, filename: str):
+ url = f"{self.base_url}{url}"
+
+ async with httpx.AsyncClient() as client:
+ response = await client.get(url)
+
+ response.raise_for_status()
+
+ # 鎵撳紑涓�涓枃浠剁敤浜庡啓鍏�
+ with open(f"app/images/{filename}", 'wb') as f:
+ # 鍐欏叆璇锋眰鐨勫唴瀹�
+ f.write(response.content)
+
if __name__ == "__main__":
async def a():
- a = DifyService("http://192.168.20.119:11080")
- b = await a.get_knowledge_list("ImY3ZTZlZWQwYTY2NTExZWY5ZmFiMDI0MmFjMTMwMDA2Ig.Zzxwmw.uI_HAWzOkipQuga1aeQtoeIc3IM", 1,
- 10)
+ a = DifyService("http://192.168.20.116")
+ b = await a.get_session_history("app-YmOAMDsPpDDlqryMHnc9TzTO", "f94c6328-8ff0-4713-af3f-e823d547682d",
+ "63")
print(b)
import asyncio
--
Gitblit v1.8.0