langchain_community.chat_message_histories.upstash_redis.UpstashRedisChatMessageHistory¶
- class langchain_community.chat_message_histories.upstash_redis.UpstashRedisChatMessageHistory(session_id: str, url: str = '', token: str = '', key_prefix: str = 'message_store:', ttl: Optional[int] = None)[source]¶
存储在上置 Redis 数据库中的聊天消息历史。
属性
key构造用于使用的记录键
messages从上置 Redis 中检索消息
方法
__init__(session_id[, url, token, ...])aadd_messages(messages)异步添加消息列表。
aclear()异步从存储中删除所有消息
add_ai_message(message)向存储中添加 AI 消息字符串的便利方法。
add_message(message)将消息追加到上置 Redis 中的记录
add_messages(messages)添加消息列表。
add_user_message(message)向存储中添加人消息字符串的便利方法。
获取消息的异步版本。
clear()从上置 Redis 中清除会话内存
- 参数
session_id (str) –
url (str) -
token (str) -
key_prefix (str) -
ttl (可选 [int]) -
- __init__(session_id: str, url: str = '', token: str = '', key_prefix: str = 'message_store:', ttl: Optional[int] = None)[source]¶
- 参数
session_id (str) –
url (str) -
token (str) -
key_prefix (str) -
ttl (可选 [int]) -
- async aadd_messages(messages: Sequence[BaseMessage]) None¶
异步添加消息列表。
- 参数
messages (Sequence[BaseMessage]) - 存储的 BaseMessage 对象的序列。
- 返回类型
None
- async aclear() None¶
异步从存储中删除所有消息
- 返回类型
None
- add_ai_message(message: Union[AIMessage, str]) None¶
向存储中添加 AI 消息字符串的便利方法。
请注意，这是一个方便方法。代码应倾向于批量添加消息接口以节省对底层持久化层的往返。
此方法可能在未来的版本中弃用。
- 参数
message (Union[AIMessage, str]) - 要添加的 AI 消息。
- 返回类型
None
- add_message(message: BaseMessage) None[source]¶
将消息追加到上置 Redis 中的记录
- 参数
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]¶
获取消息的异步版本。
可以覆盖此方法以提供高效的异步实现。
通常，获取消息可能涉及到底层持久层的IO。
- 返回类型
List[BaseMessage]