增加删除

zhaoqingang

2024-11-19 9c275b214f9619a64cd2998596ce696610185eb4

 app/task/sync_resources.py

@@ -1,3 +1,5 @@
import asyncio

from fastapi import Depends

from Log import logger
@@ -9,11 +11,12 @@
from app.service.ragflow import RagflowService


async def sync_resource():
    await sync_knowledge()
    await sync_dialog()
    await sync_agent()
    await sync_llm()
def sync_resource():
    asyncio.run(sync_knowledge())
    asyncio.run(sync_dialog())
    asyncio.run(sync_agent())
    asyncio.run(sync_llm())


async def sync_knowledge(db=Depends(get_db)):

@@ -24,12 +27,14 @@
        if rapp.app_type == AgentType.RAGFLOW:
            token = ""
            ragflow_service = RagflowService(settings.fwr_base_url)
            ragflow_service.get_knowledge_list()
        elif rapp.app_type ==AgentType.BISHENG:
            token = ""
            bisheng_service = BishengService(settings.sgb_base_url)
        else:
            logger.error("注册未知应用：{}".format(rapp.app_type))


async def sync_dialog():
    ...