langchain_community.document_loaders.astradb.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]

[Deprecated]

Notes

Deprecated since version 0.0.29.

加载DataStax Astra DB文档。

参数:

collection_name: 要使用的Astra DB集合的名称。 token: Astra DB使用的API令牌。 api_endpoint: API端点的完整URL,例如`https://<DB-ID>-us-east1.apps.astra.datastax.com`。 astra_db_client: token+api_endpoint的替代方法,可以传递一个已创建的’astrapy.db.AstraDB’实例。 async_astra_db_client: token+api_endpoint的替代方法,可以传递一个已创建的’astrapy.db.AsyncAstraDB’实例。 namespace: 集合所在的命名空间(又名键空间)。默认为数据库的“默认命名空间”。 filter_criteria: 用于过滤文档的条件。 projection: 指定要返回的字段。 find_options: 查询的其他选项。 nb_prefetched: 预取的文档的最大数量。默认为1000。 extraction_function: 应用于集合文档以创建LangChain文档的`page_content`的函数。默认为`json.dumps`。

Methods

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

加载DataStax Astra DB文档。

alazy_load()

一个用于文档的惰性加载器。

aload()

将数据加载到Document对象中。

lazy_load()

一个用于文档的惰性加载器。

load()

将数据加载到文档对象中。

load_and_split([text_splitter])

加载文档并分割成块。块作为文档返回。

Parameters
  • collection_name (str) –

  • token (Optional[str]) –

  • api_endpoint (Optional[str]) –

  • astra_db_client (Optional[AstraDB]) –

  • async_astra_db_client (Optional[AsyncAstraDB]) –

  • namespace (Optional[str]) –

  • filter_criteria (Optional[Dict[str, Any]]) –

  • projection (Optional[Dict[str, Any]]) –

  • find_options (Optional[Dict[str, Any]]) –

  • nb_prefetched (int) –

  • extraction_function (Callable[[Dict], str]) –

Return type

None

__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[source]

加载DataStax Astra DB文档。

参数:

collection_name: 要使用的Astra DB集合的名称。 token: Astra DB使用的API令牌。 api_endpoint: API端点的完整URL,例如`https://<DB-ID>-us-east1.apps.astra.datastax.com`。 astra_db_client: token+api_endpoint的替代方法,可以传递一个已创建的’astrapy.db.AstraDB’实例。 async_astra_db_client: token+api_endpoint的替代方法,可以传递一个已创建的’astrapy.db.AsyncAstraDB’实例。 namespace: 集合所在的命名空间(又名键空间)。默认为数据库的“默认命名空间”。 filter_criteria: 用于过滤文档的条件。 projection: 指定要返回的字段。 find_options: 查询的其他选项。 nb_prefetched: 预取的文档的最大数量。默认为1000。 extraction_function: 应用于集合文档以创建LangChain文档的`page_content`的函数。默认为`json.dumps`。

Parameters
  • collection_name (str) –

  • token (Optional[str]) –

  • api_endpoint (Optional[str]) –

  • astra_db_client (Optional[AstraDB]) –

  • async_astra_db_client (Optional[AsyncAstraDB]) –

  • namespace (Optional[str]) –

  • filter_criteria (Optional[Dict[str, Any]]) –

  • projection (Optional[Dict[str, Any]]) –

  • find_options (Optional[Dict[str, Any]]) –

  • nb_prefetched (int) –

  • extraction_function (Callable[[Dict], str]) –

Return type

None

async alazy_load() AsyncIterator[Document][source]

一个用于文档的惰性加载器。

Return type

AsyncIterator[Document]

async aload() List[Document][source]

将数据加载到Document对象中。

Return type

List[Document]

lazy_load() Iterator[Document][source]

一个用于文档的惰性加载器。

Return type

Iterator[Document]

load() List[Document]

将数据加载到文档对象中。

Return type

List[Document]

load_and_split(text_splitter: Optional[TextSplitter] = None) List[Document]

加载文档并分割成块。块作为文档返回。

不要覆盖此方法。应该被视为已弃用!

参数:
text_splitter: 用于分割文档的TextSplitter实例。

默认为RecursiveCharacterTextSplitter。

返回:

文档列表。

Parameters

text_splitter (Optional[TextSplitter]) –

Return type

List[Document]

Examples using AstraDBLoader