`langchain_community.storage.cassandra`.CassandraByteStore¶

class langchain_community.storage.cassandra.CassandraByteStore(table: str, ..., session: Optional[Session] = None, keyspace: Optional[str] = None, setup_mode: SetupMode = SetupMode.SYNC)[来源]¶

使用 Cassandra 作为后端的 ByteStore 实现。

参数

table (str) - 要使用的表名。
session (Optional[Session]) - Cassandra 会话对象。如果没有提供，将从 cassio 配置中解析。
keyspace (Optional[str]) - 要使用的命名空间。如果没有提供，将从 cassio 配置中解析。
setup_mode (SetupMode) - 要使用的设置模式。默认为 SYNC (SetupMode.SYNC)。

方法

`__init__`(table, *[, session, keyspace, ...])
`aensure_db_setup`()	确保数据库设置完成。
`amdelete`(keys)	异步删除给定的键及其相关值。
`amget`(keys)	异步获取与给定键关联的值。
`amset`(key_value_pairs)	异步为给定的键设置值。
`ayield_keys`(*[, prefix])	异步获取匹配给定前缀的键的迭代器。
`ensure_db_setup`()	确保数据库设置完成。
`get_delete_statement`()	获取表的预编译删除语句。
`get_insert_statement`()	获取表的预编译插入语句。
`get_select_statement`()	获取表的预编译选择语句。
`mdelete`(keys)	删除给定的键及其相关值。
`mget`(keys)	获取与给定键相关联的值。
`mset`(key_value_pairs)	设置给定键的值。
`yield_keys`(*[, prefix])	获取与给定前缀匹配的键的迭代器。

__init__(table: str, *, session: Optional[Session] = None, keyspace: Optional[str] = None, setup_mode: SetupMode = SetupMode.SYNC) → None[source]¶

参数

table (str) –
session (Optional[Session]) –
keyspace (Optional[str]) –
setup_mode (SetupMode) –

返回类型

None

async aensure_db_setup() → None[source]¶

确保数据库设置已完成。如果没有，等待完成。

返回类型: None

async amdelete(keys: Sequence[str]) → None[source]¶

异步删除给定的键及其相关值。

参数: keys (Sequence[K]) – 要删除的键序列。
返回类型: None

async amget(keys: Sequence[str]) → List[Optional[bytes]][源码]¶

异步获取与给定键关联的值。

参数: keys (Sequence[K]) – 键序列。
返回: 与键相关联的可选值的序列。如果找不到键，相应的值将为None。
返回类型: List[Optional[bytes]]

async amset(key_value_pairs: Sequence[Tuple[str, bytes]]) → None[源码]¶

异步为给定的键设置值。

参数: key_value_pairs (Sequence[Tuple[K, V]]) – 键值对序列。
返回类型: None

async ayield_keys(*, prefix: Optional[str] = None) → AsyncIterator[str][源码]¶

异步获取匹配给定前缀的键的迭代器。

参数: prefix (str) – 匹配的前缀。
产生: Iterator[K | str] – 对匹配指定前缀的键的迭代器。此方法可以返回对K或str的迭代器，具体取决于针对给定存储库哪种做法更有意义。
返回类型: AsyncIterator[str]

ensure_db_setup() → None[源码]¶

确保数据库设置完成。如果没有完成，则引发ValueError。

返回类型: None

get_delete_statement() → PreparedStatement[源代码]¶

获取表的准备好的删除语句。如果不可用，则准备它。

返回: 已准备好的语句。
返回类型: PreparedStatement

get_insert_statement() → PreparedStatement[源代码]¶

获取表的准备好的插入语句。如果不可用，则准备它。

返回: 已准备好的语句。
返回类型: PreparedStatement

get_select_statement() → PreparedStatement[源代码]¶

获取表的准备好的选择语句。如果不可用，则准备它。

返回: 已准备好的语句。
返回类型: PreparedStatement

mdelete(keys: Sequence[str]) → None[源代码]¶

删除给定的键及其相关值。

参数: keys (Sequence[K]) – 要删除的键序列。
返回类型: None

mget(keys: Sequence[str]) → List[Optional[bytes]][源代码]¶

获取与给定键相关联的值。

参数: keys (Sequence[K]) – 键序列。
返回: 与键相关联的可选值的序列。如果找不到键，相应的值将为None。
返回类型: List[Optional[bytes]]

mset(key_value_pairs: Sequence[Tuple[str, bytes]) → None[源代码]¶

设置给定键的值。

参数: key_value_pairs (Sequence[Tuple[K, V]]) – 键值对序列。
返回类型: None

yield_keys(*, prefix: Optional[str] = None) → Iterator[str][source]¶

获取与给定前缀匹配的键的迭代器。

参数: prefix (str) – 匹配的前缀。
产生: Iterator[K | str] – 对匹配指定前缀的键的迭代器。此方法可以返回对K或str的迭代器，具体取决于针对给定存储库哪种做法更有意义。
返回类型: str 迭代器

使用 CassandraByteStore 的示例¶

Cassandra

langchain_community.storage.cassandra.CassandraByteStore¶

使用 CassandraByteStore 的示例¶

`langchain_community.storage.cassandra`.CassandraByteStore¶