Camel.storages.vectordb storages.qdrant

​

QdrantStorage

class QdrantStorage(BaseVectorStorage):

• vector_dim (int): The dimension of storing vectors.
• collection_name (Optional[str], optional): Name for the collection in the Qdrant. If not provided, set it to the current time with iso format. (default: :obj:None)
• url_and_api_key (Optional[Tuple[str, str]], optional): Tuple containing the URL and API key for connecting to a remote Qdrant instance. (default: :obj:None)
• path (Optional[str], optional): Path to a directory for initializing a local Qdrant client. (default: :obj:None)
• distance (VectorDistance, optional): The distance metric for vector comparison (default: :obj:VectorDistance.COSINE)
• delete_collection_on_del (bool, optional): Flag to determine if the collection should be deleted upon object destruction. (default: :obj:False) **kwargs (Any): Additional keyword arguments for initializing QdrantClient.

• If url_and_api_key is provided, it takes priority and the client will attempt to connect to the remote Qdrant instance using the URL endpoint.
• If url_and_api_key is not provided and path is given, the client will use the local path to initialize Qdrant.
• If neither url_and_api_key nor path is provided, the client will be initialized with an in-memory storage (":memory:").

​

init

def __init__(
    self,
    vector_dim: int,
    collection_name: Optional[str] = None,
    url_and_api_key: Optional[Tuple[str, str]] = None,
    path: Optional[str] = None,
    distance: VectorDistance = VectorDistance.COSINE,
    delete_collection_on_del: bool = False,
    **kwargs: Any
):

​

del

def __del__(self):

​

_create_client

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

​

_check_and_create_collection

def _check_and_create_collection(self):

​

_create_collection

def _create_collection(
    self,
    collection_name: str,
    size: int,
    distance: VectorDistance = VectorDistance.COSINE,
    **kwargs: Any
):

• collection_name (str): Name of the collection to be created.
• size (int): Dimensionality of vectors to be stored in this collection.
• distance (VectorDistance, optional): The distance metric to be used for vector similarity. (default: :obj:VectorDistance.COSINE) **kwargs (Any): Additional keyword arguments.

​

_delete_collection

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

• collection (str): Name of the collection to be deleted. **kwargs (Any): Additional keyword arguments.

​

_collection_exists

def _collection_exists(self, collection_name: str):

​

_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.

​

close_client

def close_client(self, **kwargs):

​

add

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

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

​

update_payload

def update_payload(
    self,
    ids: List[str],
    payload: Dict[str, Any],
    **kwargs: Any
):

• ids (List[str]): List of unique identifiers for the vectors to be updated.
• payload (Dict[str, Any]): List of payloads to be updated. **kwargs (Any): Additional keyword arguments.

​

delete_collection

def delete_collection(self):

​

delete

def delete(
    self,
    ids: Optional[List[str]] = None,
    payload_filter: Optional[Dict[str, Any]] = None,
    **kwargs: Any
):

• ids (Optional[List[str]], optional): List of unique identifiers for the vectors to be deleted.
• payload_filter (Optional[Dict[str, Any]], optional): A filter for the payload to delete points matching specific conditions. If ids is provided, payload_filter will be ignored unless both are combined explicitly. **kwargs (Any): Additional keyword arguments pass to QdrantClient. delete.

• If ids is provided, the points with these IDs will be deleted directly, and the payload_filter will be ignored.
• If ids is not provided but payload_filter is, then points matching the payload_filter will be deleted.

​

status

def status(self):

​

query

def query(
    self,
    query: VectorDBQuery,
    filter_conditions: Optional[Dict[str, Any]] = None,
    **kwargs: Any
):

• query (VectorDBQuery): The query object containing the search vector and the number of top similar vectors to retrieve.
• filter_conditions (Optional[Dict[str, Any]], optional): A dictionary specifying conditions to filter the query results. **kwargs (Any): Additional keyword arguments.

​

clear

def clear(self):

​

load

def load(self):

​

client

def client(self):