Camel.storages.vectordb storages.pgvector

​

PgVectorStorage

class PgVectorStorage(BaseVectorStorage):

• vector_dim (int): The dimension of the vectors to be stored.
• conn_info (Dict[str, Any]): Connection information for psycopg2.connect.
• table_name (str, optional): Name of the table to store vectors. (default: :obj:None)
• distance (VectorDistance, optional): Distance metric for vector comparison. (default: :obj:VectorDistance.COSINE)

​

init

def __init__(
    self,
    vector_dim: int,
    conn_info: Dict[str, Any],
    table_name: Optional[str] = None,
    distance: VectorDistance = VectorDistance.COSINE,
    **kwargs: Any
):

• vector_dim (int): The dimension of the vectors.
• conn_info (Dict[str, Any]): Connection info for psycopg2.connect.
• table_name (str, optional): Table name. (default: :obj:None)
• distance (VectorDistance, optional): Distance metric. (default: :obj:VectorDistance.COSINE)

​

_ensure_table

def _ensure_table(self):

​

_ensure_index

def _ensure_index(self):

​

add

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

• records (List[VectorRecord]): List of vector records to add or update.

​

delete

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

• ids (List[str]): List of record IDs to delete.

​

query

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

• query (VectorDBQuery): Query object containing the query vector and top_k. **kwargs (Any): Additional keyword arguments for the query.

​

status

def status(self, **kwargs: Any):

​

clear

def clear(self):

​

load

def load(self):

​

close

def close(self):

​

del

def __del__(self):

​

client

def client(self):