`langchain_core.indexing.base`.InMemoryRecordManager¶

class langchain_core.indexing.base.InMemoryRecordManager(namespace: str)[源代码]¶

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

初始化内存记录管理器。

参数: 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[源代码]¶

初始化内存记录管理器。

参数: namespace (str) – 记录管理器的命名空间。
返回类型: None

async acreate_schema() → None[source]¶

异步的内存架构创建仅确保结构已初始化。

返回类型: None

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

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

参数: keys (Sequence[str]) – 要删除的键列表。
返回类型: None

async aexists(keys: Sequence[str]) → List[bool][source]¶

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

参数: keys (Sequence[str]) – 要检查的键列表。
返回: 一个布尔值的列表，表示每个键的存在性。
返回类型: List[bool]

async aget_time() → float[source]¶

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

返回类型: 浮点数

async alist_keys(*, before: Optional[float] = None, after: Optional[float] = None, group_ids: Optional[Sequence[str]] = None, limit: Optional[int] = None) → List[str][source]¶

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

参数

before (Optional[float]) – 过滤在指定时间之前更新的记录。默认为 None。
after (Optional[float]) – 过滤在指定时间之后更新的记录。默认为 None。
group_ids (Optional[Sequence[str]]) – 过滤指定分组 ID 的记录。默认为 None。
limit (Optional[int]) – 可选的返回记录数量限制。默认为 None。

返回

匹配记录的关键字列表。

返回类型

List[字符串]

async aupdate(keys: Sequence[str], *, group_ids: Optional[Sequence[Optional[str]] = None, time_at_least: Optional[float] = None) → None[source]¶

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

参数

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

抛出

ValueError – 如果keys的长度与group_ids的长度不匹配。
ValueError – 如果time_at_least在将来。

返回类型

None

create_schema() → None[source]¶

内存架构创建仅确保结构已初始化。

返回类型: None

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

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

参数: keys (Sequence[str]) – 要删除的键列表。
返回类型: None

exists(keys: Sequence[str]) → List[bool][source]¶

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

参数: keys (Sequence[str]) – 要检查的键列表。
返回: 一个布尔值的列表，表示每个键的存在性。
返回类型: List[bool]

get_time() → float[source]¶

获取当前服务器时间的最高分辨率时间戳！

返回类型: 浮点数

list_keys(*, before: Optional[float] = None, after: Optional[float] = None, group_ids: Optional[Sequence[str]] = None, limit: Optional[int] = None) → List[str][source]¶

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

参数

before (Optional[float]) – 过滤在指定时间之前更新的记录。默认为 None。
after (Optional[float]) – 过滤在指定时间之后更新的记录。默认为 None。
group_ids (Optional[Sequence[str]]) – 过滤指定分组 ID 的记录。默认为 None。
limit (Optional[int]) – 可选的返回记录数量限制。默认为 None。

返回

匹配记录的关键字列表。

返回类型

List[字符串]

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

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

参数

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

抛出

ValueError – 如果keys的长度与group_ids的长度不匹配。
ValueError – 如果time_at_least在将来。

返回类型

None

langchain_core.indexing.base.InMemoryRecordManager¶

`langchain_core.indexing.base`.InMemoryRecordManager¶