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文档。
一个用于文档的惰性加载器。
aload
()将数据加载到Document对象中。
一个用于文档的惰性加载器。
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]
- load_and_split(text_splitter: Optional[TextSplitter] = None) List[Document] ¶
加载文档并分割成块。块作为文档返回。
不要覆盖此方法。应该被视为已弃用!
- 参数:
- text_splitter: 用于分割文档的TextSplitter实例。
默认为RecursiveCharacterTextSplitter。
- 返回:
文档列表。
- Parameters
text_splitter (Optional[TextSplitter]) –
- Return type
List[Document]