`langchain_community.chat_message_histories.cassandra`.CassandraChatMessageHistory¶

class langchain_community.chat_message_histories.cassandra.CassandraChatMessageHistory(session_id: str, session: Optional[Session] = None, keyspace: Optional[str] = None, table_name: str = 'message_store', ttl_seconds: Optional[int] = None, *, setup_mode: SetupMode = SetupMode.SYNC)[source]¶

Cassandra数据库中存储聊天消息历史。

参数

session_id (str) – 用于存储单个聊天会话消息的任意键。
session (Optional[Session]) – Cassandra驱动会话。如果不提供，将从cassio中解析。
keyspace (Optional[str]) – Cassandra密钥空间。如果不提供，将从cassio中解析。
table_name (str) – 要使用的表名。
ttl_seconds (Optional[int]) – 存储条目自动过期的存活时间（秒）。默认为None（无过期）。
setup_mode (SetupMode) – 创建Cassandra表的模式（SYNC, ASYNC或OFF）。

属性

messages

从数据库中检索所有会话消息。

方法

`__init__`(session_id[, session, keyspace, ...])	Cassandra数据库中存储聊天消息历史。
`aadd_messages`(messages)	异步添加消息列表。
`aclear`()	从数据库中清除会话内存。
`add_ai_message`(message)	将AI消息字符串添加到存储的便捷方法。
`add_message`(message)	将消息写入表。
`add_messages`(messages)	添加消息列表。
`add_user_message`(message)	将人类消息字符串添加到存储的便捷方法。
`get_messages`()	从数据库中检索所有会话消息。
`clear`()	从数据库中清除会话内存。

__init__(session_id: str, session: Optional[Session] = None, keyspace: Optional[str] = None, table_name: str = 'message_store', ttl_seconds: Optional[int] = None, *, setup_mode: SetupMode = SetupMode.SYNC) → None[source]¶

Cassandra数据库中存储聊天消息历史。

参数

session_id (str) – 用于存储单个聊天会话消息的任意键。
session (Optional[Session]) – Cassandra驱动会话。如果不提供，将从cassio中解析。
keyspace (Optional[str]) – Cassandra密钥空间。如果不提供，将从cassio中解析。
table_name (str) – 要使用的表名。
ttl_seconds (Optional[int]) – 存储条目自动过期的存活时间（秒）。默认为None（无过期）。
setup_mode (SetupMode) – 创建Cassandra表的模式（SYNC, ASYNC或OFF）。

返回类型

None

async aadd_messages(messages: Sequence[BaseMessage]) → None[source]¶

异步添加消息列表。

参数: messages (Sequence[BaseMessage]) – 需要存储的 BaseMessage 对象序列。
返回类型: None

async aclear() → None[source]¶

从数据库中清除会话内存。

返回类型: None

add_ai_message(message: Union[AIMessage, str]) → None¶

将AI消息字符串添加到存储的便捷方法。

请注意，这是一个便利的方法。代码应优先使用批量添加消息的界面，以节省底层持久层往返。

该方法可能在未来的版本中被弃用。

参数: message (Union[AIMessage, str]) – 要添加的 AI 消息。
返回类型: None

add_message(message: BaseMessage) → None¶

将消息写入表。

参数: message (BaseMessage) – 要写入的消息。
返回类型: None

add_messages(messages: Sequence[BaseMessage]) → None¶

添加消息列表。

实现应覆盖此方法以以高效方式处理消息的批量添加，以避免对底层存储的不必要的多次往返。

参数: messages (Sequence[BaseMessage]) – 需要存储的 BaseMessage 对象序列。
返回类型: None

add_user_message(message: Union[HumanMessage, str]) → None¶

将人类消息字符串添加到存储的便捷方法。

请注意，这是一个便利的方法。代码应优先使用批量添加消息的界面，以节省底层持久层往返。

该方法可能在未来的版本中被弃用。

参数: message (Union[HumanMessage, str]) – 要添加到存储中的人类消息。
返回类型: None

async aget_messages() → List[BaseMessage][source]¶

从数据库中检索所有会话消息。

返回类型: List[BaseMessage]

clear() → None[source]¶

从数据库中清除会话内存。

返回类型: None

使用 CassandraChatMessageHistory 的示例¶

langchain_community.chat_message_histories.cassandra.CassandraChatMessageHistory¶

使用 CassandraChatMessageHistory 的示例¶

`langchain_community.chat_message_histories.cassandra`.CassandraChatMessageHistory¶