langchain_community.storage.mongodb.MongoDBByteStore

class langchain_community.storage.mongodb.MongoDBByteStore(connection_string: str, db_name: str, collection_name: str, *, client_kwargs: Optional[dict] = None)[source]

使用MongoDB作为底层存储的BaseStore实现。

示例

创建MongoDBByteStore实例并在其上执行操作

# Instantiate the MongoDBByteStore with a MongoDB connection
from langchain.storage import MongoDBByteStore

mongo_conn_str = "mongodb://localhost:27017/"
mongodb_store = MongoDBBytesStore(mongo_conn_str, db_name="test-db",
                             collection_name="test-collection")

# Set values for keys
mongodb_store.mset([("key1", "hello"), ("key2", "workd")])

# Get values for keys
values = mongodb_store.mget(["key1", "key2"])
# [bytes1, bytes1]

# Iterate over keys
for key in mongodb_store.yield_keys():
    print(key)

# Delete keys
mongodb_store.mdelete(["key1", "key2"])

使用MongoDB连接字符串初始化MongoDBStore。

参数
  • connection_string (str) – MongoDB连接字符串

  • db_name (str) – 要使用的名称

  • collection_name (str) – 要使用的集合名称

  • client_kwargs (dict) – 传递给Mongo客户端的键值参数

方法

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

使用MongoDB连接字符串初始化MongoDBStore。

amdelete(keys)

异步删除给定的键及其相关值。

amget(keys)

异步获取与给定键关联的值。

amset(key_value_pairs)

异步设置给定键的值。

ayield_keys(*[, prefix])

异步获取与给定前缀匹配的键的迭代器。

mdelete(keys)

删除给定的ID。

mget(keys)

获取与给定键关联的文档列表。

mset(key_value_pairs)

设置给定的键值对。

yield_keys([prefix])

返回存储中的键。

__init__(connection_string: str, db_name: str, collection_name: str, *, client_kwargs: Optional[dict] = None) None[源代码]

使用MongoDB连接字符串初始化MongoDBStore。

参数
  • connection_string (str) – MongoDB连接字符串

  • db_name (str) – 要使用的名称

  • collection_name (str) – 要使用的集合名称

  • client_kwargs (dict) – 传递给Mongo客户端的键值参数

返回类型

None

async amdelete(keys: Sequence[K]) None

异步删除给定的键及其相关值。

参数

keys (Sequence[K]) – 需要删除的键的序列。

返回类型

None

async amget(keys: Sequence[K]) List[Optional[V]]

异步获取与给定键关联的值。

参数

keys (Sequence[K]) – 键的序列。

返回

与键相关联的可选值序列。如果找不到键,相应的值将为 None。

返回类型

List[Optional[V]]

async amset(key_value_pairs: Sequence[Tuple[K, V]]) None

异步设置给定键的值。

参数

key_value_pairs (Sequence[Tuple[K, V]]) – 键值对序列。

返回类型

None

异步获取与给定前缀匹配的键的迭代器。

参数

返回类型

删除给定的ID。

参数

返回类型

None

获取与给定键关联的文档列表。

参数

返回

返回类型

设置给定的键值对。

参数

返回类型

None

yield_keys(prefix: Optional[str] = None) Iterator[str][源代码]

返回存储中的键。

参数

prefix (str) – 要检索的键的前缀。

返回类型

字符串迭代器