Postgres聊天消息历史#

class langchain_community.chat_message_histories.postgres.PostgresChatMessageHistory(session_id: str, connection_string: str = 'postgresql://postgres:mypassword@localhost/chat_history', table_name: str = 'message_store')[source]#

自版本0.0.31起已弃用:此类已被弃用,并将在未来的版本中移除。您可以切换到使用langchain_postgres中的PostgresChatMessageHistory实现。请不要再向此类提交进一步的PR。参见<langchain-ai/langchain-postgres> 请使用from langchain_postgres import PostgresChatMessageHistory;代替。

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

已弃用: 此类已弃用,并将在未来的版本中移除。

使用langchain_postgres中的PostgresChatMessageHistory实现。

属性

messages

从PostgreSQL中检索消息

方法

__init__(session_id[, connection_string, ...])

aadd_messages(messages)

异步添加消息列表。

aclear()

异步从存储中移除所有消息

add_ai_message(message)

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

add_message(message)

将消息追加到PostgreSQL中的记录

add_messages(messages)

添加消息列表。

add_user_message(message)

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

aget_messages()

获取消息的异步版本。

clear()

从PostgreSQL中清除会话内存

Parameters:
  • session_id (str)

  • connection_string (str)

  • table_name (str)

__init__(session_id: str, connection_string: str = 'postgresql://postgres:mypassword@localhost/chat_history', table_name: str = 'message_store')[源代码]#
Parameters:
  • session_id (str)

  • connection_string (str)

  • table_name (str)

async aadd_messages(messages: Sequence[BaseMessage]) None#

异步添加消息列表。

Parameters:

messages (Sequence[BaseMessage]) – 要存储的BaseMessage对象序列。

Return type:

async aclear() None#

异步从存储中移除所有消息

Return type:

add_ai_message(message: AIMessage | str) None#

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

请注意,这是一个便捷方法。代码应优先使用批量 add_messages 接口,以减少与底层持久层的往返次数。

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

Parameters:

message (AIMessage | str) – 要添加的AI消息。

Return type:

add_message(message: BaseMessage) None[source]#

将消息附加到PostgreSQL中的记录

Parameters:

消息 (BaseMessage)

Return type:

add_messages(messages: Sequence[BaseMessage]) None#

添加消息列表。

实现应重写此方法,以高效地处理消息的批量添加,避免对底层存储进行不必要的往返。

Parameters:

messages (Sequence[BaseMessage]) – 要存储的BaseMessage对象序列。

Return type:

add_user_message(message: HumanMessage | str) None#

用于向存储中添加人类消息字符串的便捷方法。

请注意,这是一个便捷方法。代码应优先使用批量 add_messages 接口,以减少对底层持久层的往返次数。

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

Parameters:

message (HumanMessage | str) – 要添加到存储中的人类消息。

Return type:

async aget_messages() list[BaseMessage]#

获取消息的异步版本。

可以重写此方法以提供高效的异步实现。

通常,获取消息可能涉及到底层持久层的IO操作。

Return type:

列表[BaseMessage]

clear() None[source]#

从PostgreSQL清除会话内存

Return type:

使用 PostgresChatMessageHistory 的示例