|
|
|
# ANN Insert Operator: Milvus
|
|
|
|
|
|
|
|
*author: shiyu*
|
|
|
|
|
|
|
|
<br />
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
## Desription
|
|
|
|
|
|
|
|
Insert data into Milvus collections. **Please make sure you have [created Milvus Collection](https://milvus.io/docs/v2.0.x/create_collection.md)
|
|
|
|
and connected Milvus before loading the data.**
|
|
|
|
|
|
|
|
<br />
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
## Code Example
|
|
|
|
|
|
|
|
### Example
|
|
|
|
|
|
|
|
*Write the pipeline in simplified style:*
|
|
|
|
|
|
|
|
```python
|
|
|
|
import towhee
|
|
|
|
|
|
|
|
towhee.dc(your_embeddings) \
|
|
|
|
.ann_insert.milvus(uri='tcp://<milvus-host>:<milvus-port>/<collection-name>')
|
|
|
|
```
|
|
|
|
|
|
|
|
*Write a same pipeline with explicit inputs/outputs name specifications:*
|
|
|
|
|
|
|
|
```python
|
|
|
|
import towhee
|
|
|
|
|
|
|
|
towhee.dc['vec'](your_embeddings) \
|
|
|
|
.ann_insert.milvus['vec', 'results'](uri='tcp://<milvus-host>:<milvus-port>/<collection-name>') \
|
|
|
|
.show()
|
|
|
|
```
|
|
|
|
|
|
|
|
<img src="./result.png" height="150px"/>
|
|
|
|
|
|
|
|
### Load Collection
|
|
|
|
|
|
|
|
> Please load the Collection after inserted data.
|
|
|
|
|
|
|
|
```python
|
|
|
|
collection.load()
|
|
|
|
```
|
|
|
|
|
|
|
|
<br />
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
## Factory Constructor
|
|
|
|
|
|
|
|
Create the operator via the following factory method:
|
|
|
|
|
|
|
|
***ann_insert.milvus(collection)***
|
|
|
|
|
|
|
|
<br />
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
**Parameters:**
|
|
|
|
|
|
|
|
***uri:*** *str*
|
|
|
|
|
|
|
|
The uri for Milvus Collection, such as `tcp://<milvus-host>:<milvus-port>/<collection-name>`.
|
|
|
|
|
|
|
|
|
|
|
|
<br />
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
## Interface
|
|
|
|
|
|
|
|
**Parameters:**
|
|
|
|
|
|
|
|
***data:*** *list*
|
|
|
|
|
|
|
|
The embedding data to be inserted.
|
|
|
|
|
|
|
|
<br />
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
**Returns:** *mr*
|
|
|
|
|
|
|
|
Return milvus results with `milvus.insert`.
|