管理模式
此主题介绍了 Milvus 中的模式。模式用于定义集合的属性以及其中的字段。
字段模式
字段模式是字段的逻辑定义。在定义 集合模式 和 管理集合 之前,需要先定义字段模式。
Milvus 中每个集合仅支持一个主键字段。
字段模式属性
创建字段模式
为了减少数据插入的复杂性,Milvus 允许你在字段模式创建过程中为每个标量字段指定一个默认值,除了主键字段。这意味着如果在插入数据时将字段留空,将应用你为该字段指定的默认值。
创建一个普通字段模式:
from pymilvus import FieldSchema
id_field = FieldSchema(name="id", dtype=DataType.INT64, is_primary=True, description="primary id")
age_field = FieldSchema(name="age", dtype=DataType.INT64, description="age")
embedding_field = FieldSchema(name="embedding", dtype=DataType.FLOAT_VECTOR, dim=128, description="vector")
# 以下创建一个字段并将其用作分区键
position_field = FieldSchema(name="position", dtype=DataType.VARCHAR, max_length=256, is_partition_key=True)
创建具有默认字段值的字段模式:
from pymilvus import FieldSchema
fields = [
FieldSchema(name="id", dtype=DataType.INT64, is_primary=True),
# 为字段`age`配置默认值`25`
FieldSchema(name="age", dtype=DataType.INT64, default_value=25, description="age"),
embedding_field = FieldSchema(name="embedding", dtype=DataType.FLOAT_VECTOR, dim=128, description="vector")
]
支持的数据类型
DataType
定义了字段包含的数据类型。不同的字段支持不同的数据类型。
-
主键字段支持:
- INT64:numpy.int64
- VARCHAR:VARCHAR
-
标量字段支持:
- BOOL:布尔值(
true
或false
) - INT8:numpy.int8
- INT16:numpy.int16
- INT32:numpy.int32
- INT64:numpy.int64
- FLOAT:numpy.float32
- DOUBLE:numpy.double
- VARCHAR:VARCHAR
- JSON:JSON
- 数组:Array
JSON 作为一种组合数据类型可用。JSON 字段包含键值对。每个键是一个字符串,值可以是数字、字符串、布尔值、数组或列表。详细信息请参阅 JSON:一种新的数据类型。
- BOOL:布尔值(
-
向量字段支持:
- BINARY_VECTOR:以 0 和 1 的序列形式存储二进制数据,用于图像处理和信息检索中的紧凑特征表示。
- FLOAT_VECTOR:以 32 位浮点数形式存储,常用于科学计算和机器学习中表示实数。
- FLOAT16_VECTOR:以 16 位半精度浮点数形式存储,用于深度学习和 GPU 计算以获得内存和带宽效率。
- BFLOAT16_VECTOR:以 16 位浮点数形式存储,具有与 Float32 相同的指数范围,用于深度学习以减少内存和计算需求,而对精度影响不大。
- SPARSE_FLOAT_VECTOR:存储非零元素及其相应索引的列表,用于表示稀疏向量。有关详细信息,请参阅 稀疏向量。
Milvus 支持在一个集合中使用多个向量字段。有关详细信息,请参阅 多向量搜索。
集合模式
集合模式是集合的逻辑定义。通常在定义 字段模式 之前需要定义集合模式并进行 集合管理。
集合模式属性
创建集合模式
from pymilvus import FieldSchema, CollectionSchema
id_field = FieldSchema(name="id", dtype=DataType.INT64, is_primary=True, description="主键id")
age_field = FieldSchema(name="age", dtype=DataType.INT64, description="年龄")
embedding_field = FieldSchema(name="embedding", dtype=DataType.FLOAT_VECTOR, dim=128, description="向量")
# 如果需要基于分区键字段实现多租户功能,请在字段上启用分区键
position_field = FieldSchema(name="position", dtype=DataType.VARCHAR, max_length=256, is_partition_key=True)
# 如果需要使用动态字段,请将 enable_dynamic_field 设置为 True
schema = CollectionSchema(fields=[id_field, age_field, embedding_field], auto_id=False, enable_dynamic_field=True, description="集合的描述")
使用指定的模式创建集合:
from pymilvus import Collection
collection_name1 = "教程_1"
collection1 = Collection(name=collection_name1, schema=schema, using='default', shards_num=2)
- 你可以使用 shards_num 来定义分片数量。
- 你可以通过在 using 中指定别名来定义 Milvus 服务器。
- 如果需要实现 基于分区键的多租户功能,请将字段上的 is_partition_key 设置为 True 。
- 如果需要 启用动态字段,请在集合模式中将 enable_dynamic_field 设置为 True 。
import pandas as pd
df = pd.DataFrame({
"id": [i for i in range(nb)],
"age": [random.randint(20, 40) for i in range(nb)],
"embedding": [[random.random() for _ in range(dim)] for _ in range(nb)],
"position": "test_pos"
})
collection, ins_res = Collection.construct_from_dataframe(
'my_collection',
df,
primary_field='id',
auto_id=False
)