Cassandra字节存储#

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

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

Parameters:

  • table (str) – 要使用的表的名称。

  • session (可选[Session]) – 一个Cassandra会话对象。如果未提供，将从cassio配置中解析。

  • keyspace (可选[str]) – 要使用的keyspace。如果未提供，将从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: Session | None = None, keyspace: str | None = None, setup_mode: SetupMode = SetupMode.SYNC) → None[source]#
Parameters:

  • table (str)

  • session (可选[Session])

  • keyspace (可选[str])

  • setup_mode (SetupMode)

Return type:

无

async aensure_db_setup() → None[source]#

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

Return type:

无

async amdelete(keys: Sequence[str]) → None[来源]#

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

Parameters:

keys (Sequence[K]) – 要删除的键序列。

Return type:

无

async amget(keys: Sequence[str]) → List[bytes | None][来源]#

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

Parameters:

keys (Sequence[K]) – 一个键的序列。

Returns:

与键相关联的一系列可选值。 如果未找到键，则对应的值将为None。

Return type:

列表[字节 | 无]

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

异步设置给定键的值。

Parameters:

key_value_pairs (Sequence[Tuple[K, V]]) – 一个键值对的序列。

Return type:

无

async ayield_keys(*, prefix: str | None = None) → AsyncIterator[str][source]#

异步获取一个迭代器，用于遍历与给定前缀匹配的键。

Parameters:

prefix (str) – 要匹配的前缀。

Yields:

Iterator[K | str] – 一个遍历与给定前缀匹配的键的迭代器。 此方法允许返回一个遍历 K 或 str 的迭代器，具体取决于给定存储的更有意义的方式。

Return type:

AsyncIterator[str]

ensure_db_setup() → None[source]#

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

Return type:

无

get_delete_statement() → PreparedStatement[source]#

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

Returns:

准备好的语句。

Return type:

PreparedStatement

get_insert_statement() → PreparedStatement[source]#

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

Returns:

准备好的语句。

Return type:

PreparedStatement

get_select_statement() → PreparedStatement[来源]#

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

Returns:

准备好的语句。

Return type:

PreparedStatement

mdelete(keys: Sequence[str]) → None[source]#

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

Parameters:

keys (Sequence[K]) – 要删除的键序列。

Return type:

无

mget(keys: Sequence[str]) → List[bytes | None][来源]#

获取与给定键关联的值。

Parameters:

keys (Sequence[K]) – 一个键的序列。

Returns:

与键相关联的一系列可选值。 如果未找到键，则对应的值将为None。

Return type:

列表[字节 | 无]

mset(key_value_pairs: Sequence[Tuple[str, bytes]]) → None[source]#

为给定的键设置值。

Parameters:

key_value_pairs (Sequence[Tuple[K, V]]) – 一个键值对的序列。

Return type:

无

yield_keys(*, prefix: str | None = None) → Iterator[str][source]#

获取一个迭代器，用于遍历与给定前缀匹配的键。

Parameters:

prefix (str) – 要匹配的前缀。

Yields:

Iterator[K | str] – 一个遍历与给定前缀匹配的键的迭代器。 此方法允许返回一个遍历 K 或 str 的迭代器，具体取决于给定存储的更有意义的方式。

Return type:

迭代器[str]

使用CassandraByteStore的示例