将URI转换为异步版本

获取缓存的 BM25 索引，如果文档变化则重建 Args: cache_key: 缓存键（如知识库名称） docs: 文档列表 preprocess_func: 分词函数

根据loader_name和文件路径或内容返回文档加载器。

从prompt_config中加载模板内容 type: 对应于 model_settings.llm_model_config 模型类别其中的一种，以及 "rag"，如果有新功能，应该进行加入。

将URI转换为同步版本

从用户记忆中提取用户画像/偏好信息 :param session: 数据库会话 :param user_id: 用户ID :return: 用户画像字典

获取用户的模型配置设置 Args: session: 数据库会话 identifier: 用户标识符 (如 'admin', 'user1') Returns: 用户设置字典,如果没有则返回空字典

初始化数据库,创建所有缺失的表

Checks to see if the text passes all of the checks for a valid title. Parameters ---------- text The input text to check titl

通过file_name或metadata检索Document

根据参数获取特定的分词器

将 metadata 中的不支持的值转换为 ChromaDB 支持的格式

保存用户的模型配置设置 Args: session: 数据库会话 identifier: 用户标识符 (如 'admin', 'user1') settings: 要保存的设置字典 Returns:

Checks if the proportion of non-alpha characters in the text snippet exceeds a given threshold. This helps prevent text like "-----------BREAK----

更新知识库文档

nltk 模型存储路径

Create a new TextSplitter.

从PDF文件中提取元素

from langchain_community.vectorstores.chroma import Chroma

Split incoming text and return chunks.

Asynchronous Embed search docs. Args: texts: List of text to embed. Returns: List of embeddings.

Asynchronous Embed query text. Args: text: Text to embed. Returns: Embedding.

调用模型生成工具调用

分析当前代理状态并确定下一步的route logic

返回 API 地址

根据当前的route logic向用户询问更多信息。

清空所有缓存

执行 knowledge_graph 子图节点

执行 SQL 查询子图节点

将消息列表转换为模型可用的格式。 特别处理 ToolMessage，确保保留 tool_call_id。

删除指定 threadId 的所有对话消息