Infinispan#
- class langchain_community.vectorstores.infinispanvs.Infinispan(schema: str = 'http', user: str = '', password: str = '', hosts: List[str] = ['127.0.0.1:11222'], cache_url: str = '/rest/v2/caches', schema_url: str = '/rest/v2/schemas', use_post_for_query: bool = True, http2: bool = True, verify: bool = True, **kwargs: Any)[source]#
Infinispan REST接口的辅助类。
这个类公开了创建和设置向量数据库所需的Infinispan操作。
你需要一个没有身份验证的正在运行的 Infinispan (15+) 服务器。 你可以轻松启动一个,请参阅: rigazilla/infinispan-vector
- Parameters:
schema (str) – HTTP请求的模式:“http”或“https”。默认值为“http”
user (str) – 如果需要认证,用户和密码。默认值为 None
password (str) – 如果需要认证,用户和密码。默认值为 None
hosts (List[str]) – 服务器地址列表。默认值为 [“127.0.0.1:11222”]
cache_url (str) – 缓存API的URL端点。默认值为“/rest/v2/caches”
schema_url (str) – 模式API的URL端点。默认值为“/rest/v2/schemas”
use_post_for_query (bool) – 是否应该使用POST方法进行查询。默认为True
http2 (bool) – 是否应使用HTTP/2协议。需要pip install “httpx[http2]”来支持HTTP/2。默认值为True
verify (bool) – 是否必须验证TLS证书。默认值为True
kwargs (Any)
方法
__init__
([schema, user, password, hosts, ...])cache_clear
(cache_name)清除缓存 :param cache_name: 缓存的名称。
cache_delete
(name)删除一个缓存 :param name: 缓存的名称。
cache_exists
(cache_name)检查缓存是否存在 :param cache_name: 缓存的名称。
cache_post
(name, config)创建一个缓存 :param name: 缓存的名称。
get
(key, cache_name)获取一个条目 :param key: 条目的键 :type key: str :param cache_name: 目标缓存 :type cache_name: str
index_clear
(cache_name)清除缓存上的索引 :param cache_name: 缓存的名称。
index_reindex
(cache_name)在缓存上重建索引 :param cache_name: 缓存的名称。
post
(key, data, cache_name)发布一个条目 :param key: 条目的键 :type key: str :param data: 条目的内容,格式为json :type data: str :param cache_name: 目标缓存 :type cache_name: str
put
(key, data, cache_name)放入一个条目 :param key: 条目的键 :type key: str :param data: 条目的内容,格式为json :type data: str :param cache_name: 目标缓存 :type cache_name: str
req_query
(query, cache_name[, local])请求一个查询 :param query: 请求的查询 :type query: str :param cache_name: 目标缓存的名称 :type cache_name: str :param local: 查询是否为集群本地 :type local: boolean
resource_exists
(api_url)检查资源是否存在 :param api_url: 资源的URL。
schema_delete
(name)删除一个模式 :param name: 模式的名称。
schema_post
(name, proto)部署一个模式 :param name: 模式的名称。
- __init__(schema: str = 'http', user: str = '', password: str = '', hosts: List[str] = ['127.0.0.1:11222'], cache_url: str = '/rest/v2/caches', schema_url: str = '/rest/v2/schemas', use_post_for_query: bool = True, http2: bool = True, verify: bool = True, **kwargs: Any)[source]#
- Parameters:
schema (str) – HTTP请求的模式:“http”或“https”。默认值为“http”
user (str) – 如果需要认证,用户和密码。默认值为 None
password (str) – 如果需要认证,用户和密码。默认值为 None
hosts (List[str]) – 服务器地址列表。默认值为 [“127.0.0.1:11222”]
cache_url (str) – 缓存API的URL端点。默认值为“/rest/v2/caches”
schema_url (str) – 模式API的URL端点。默认值为“/rest/v2/schemas”
use_post_for_query (bool) – 是否应该使用POST方法进行查询。默认为True
http2 (bool) – 是否应使用HTTP/2协议。需要pip install “httpx[http2]”来支持HTTP/2。默认值为True
verify (bool) – 是否必须验证TLS证书。默认值为True
kwargs (Any)
- cache_clear(cache_name: str) Response [source]#
清除缓存 :param cache_name: 缓存的名称。 :type cache_name: str
- Returns:
一个包含操作结果的http响应
- Parameters:
cache_name (str)
- Return type:
响应
- cache_delete(name: str) Response [source]#
删除一个缓存 :param name: 缓存的名称。 :type name: str
- Returns:
一个包含操作结果的http响应
- Parameters:
名称 (字符串)
- Return type:
响应
- cache_exists(cache_name: str) bool [source]#
检查缓存是否存在 :param cache_name: 缓存的名称。 :type cache_name: str
- Returns:
如果缓存存在则为真
- Parameters:
cache_name (str)
- Return type:
布尔
- cache_post(name: str, config: str) Response [source]#
创建一个缓存 :param name: 缓存的名称。 :type name: str :param config: 缓存的配置。 :type config: str
- Returns:
一个包含操作结果的http响应
- Parameters:
name (str)
config (str)
- Return type:
响应
- get(key: str, cache_name: str) Response [source]#
获取一个条目 :param key: 条目的键 :type key: str :param cache_name: 目标缓存 :type cache_name: str
- Returns:
一个包含条目或错误的http响应
- Parameters:
key (str)
cache_name (str)
- Return type:
响应
- index_clear(cache_name: str) Response [source]#
清除缓存上的索引 :param cache_name: 缓存的名称。 :type cache_name: str
- Returns:
一个包含操作结果的http响应
- Parameters:
cache_name (str)
- Return type:
响应
- index_reindex(cache_name: str) Response [source]#
在缓存上重建索引 :param cache_name: 缓存的名称。 :type cache_name: str
- Returns:
一个包含操作结果的http响应
- Parameters:
cache_name (str)
- Return type:
响应
- post(key: str, data: str, cache_name: str) Response [source]#
发布一个条目 :param key: 条目的键 :type key: str :param data: 条目的内容,格式为json :type data: str :param cache_name: 目标缓存 :type cache_name: str
- Returns:
一个包含操作结果的http响应
- Parameters:
key (str)
data (str)
cache_name (str)
- Return type:
响应
- put(key: str, data: str, cache_name: str) Response [source]#
放入一个条目 :param key: 条目的键 :type key: str :param data: 条目的内容,格式为json :type data: str :param cache_name: 目标缓存 :type cache_name: str
- Returns:
一个包含操作结果的http响应
- Parameters:
key (str)
data (str)
cache_name (str)
- Return type:
响应
- req_query(query: str, cache_name: str, local: bool = False) Response [source]#
请求一个查询 :param query: 请求的查询 :type query: str :param cache_name: 目标缓存的名称 :type cache_name: str :param local: 查询是否本地到集群 :type local: boolean
- Returns:
一个包含结果集或错误的http响应
- Parameters:
query (str)
cache_name (str)
local (bool)
- Return type:
响应
- resource_exists(api_url: str) bool [source]#
检查资源是否存在 :param api_url: 资源的URL。 :type api_url: str
- Returns:
如果资源存在则为真
- Parameters:
api_url (str)
- Return type:
布尔