langchain_community.document_loaders.cassandra.CassandraLoader

class langchain_community.document_loaders.cassandra.CassandraLoader(table: Optional[str] = None, session: Optional[Session] = None, keyspace: Optional[str] = None, query: Union[str, Statement, None] = None, page_content_mapper: Callable[[Any], str] = <class 'str'>, metadata_mapper: Callable[[Any], dict] = <function CassandraLoader.<lambda>>, *, query_parameters: Union[dict, Sequence, None] = None, query_timeout: Optional[float] = <object object>, query_trace: bool = False, query_custom_payload: Optional[dict] = None, query_execution_profile: Any = <object object>, query_paging_state: Any = None, query_host: Optional[Host] = None, query_execute_as: Optional[str] = None)

为Apache Cassandra加载文档。

参数：

table: 从中加载数据的表。

（不要与查询参数一起使用）

session: Cassandra驱动程序会话。

如果未提供，则将使用cassio解析的会话。

keyspace: 表的键空间。

如果未提供，则将使用cassio解析的键空间。

query: 用于加载数据的查询。

（不要与表参数一起使用）

page_content_mapper: 将行转换为字符串页面内容的函数。

默认为行的str表示。

metadata_mapper: 将行转换为文档元数据的函数。 query_parameters: 调用session.execute时使用的查询参数。 query_timeout: 调用session.execute时使用的查询超时。 query_trace: 调用session.execute时是否使用跟踪。 query_custom_payload: 调用session.execute时使用的查询自定义负载。 query_execution_profile: 调用session.execute时使用的查询执行配置文件。 query_host: 调用session.execute时使用的查询主机。 query_execute_as: 调用session.execute时使用的查询执行者。

Methods

__init__([table, session, keyspace, query, ...])	为Apache Cassandra加载文档。
alazy_load()	一个用于文档的惰性加载器。
aload()	将数据加载到文档对象中。
lazy_load()	一个用于文档的惰性加载器。
load()	将数据加载到文档对象中。
load_and_split([text_splitter])	加载文档并分割成块。块作为文档返回。

Parameters

• table (Optional[str]) –

• session (Optional[Session]) –

• keyspace (Optional[str]) –

• query (Union[str, Statement, None]) –

• page_content_mapper (Callable[[Any], str]) –

• metadata_mapper (Callable[[Any], dict]) –

• query_parameters (Union[dict, Sequence, None]) –

• query_timeout (Optional[float]) –

• query_trace (bool) –

• query_custom_payload (Optional[dict]) –

• query_execution_profile (Any) –

• query_paging_state (Any) –

• query_host (Optional[Host]) –

• query_execute_as (Optional[str]) –

Return type

None

__init__(table: Optional[str] = None, session: Optional[Session] = None, keyspace: Optional[str] = None, query: Union[str, Statement, None] = None, page_content_mapper: Callable[[Any], str] = <class 'str'>, metadata_mapper: Callable[[Any], dict] = <function CassandraLoader.<lambda>>, *, query_parameters: Union[dict, Sequence, None] = None, query_timeout: Optional[float] = <object object>, query_trace: bool = False, query_custom_payload: Optional[dict] = None, query_execution_profile: Any = <object object>, query_paging_state: Any = None, query_host: Optional[Host] = None, query_execute_as: Optional[str] = None) → None

为Apache Cassandra加载文档。

参数：

table: 从中加载数据的表。

（不要与查询参数一起使用）

session: Cassandra驱动程序会话。

如果未提供，则将使用cassio解析的会话。

keyspace: 表的键空间。

如果未提供，则将使用cassio解析的键空间。

query: 用于加载数据的查询。

（不要与表参数一起使用）

page_content_mapper: 将行转换为字符串页面内容的函数。

默认为行的str表示。

metadata_mapper: 将行转换为文档元数据的函数。 query_parameters: 调用session.execute时使用的查询参数。 query_timeout: 调用session.execute时使用的查询超时。 query_trace: 调用session.execute时是否使用跟踪。 query_custom_payload: 调用session.execute时使用的查询自定义负载。 query_execution_profile: 调用session.execute时使用的查询执行配置文件。 query_host: 调用session.execute时使用的查询主机。 query_execute_as: 调用session.execute时使用的查询执行者。

Parameters

• table (Optional[str]) –

• session (Optional[Session]) –

• keyspace (Optional[str]) –

• query (Union[str, Statement, None]) –

• page_content_mapper (Callable[[Any], str]) –

• metadata_mapper (Callable[[Any], dict]) –

• query_parameters (Union[dict, Sequence, None]) –

• query_timeout (Optional[float]) –

• query_trace (bool) –

• query_custom_payload (Optional[dict]) –

• query_execution_profile (Any) –

• query_paging_state (Any) –

• query_host (Optional[Host]) –

• query_execute_as (Optional[str]) –

Return type

None

async alazy_load() → AsyncIterator[Document]

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

Return type

AsyncIterator[Document]

async aload() → List[Document]

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

Return type

List[Document]

lazy_load() → Iterator[Document]

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

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 CassandraLoader

• Cassandra

• cassandra.md