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:

布尔

schema_delete(name: str) Response[source]#

删除一个模式 :param name: 模式的名称。 :type name: str

Returns:

一个包含操作结果的http响应

Parameters:

名称 (字符串)

Return type:

响应

schema_post(name: str, proto: str) Response[source]#

部署一个模式 :param name: 模式的名称。将用作键 :type name: str :param proto: protobuf 模式 :type proto: str

Returns:

一个包含操作结果的http响应

Parameters:
  • name (str)

  • proto (str)

Return type:

响应