Camel.storages.vectordb storages.milvus

​

MilvusStorage

class MilvusStorage(BaseVectorStorage):

• vector_dim (int): The dimension of storing vectors.
• url_and_api_key (Tuple[str, str]): Tuple containing the URL and API key for connecting to a remote Milvus instance. URL maps to Milvus uri concept, typically “endpoint:port”. API key maps to Milvus token concept, for self-hosted it’s “username:pwd”, for Zilliz Cloud (fully-managed Milvus) it’s API Key.
• collection_name (Optional[str], optional): Name for the collection in the Milvus. If not provided, set it to the current time with iso format. (default: :obj:None) **kwargs (Any): Additional keyword arguments for initializing MilvusClient.

​

init

def __init__(
    self,
    vector_dim: int,
    url_and_api_key: Tuple[str, str],
    collection_name: Optional[str] = None,
    **kwargs: Any
):

​

_create_client

def _create_client(self, url_and_api_key: Tuple[str, str], **kwargs: Any):

• url_and_api_key (Tuple[str, str]): The URL and API key for the Milvus server. **kwargs: Additional keyword arguments passed to the Milvus client.

​

_check_and_create_collection

def _check_and_create_collection(self):

​

_create_collection

def _create_collection(self, collection_name: str, **kwargs: Any):

• collection_name (str): Name of the collection to be created. **kwargs (Any): Additional keyword arguments pass to create collection.

​

_delete_collection

def _delete_collection(self, collection_name: str):

• collection (str): Name of the collection to be deleted.

​

_collection_exists

def _collection_exists(self, collection_name: str):

• collection_name (str): The name of the collection to check.

​

_generate_collection_name

def _generate_collection_name(self):

​

_get_collection_info

def _get_collection_info(self, collection_name: str):

• collection_name (str): Name of the collection to be checked.

​

_validate_and_convert_vectors

def _validate_and_convert_vectors(self, records: List[VectorRecord]):

• records (List[VectorRecord]): List of vector records to validate and convert.

​

add

def add(self, records: List[VectorRecord], **kwargs):

• records (List[VectorRecord]): List of vectors to be added. **kwargs (Any): Additional keyword arguments pass to insert.

​

delete

def delete(self, ids: List[str], **kwargs: Any):

• ids (List[str]): List of unique identifiers for the vectors to be deleted. **kwargs (Any): Additional keyword arguments passed to delete.

​

status

def status(self):

​

query

def query(self, query: VectorDBQuery, **kwargs: Any):

• query (VectorDBQuery): The query object containing the search vector and the number of top similar vectors to retrieve. **kwargs (Any): Additional keyword arguments passed to search.

​

clear

def clear(self):

​

load

def load(self):

​

client

def client(self):