Skip to main content
Open In ColabOpen on GitHub

百度云 Elasticsearch VectorSearch

百度云 VectorSearch 是一项完全托管的企业级分布式搜索和分析服务,与开源版本 100% 兼容。百度云 VectorSearch 为结构化/非结构化数据提供低成本、高性能、高可靠性的检索和分析平台级产品服务。作为一款向量数据库,它支持多种索引类型和相似度距离方法。

百度云 Elasticsearch 提供权限管理机制,您可以自由配置集群权限,进一步确保数据安全。

本 Notebook 展示了如何使用与 Baidu Cloud ElasticSearch VectorStore 相关的क्स्टra。要运行,您应该有一个正在运行的 百度云 Elasticsearch 实例:

请阅读帮助文档,以快速熟悉和配置百度云 Elasticsearch 实例。

实例启动和运行后,请按照以下步骤拆分文档、获取嵌入、连接到百度云 Elasticsearch 实例、索引文档以及执行向量检索。

我们首先需要安装以下 Python 包。

%pip install --upgrade --quiet langchain-community elasticsearch == 7.11.0

首先,我们要使用QianfanEmbeddings,因此需要获取Qianfan的AK和SK。关于QianFan的详细信息,请参考Baidu Qianfan Workshop

import getpass
import os

if "QIANFAN_AK" not in os.environ:
os.environ["QIANFAN_AK"] = getpass.getpass("Your Qianfan AK:")
if "QIANFAN_SK" not in os.environ:
os.environ["QIANFAN_SK"] = getpass.getpass("Your Qianfan SK:")

其次,拆分文档并获取 embeddings。

from langchain_community.document_loaders import TextLoader
from langchain_text_splitters import CharacterTextSplitter

loader = TextLoader("../../../state_of_the_union.txt")
documents = loader.load()
text_splitter = CharacterTextSplitter(chunk_size=1000, chunk_overlap=0)
docs = text_splitter.split_documents(documents)

from langchain_community.embeddings import QianfanEmbeddingsEndpoint

embeddings = QianfanEmbeddingsEndpoint()

然后,创建一个百度 Elasticsearch 可访问的实例。

# Create a bes instance and index docs.
from langchain_community.vectorstores import BESVectorStore

bes = BESVectorStore.from_documents(
documents=docs,
embedding=embeddings,
bes_url="your bes cluster url",
index_name="your vector index",
)
bes.client.indices.refresh(index="your vector index")
API Reference:BESVectorStore

最后,查询和检索数据

query = "What did the president say about Ketanji Brown Jackson"
docs = bes.similarity_search(query)
print(docs[0].page_content)

如果您在使用过程中遇到任何问题,请随时联系 liuboyao@baidu.comchenweixu01@baidu.com,我们将竭诚为您提供支持。