AstraDBLoader#

class langchain_community.document_loaders.astradb.AstraDBLoader(collection_name: str, *, token: Optional[str] = None, api_endpoint: Optional[str] = None, astra_db_client: Optional[AstraDB] = None, async_astra_db_client: Optional[AsyncAstraDB] = None, namespace: Optional[str] = None, filter_criteria: Optional[Dict[str, Any]] = None, projection: Optional[Dict[str, Any]] = None, find_options: Optional[Dict[str, Any]] = None, nb_prefetched: int = 1000, extraction_function: Callable[[Dict], str] = <function dumps>)[source]#

自版本0.0.29起已弃用：请改用:class:`~langchain_astradb.AstraDBLoader`。在langchain-community==1.0之前不会移除。

加载DataStax Astra DB文档。

Parameters:

  • collection_name (str) – 要使用的Astra DB集合的名称。

  • token (可选[str]) – 用于Astra DB的API令牌。

  • api_endpoint (可选[str]) – API端点的完整URL， 例如 https://-us-east1.apps.astra.datastax.com。

  • astra_db_client (可选[AstraDB]) – 替代 token+api_endpoint, 你可以传递一个已经创建的 'astrapy.db.AstraDB' 实例。

  • async_astra_db_client (Optional[AsyncAstraDB]) – 替代token+api_endpoint, 你可以传递一个已经创建的‘astrapy.db.AsyncAstraDB’实例。

  • namespace (Optional[str]) – 命名空间（也称为keyspace），集合所在的位置。默认为数据库的“默认命名空间”。

  • filter_criteria (可选[字典[字符串, 任意类型]]) – 用于过滤文档的条件。

  • projection (Optional[Dict[str, Any]]) – 指定要返回的字段。

  • find_options (可选[字典[字符串, 任意类型]]) – 查询的附加选项。

  • nb_prefetched (int) – 预取文档的最大数量。默认为1000。

  • extraction_function (Callable[[Dict], str]) – 应用于集合文档以创建LangChain文档的page_content的函数。默认为json.dumps。

方法

__init__(collection_name, *[, token, ...])

加载DataStax Astra DB文档。

alazy_load()

文档的懒加载器。

aload()

将数据加载到Document对象中。

lazy_load()

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

load()

将数据加载到Document对象中。

load_and_split([text_splitter])

加载文档并将其分割成块。
__init__(collection_name: str, *, token: Optional[str] = None, api_endpoint: Optional[str] = None, astra_db_client: Optional[AstraDB] = None, async_astra_db_client: Optional[AsyncAstraDB] = None, namespace: Optional[str] = None, filter_criteria: Optional[Dict[str, Any]] = None, projection: Optional[Dict[str, Any]] = None, find_options: Optional[Dict[str, Any]] = None, nb_prefetched: int = 1000, extraction_function: Callable[[Dict], str] = <function dumps>) → None[来源]#

加载DataStax Astra DB文档。

Parameters:

  • collection_name (str) – 要使用的Astra DB集合的名称。

  • token (可选[str]) – 用于Astra DB的API令牌。

  • api_endpoint (可选[str]) – API端点的完整URL， 例如 https://-us-east1.apps.astra.datastax.com。

  • astra_db_client (可选[AstraDB]) – 替代 token+api_endpoint, 你可以传递一个已经创建的 'astrapy.db.AstraDB' 实例。

  • async_astra_db_client (Optional[AsyncAstraDB]) – 替代token+api_endpoint, 你可以传递一个已经创建的‘astrapy.db.AsyncAstraDB’实例。

  • namespace (Optional[str]) – 命名空间（也称为keyspace），集合所在的位置。默认为数据库的“默认命名空间”。

  • filter_criteria (可选[字典[字符串, 任意类型]]) – 用于过滤文档的条件。

  • projection (Optional[Dict[str, Any]]) – 指定要返回的字段。

  • find_options (可选[字典[字符串, 任意类型]]) – 查询的附加选项。

  • nb_prefetched (int) – 预取文档的最大数量。默认为1000。

  • extraction_function (Callable[[Dict], str]) – 应用于集合文档以创建LangChain文档的page_content的函数。默认为json.dumps。

Return type:

无

async alazy_load() → AsyncIterator[Document][来源]#

文档的懒加载器。

Return type:

AsyncIterator[Document]

async aload() → List[Document][来源]#

将数据加载到Document对象中。

Return type:

列表[文档]

lazy_load() → Iterator[Document][来源]#

文档的懒加载器。

Return type:

迭代器[文档]

load() → list[Document]#

将数据加载到Document对象中。

Return type:

列表[Document]

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

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

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

Parameters:

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

Returns:

文档列表。

Return type:

列表[Document]

使用AstraDBLoader的示例