Qdrant 是专为扩展过滤支持而设计的向量相似度搜索引擎和向量数据库，这使得它适用于各种基于神经网络的语义匹配、图像搜索等应用。
Qdrant 使用 Rust 🦀 编写，即使在高负载下也能快速、可靠地工作。
Qdrant架构
上图展示了 Qdrant 一些主要组件的高级概述。以下是您应该熟悉的术语。
- 集合（Collections）：集合是一组命名的点（带有有效负载的向量），您可以在其中进行搜索。同一集合中每个点的向量必须具有相同的维度，并通过单个度量进行比较。命名向量可用于在单个点中包含多个向量，每个向量都可以有自己的维度和度量要求。
- 距离度量（Distance Metrics）：这些用于测量向量之间的相似性，必须在创建集合的同时选择它们。度量的选择取决于向量的获取方式，特别是取决于将用于编码新查询的神经网络。
- 点（Points）：点是 Qdrant 运行的中心实体，它们由向量和可选的 id 和有效负载组成。
-
- id：向量的唯一标识符。
- 矢量（Vector）：数据的高维表示，例如图像、声音、文档、视频等。
- 有效负载（Payload）：有效负载是一个 JSON 对象，其中包含可以添加到向量中的附加数据。
- 存储（Storage）：Qdrant 可以使用两种存储选项之一：内存存储（将所有向量存储在 RAM 中，具有最高速度，因为仅需要持久性才需要磁盘访问）或Memmap存储（创建与磁盘上的文件）。
- 客户端：可用于连接到 Qdrant 的编程语言。
快速开始
在开始之前，请确保 Docker 已安装并在您的系统上运行。
快速启动
docker run --privileged -p 6333:6333 qdrant/qdrant
--privileged 是我本地执行时出现Operation not permitted进程创建受限加的，一般不用加
数据挂载启动
docker run -p 6333:6333 -p 6334:6334 \ -v $(pwd)/qdrant_storage:/qdrant/storage:z \ qdrant/qdrant在默认配置下，所有数据都将存储在该./qdrant_storage目录中。
Qdrant 现在可以访问：
- REST API：本地主机：6333
- 网页用户界面：本地主机：6333/dashboard
- GRPC API：本地主机：6334
网页直接访问面板： http://127.0.0.1:6333/collections/dashboard
网页直接访问API：http://127.0.0.1:6333/collections，就可以看到
collections返回当前的所有集合，那就让我们来用python客户端连接，并创建一个集合吧
增删改查
创建一个集合
您将把所有矢量数据存储在 Qdrant 集合中，我们就这样称呼它test_collection吧。该集合将使用点积距离度量来比较向量。
from qdrant_client.http.models import Distance, VectorParams client.create_collection( collection_name="test_collection", vectors_config=VectorParams(size=4, distance=Distance.DOT), )size：向量的大小（维度）
distance：距离度量类型
- COSINE 余弦相似度（Cosine similarity）：余弦相似度是一种常用的向量相似度度量方法，它衡量了两个向量之间的夹角余弦值。在Qdrant中，可以使用COSINE作为距离度量方法来计算余弦相似度。
- EUCLID 欧氏距离（Euclidean distance）：欧氏距离是最常见的距离度量方法，用于计算向量空间中两个向量之间的直线距离。在Qdrant中，可以使用L2作为距离度量方法来计算欧氏距离。
- 点积（Dot Product）：它是一种常见的向量运算。点积是将两个向量的对应元素相乘，并将乘积相加得到的标量值。可以使用点积来计算向量之间的夹角余弦值。夹角余弦值反映了两个向量的方向相似程度。夹角余弦值的取值范围在 -1 到 1 之间。
相似性学习模型中最典型的度量是余弦度量。
添加向量
现在让我们添加一些带有有效负载的向量。有效负载是您想要与向量关联的其他数据：
from qdrant_client.http.models import PointStruct operation_info = client.upsert( collection_name="test_collection", wait=True, points=[ PointStruct(id=1, vector=[0.05, 0.61, 0.76, 0.74], payload={"city": "Berlin"}), PointStruct(id=2, vector=[0.19, 0.81, 0.75, 0.11], payload={"city": "London"}), PointStruct(id=3, vector=[0.36, 0.55, 0.47, 0.94], payload={"city": "Moscow"}), PointStruct(id=4, vector=[0.18, 0.01, 0.85, 0.80], payload={"city": "New York"}), PointStruct(id=5, vector=[0.24, 0.18, 0.22, 0.44], payload={"city": "Beijing"}), PointStruct(id=6, vector=[0.35, 0.08, 0.11, 0.44], payload={"city": "Mumbai"}), ], ) print(operation_info)执行结果：
operation_id=0 status=
运行查询
让我们问一个基本问题 - 我们存储的哪个向量与查询向量最相似[0.2, 0.1, 0.9, 0.7]？
search_result = client.search( collection_name="test_collection", query_vector=[0.2, 0.1, 0.9, 0.7], limit=3 # , with_vectors=True, with_payload=True ) print(search_result)执行结果：
ScoredPoint(id=4, version=0, score=1.362, payload={"city": "New York"}, vector=None), ScoredPoint(id=1, version=0, score=1.273, payload={"city": "Berlin"}, vector=None), ScoredPoint(id=3, version=0, score=1.208, payload={"city": "Moscow"}, vector=None)结果以相似度递减的顺序返回。请注意，默认情况下，这些结果中缺少有效负载和矢量数据。有关如何启用它的信息，请参阅结果中的有效负载和向量。
执行结果：
[ ScoredPoint(id=4, version=0, score=1.362, payload={'city': 'New York'}, vector=[0.18, 0.01, 0.85, 0.8]), ScoredPoint(id=6, version=0, score=1.28, payload={'city': 'Berlin'}, vector=[0.05, 0.61, 0.76, 0.75]), ScoredPoint(id=1, version=0, score=1.273, payload={'city': 'Berlin'}, vector=[0.05, 0.61, 0.76, 0.74]) ]思考：上面的举例模式类似现实生活中什么场景呢？？？
添加过滤器
我们可以通过按有效负载过滤来进一步缩小结果范围。让我们查找包含“London”的最接近的结果。
from qdrant_client.http.models import Filter, FieldCondition, MatchValue search_result = client.search( collection_name="test_collection", query_vector=[0.2, 0.1, 0.9, 0.7], query_filter=Filter( must=[FieldCondition(key="city", match=MatchValue(value="London"))] ), with_payload=True, limit=3, ) print(search_result)执行结果：
ScoredPoint(id=2, version=0, score=0.871, payload={"city": "London"}, vector=None)您刚刚进行了矢量搜索。您将向量加载到数据库中并使用您自己的向量查询数据库。Qdrant 找到最接近的结果并向您提供相似度分数。
client.search()参数说明：
- collection_name（必需）：要搜索的集合名称。
- query_vector（必需）：查询向量。可以是以下类型之一：
-
- types.NumpyArray：NumPy 数组表示的向量。
- Sequence[float]：浮点数列表表示的向量。
- Tuple[str, List[float]]：带有向量名称的元组。
- types.NamedVector：命名向量对象。
- query_filter（可选）：过滤器条件。可以使用 types.Filter 类型的对象来指定过滤条件。默认为 None。
- search_params（可选）：搜索参数。可以使用 types.SearchParams 类型的对象来指定搜索参数。默认为 None。
-
- ef（可选）：查询的有效范围（Efficient Search）。它控制搜索的速度和准确性之间的权衡。较高的值会提高搜索准确性，但会增加搜索时间。
- ef_search（可选）：查询期间的最大搜索次数。它控制搜索的时间和资源消耗。较高的值会增加搜索时间，但可能提高搜索结果的准确性。
- limit（可选）：返回结果的最大数量。默认为 10。
- offset（可选）：结果偏移量，用于分页。默认为 0。
- with_payload（可选）：是否返回结果的负载信息。
-
- True：返回搜索结果中的所有载荷数据。
- False：不返回任何载荷数据。
- Sequence[str]：指定要返回的特定载荷字段列表。
- with_vectors（可选）：是否返回结果的向量信息。
- score_threshold（可选）：结果的得分阈值。只返回得分高于或等于阈值的结果。默认为 None，表示不应用阈值。
- append_payload（可选）：是否将负载信息追加到搜索结果中。默认为 True。
- consistency（可选）：读一致性选项。可以是 types.ReadConsistency 类型的对象，用于指定读操作的一致性级别。默认为 None。
- **kwargs：其他可选参数。
search方法返回一个包含 types.ScoredPoint 对象的列表，每个对象表示一个得分较高的向量点。
我们可以根据需要使用这些参数来执行 Qdrant 的搜索操作，并根据返回结果进行进一步处理。
删除向量
def test_delete(self): self.client.delete( collection_name="test_collection", points_selector=models.PointIdsList( points=[6], ), )删除指定过滤器下的向量
def test_delete_filter(self): self.client.delete( collection_name="test_collection", points_selector=models.FilterSelector( filter=models.Filter( must=[ models.FieldCondition( key="city", match=models.MatchValue(value="New York"), ), ], ) ), )问题：上面入参的都是用vector=[0.05, 0.61, 0.76, 0.74]这种向量，那和我的业务数据怎么关联呢???
-
-
-
-