MongodbLoader#

class langchain_community.document_loaders.mongodb.MongodbLoader(connection_string: str, db_name: str, collection_name: str, *, filter_criteria: Dict | None = None, field_names: Sequence[str] | None = None, metadata_names: Sequence[str] | None = None, include_db_collection_in_metadata: bool = True)[来源]#

加载MongoDB文档。

使用必要的数据库连接详细信息和配置初始化MongoDB加载器。

Parameters:
  • connection_string (str) – MongoDB 连接 URI。

  • db_name (str) – 要连接的数据库的名称。

  • collection_name (str) – 从中获取文档的集合名称。

  • filter_criteria (可选[字典]) – 用于查询的MongoDB过滤条件

  • documents. (摘录自)

  • field_names (可选[序列[str]]) – 要检索的字段名称列表

  • 文档。

  • metadata_names (可选[序列[str]]) – 额外的元数据字段

  • 文档。

  • include_db_collection_in_metadata (bool) – 标志以包含数据库和

  • metadata. (集合名称在)

Raises:
  • ImportError – 如果未安装电机库。

  • ValueError – 如果缺少任何必要的参数。

方法

__init__(connection_string, db_name, ...[, ...])

使用必要的数据库连接详细信息和配置初始化MongoDB加载器。

alazy_load()

一个用于文档的懒加载器。

aload()

异步加载数据到Document对象中。

lazy_load()

一个用于文档的懒加载器。

load()

将数据加载到Document对象中。

load_and_split([text_splitter])

加载文档并将其分割成块。

__init__(connection_string: str, db_name: str, collection_name: str, *, filter_criteria: Dict | None = None, field_names: Sequence[str] | None = None, metadata_names: Sequence[str] | None = None, include_db_collection_in_metadata: bool = True) None[source]#

使用必要的数据库连接详细信息和配置初始化MongoDB加载器。

Parameters:
  • connection_string (str) – MongoDB 连接 URI。

  • db_name (str) – 要连接的数据库的名称。

  • collection_name (str) – 从中获取文档的集合名称。

  • filter_criteria (可选[字典]) – 用于查询的MongoDB过滤条件

  • documents. (摘录自)

  • field_names (可选[序列[str]]) – 要检索的字段名称列表

  • 文档。

  • metadata_names (可选[序列[str]]) – 额外的元数据字段

  • 文档。

  • include_db_collection_in_metadata (bool) – 标志以包含数据库和

  • metadata. (集合名称在)

Raises:
  • ImportError – 如果未安装电机库。

  • ValueError – 如果缺少任何必要的参数。

Return type:

async alazy_load() AsyncIterator[Document]#

文档的懒加载器。

Return type:

AsyncIterator[Document]

async aload() List[Document][source]#

异步加载数据到Document对象中。

Return type:

列表[文档]

lazy_load() Iterator[Document]#

文档的懒加载器。

Return type:

迭代器[文档]

load() List[Document][source]#

将数据加载到Document对象中。

注意:

此实现启动了一个asyncio事件循环,只有在同步环境中运行时才会工作。在异步环境中,它应该会失败,因为已经有一个事件循环在运行。

此代码应更新为在异步上下文中运行时从单独的线程启动事件循环。

Return type:

列表[文档]

load_and_split(text_splitter: TextSplitter | None = None) list[Document]#

加载文档并将其分割成块。块以文档形式返回。

不要重写此方法。它应该被视为已弃用!

Parameters:

text_splitter (可选[TextSplitter]) – 用于分割文档的TextSplitter实例。 默认为RecursiveCharacterTextSplitter。

Returns:

文档列表。

Return type:

列表[Document]

使用 MongodbLoader 的示例