Milvus向量数据库07-向量数据库实战

from pymilvus import MilvusClient
# 1-连接客户端
client = MilvusClient(uri="https://in03-28a0c92a05bbf57.serverless.ali-cn-hangzhou.cloud.zilliz.com.cn", token="363e395f0ec26b5adbdc2deacc279d8e3476ec560dde3959d186aa5cb81e821a86b93c98bcc386bc5e494903d66ae847fb614b9b")# 2-查看Pipeline信息
result = client.describe_collection(collection_name="usr_collection")print("\n",json.dumps(result))

复制代码

{"collection_name":"usr_collection","auto_id":true,"num_shards":1,"description":"usr_collection","fields":[{"field_id":100,"name":"Auto_id","description":"The Primary Key","type":5,"params":{},"auto_id":true,"is_primary":true},{"field_id":101,"name":"vector","description":"","type":101,"params":{"dim":5}},{"field_id":102,"name":"name","description":"用户姓名","type":21,"params":{"max_length":200}},{"field_id":103,"name":"age","description":"年龄","type":3,"params":{}},{"field_id":104,"name":"address","description":"地址","type":21,"params":{"max_length":200}},{"field_id":105,"name":"color","description":"颜色","type":21,"params":{"max_length":200}},{"field_id":106,"name":"usrId","description":"用户ID","type":3,"params":{}}],"functions":[],"aliases":[],"collection_id":454417515731180860,"consistency_level":2,"properties":{},"num_partitions":1,"enable_dynamic_field":true}

复制代码

3-IngestionPipeline添加数据

import json
import requests
# 设置请求的URL
url ="https://controller.api.ali-cn-hangzhou.cloud.zilliz.com.cn/v1/pipelines/pipe-8b6be8d582a69184bad796/run"# 设置请求头
headers ={"Content-Type":"application/json","Authorization":"Bearer 26c9a64315e62e89aea69ef7560c87d0bdf5f06ba58ab2639ad564bf227747c739b47fba5c859952ceb1eb49bd1f4f55aa0a6ff7"}# 设置请求体
data ={"data":{"text_list":["Zilliz Cloud is a fully managed vector database and data services, empowering you to unlock the full potential of unstructured data for your AI applications.","It can store, index, and manage massive embedding vectors generated by deep neural networks and other machine learning (ML) models."],"color":"my color","age":123}}# 发送POST请求
response = requests.post(url, headers=headers, data=json.dumps(data))# 打印响应print(response.status_code)print(json.dumps(response.json()))

复制代码

{"code":200,"data":{"num_entities":2,"usage":{"embedding":63},"ids":[454417515730834000,454417515730834000]}}

复制代码

4-创建查询SearchPipeline

5-SearchPipeline查询验证

import json
import requests
# 设置请求的URL
url ="https://controller.api.ali-cn-hangzhou.cloud.zilliz.com.cn/v1/pipelines/pipe-b22eb8274883e412df2ef9/run"# 设置请求头
headers ={"Content-Type":"application/json","Authorization":"Bearer 26c9a64315e62e89aea69ef7560c87d0bdf5f06ba58ab2639ad564bf227747c739b47fba5c859952ceb1eb49bd1f4f55aa0a6ff7"}# 设置请求体
data ={"data":{"query_text":"other"},"params":{"limit":1,"offset":0,"outputFields":[],"filter":"id >= 0"}}# 发送POST请求
response = requests.post(url, headers=headers, data=json.dumps(data))# 打印响应print(response.status_code)print(json.dumps(response.json()))

复制代码

{"code":200,"data":{"result":[{"id":454417515730827500,"distance":0.7203079462051392,"text":"my other text"}],"usage":{"embedding":11,"rerank":0}}}

复制代码