Elasticsearch聊天消息历史#

class langchain_elasticsearch.chat_history.ElasticsearchChatMessageHistory(index: str, session_id: str, *, es_connection: Elasticsearch | None = None, es_url: str | None = None, es_cloud_id: str | None = None, es_user: str | None = None, es_api_key: str | None = None, es_password: str | None = None, esnsure_ascii: bool | None = True)[source]#

属性

messages

方法

`__init__`(index, session_id, *[, ...])
`aadd_messages`(messages)	异步添加消息列表。
`aclear`()	异步从存储中移除所有消息
`add_ai_message`(message)	用于将AI消息字符串添加到存储中的便捷方法。
`add_message`(message)	将消息添加到Elasticsearch中的聊天会话
`add_messages`(messages)	添加消息列表。
`add_user_message`(message)	方便的方法，用于将人类消息字符串添加到存储中。
`aget_messages`()	获取消息的异步版本。
`clear`()	清除Elasticsearch中的会话内存
`create_if_missing`()
`get_messages`()	从Elasticsearch中检索消息

Parameters:

index (str)
session_id (str)
es_connection (Elasticsearch | None)
es_url (str | None)
es_cloud_id (str | None)
es_user (str | None)
es_api_key (str | None)
es_password (str | None)
esnsure_ascii (bool | None)

Parameters:

index (str)
session_id (str)
es_connection (Elasticsearch | None)
es_url (str | None)
es_cloud_id (str | None)
es_user (str | None)
es_api_key (str | None)
es_password (str | None)
esnsure_ascii (bool | None)

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]#

将消息添加到Elasticsearch中的聊天会话

Parameters:: 消息 (BaseMessage)
Return type:: 无

add_messages(messages: Sequence[BaseMessage]) → None[source]#

添加消息列表。

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

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]#

清除Elasticsearch中的会话内存

Return type:: 无

create_if_missing() → None[source]#

Return type:: 无

get_messages() → List[BaseMessage][source]#

从Elasticsearch中检索消息

Return type:: 列表[BaseMessage]

使用 ElasticsearchChatMessageHistory 的示例

Elasticsearch