InMemoryRecordManager#

class langchain_core.indexing.base.InMemoryRecordManager(namespace: str)[source]#

用于测试目的的内存记录管理器。

初始化内存中的记录管理器。

Parameters:: namespace (str) – 记录管理器的命名空间。

方法

`__init__`(namespace)	初始化内存中的记录管理器。
`acreate_schema`()	异步内存模式创建只是确保结构已初始化。
`adelete_keys`(keys)	异步从数据库中删除指定的记录。
`aexists`(keys)	异步检查提供的键是否存在于数据库中。
`aget_time`()	异步获取当前服务器时间作为高分辨率时间戳！
`alist_keys`(*[, before, after, group_ids, limit])	根据提供的过滤器异步列出数据库中的记录。
`aupdate`(keys, *[, group_ids, time_at_least])	异步将记录插入或更新到数据库中。
`create_schema`()	内存中的模式创建只是确保结构被初始化。
`delete_keys`(keys)	从数据库中删除指定的记录。
`exists`(keys)	检查提供的键是否存在于数据库中。
`get_time`()	获取当前服务器时间作为高分辨率时间戳！
`list_keys`(*[, before, after, group_ids, limit])	根据提供的过滤器列出数据库中的记录。
`update`(keys, *[, group_ids, time_at_least])	将记录插入或更新到数据库中。

__init__(namespace: str) → None[来源]#

初始化内存中的记录管理器。

Parameters:: namespace (str) – 记录管理器的命名空间。
Return type:: 无

async acreate_schema() → None[source]#

异步内存模式创建只是确保结构被初始化。

Return type:: 无

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

异步从数据库中删除指定的记录。

Parameters:: keys (Sequence[str]) – 要删除的键列表。
Return type:: 无

async aexists(keys: Sequence[str]) → list[bool][source]#

异步检查提供的键是否存在于数据库中。

Parameters:: keys (Sequence[str]) – 要检查的键列表。
Returns:: 一个布尔值列表，指示每个键的存在。
Return type:: 列表[布尔]

async aget_time() → float[source]#

异步获取当前服务器时间作为高分辨率时间戳！

Return type:: 浮点数

async alist_keys(*, before: float | None = None, after: float | None = None, group_ids: Sequence[str] | None = None, limit: int | None = None) → list[str][source]#

根据提供的过滤器异步列出数据库中的记录。

Parameters:

before (float | None) – 过滤以列出在此时间之前更新的记录。默认为 None。
after (float | None) – 过滤以列出在此时间之后更新的记录。默认为 None。
group_ids (Sequence[str] | None) – 过滤以列出具有特定组ID的记录。默认为None。
limit (int | None) – 可选的返回记录数量限制。默认为 None。

Returns:

匹配记录的键列表。

Return type:

列表[字符串]

async aupdate(keys: Sequence[str], *, group_ids: Sequence[str | None] | None = None, time_at_least: float | None = None) → None[来源]#

异步将记录插入或更新到数据库中。

Parameters:

keys (Sequence[str]) – 要插入或更新的记录键列表。
group_ids (Sequence[str | None] | None) – 与键对应的组ID列表。默认为None。
time_at_least (float | None) – 可选的时间戳。实现可以使用此选项来验证存储系统中的时间戳至少为此时间。默认为 None。例如，用于验证 postgres 数据库中的时间是否等于或大于给定的时间戳，如果不是，则引发错误。这旨在帮助防止时间漂移问题，因为时间可能不是单调递增的！

Raises:

ValueError – 如果键的长度与组ID的长度不匹配。
ValueError – 如果 time_at_least 是在未来。

Return type:

无

create_schema() → None[source]#

内存中的模式创建只是确保结构被初始化。

Return type:: 无

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

从数据库中删除指定的记录。

Parameters:: keys (Sequence[str]) – 要删除的键列表。
Return type:: 无

exists(keys: Sequence[str]) → list[bool][source]#

检查提供的键是否存在于数据库中。

Parameters:: keys (Sequence[str]) – 要检查的键列表。
Returns:: 一个布尔值列表，指示每个键的存在。
Return type:: 列表[布尔]

get_time() → float[来源]#

获取当前服务器时间作为高分辨率时间戳！

Return type:: 浮点数

list_keys(*, before: float | None = None, after: float | None = None, group_ids: Sequence[str] | None = None, limit: int | None = None) → list[str][source]#

根据提供的过滤器列出数据库中的记录。

Parameters:

before (float | None) – 过滤以列出在此时间之前更新的记录。默认为 None。
after (float | None) – 过滤以列出在此时间之后更新的记录。默认为 None。
group_ids (Sequence[str] | None) – 过滤以列出具有特定组ID的记录。默认为None。
limit (int | None) – 可选的返回记录数量限制。默认为 None。

Returns:

匹配记录的键列表。

Return type:

列表[字符串]

update(keys: Sequence[str], *, group_ids: Sequence[str | None] | None = None, time_at_least: float | None = None) → None[source]#

将记录插入或更新到数据库中。

Parameters:

keys (Sequence[str]) – 要插入或更新的记录键列表。
group_ids (Sequence[str | None] | None) – 与键对应的组ID列表。默认为None。
time_at_least (float | None) – 可选的时间戳。实现可以使用此选项来验证存储系统中的时间戳至少为此时间。默认为 None。例如，用于验证 postgres 数据库中的时间是否等于或大于给定的时间戳，如果不是，则引发错误。这旨在帮助防止时间漂移问题，因为时间可能不是单调递增的！

Raises:

ValueError – 如果键的长度与组ID的长度不匹配。
ValueError – 如果 time_at_least 是在未来。

Return type:

无