qdrant#

__all__ = ['QdrantVectorStoreDriver'] module-attribute

Attributes#

Name	Type	Description
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.location" title="location = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.location)"><code class="language-python">location</code></a>	Optional[str]	An optional location for the Qdrant client. If set to ':memory:', an in-memory client is used.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.url" title="url = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.url)"><code class="language-python">url</code></a>	Optional[str]	An optional Qdrant API URL.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.host" title="host = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.host)"><code class="language-python">host</code></a>	Optional[str]	An optional Qdrant host.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.path" title="path = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.path)"><code class="language-python">path</code></a>	Optional[str]	Persistence path for QdrantLocal. Default: None<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.port" title="port = field(default=6333, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.port)"><code class="language-python">port</code></a>	int	The port number for the Qdrant client. Defaults: 6333.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.grpc_port" title="grpc_port = field(default=6334, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.grpc_port)"><code class="language-python">grpc_port</code></a>	int	The gRPC port number for the Qdrant client. Defaults: 6334.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.prefer_grpc" title="prefer_grpc = field(default=False, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.prefer_grpc)"><code class="language-python">prefer_grpc</code></a>	bool	A boolean indicating whether to prefer gRPC over HTTP. Defaults: False.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.force_disable_check_same_thread" title="force_disable_check_same_thread = field(default=False, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.force_disable_check_same_thread)"><code class="language-python">force_disable_check_same_thread</code></a>	Optional[bool]	For QdrantLocal, force disable check_same_thread. Default: False Only use this if you can guarantee that you can resolve the thread safety outside QdrantClient.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.timeout" title="timeout = field(default=5, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.timeout)"><code class="language-python">timeout</code></a>	Optional[int]	Timeout for REST and gRPC API requests. Default: 5 seconds for REST and unlimited for gRPC<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.api_key" title="api_key = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.api_key)"><code class="language-python">api_key</code></a>	Optional[str]	API key for authentication in Qdrant Cloud. Defaults: False<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.https" title="https = field(default=True, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.https)"><code class="language-python">https</code></a>	bool	If true - use HTTPS(SSL) protocol. Default: True<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.prefix" title="prefix = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.prefix)"><code class="language-python">prefix</code></a>	Optional[str]	Add prefix to the REST URL path. Example: service/v1 will result in Example: service/v1 will result in http://localhost:6333/service/v1/{qdrant-endpoint} for REST API. Defaults: None<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.distance" title="distance = field(default=DEFAULT_DISTANCE, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.distance)"><code class="language-python">distance</code></a>	str	The distance metric to be used for the vectors. Defaults: 'COSINE'.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.collection_name" title="collection_name = field(kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.collection_name)"><code class="language-python">collection_name</code></a>	str	The name of the Qdrant collection.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.vector_name" title="vector_name = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.vector_name)"><code class="language-python">vector_name</code></a>	Optional[str]	An optional name for the vectors.<br/>
<a href="qdrant.mdx#griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.content_payload_key" title="content_payload_key = field(default=CONTENT_PAYLOAD_KEY, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute (griptape.drivers.vector.qdrant.QdrantVectorStoreDriver.content_payload_key)"><code class="language-python">content_payload_key</code></a>	str	The key for the content payload in the metadata. Defaults: 'data'.<br/>

Source Code in griptape/drivers/vector/qdrant_vector_store_driver.py

@define
class QdrantVectorStoreDriver(BaseVectorStoreDriver):
    """Vector Store Driver for Qdrant.

    Attributes:
        location: An optional location for the Qdrant client. If set to :memory:, an in-memory client is used.
        url: An optional Qdrant API URL.
        host: An optional Qdrant host.
        path: Persistence path for QdrantLocal. Default: None
        port: The port number for the Qdrant client. Defaults: 6333.
        grpc_port: The gRPC port number for the Qdrant client. Defaults: 6334.
        prefer_grpc: A boolean indicating whether to prefer gRPC over HTTP. Defaults: False.
        force_disable_check_same_thread: For QdrantLocal, force disable check_same_thread. Default: False Only use this if you can guarantee that you can resolve the thread safety outside QdrantClient.
        timeout: Timeout for REST and gRPC API requests. Default: 5 seconds for REST and unlimited for gRPC
        api_key: API key for authentication in Qdrant Cloud. Defaults: False
        https: If true - use HTTPS(SSL) protocol. Default: True
        prefix: Add prefix to the REST URL path. Example: service/v1 will result in Example: service/v1 will result in http://localhost:6333/service/v1/{qdrant-endpoint} for REST API. Defaults: None
        distance: The distance metric to be used for the vectors. Defaults: COSINE.
        collection_name: The name of the Qdrant collection.
        vector_name: An optional name for the vectors.
        content_payload_key: The key for the content payload in the metadata. Defaults: data.
    """

    location: Optional[str] = field(default=None, kw_only=True, metadata={"serializable": True})
    url: Optional[str] = field(default=None, kw_only=True, metadata={"serializable": True})
    host: Optional[str] = field(default=None, kw_only=True, metadata={"serializable": True})
    path: Optional[str] = field(default=None, kw_only=True, metadata={"serializable": True})
    port: int = field(default=6333, kw_only=True, metadata={"serializable": True})
    grpc_port: int = field(default=6334, kw_only=True, metadata={"serializable": True})
    prefer_grpc: bool = field(default=False, kw_only=True, metadata={"serializable": True})
    api_key: Optional[str] = field(default=None, kw_only=True, metadata={"serializable": True})
    https: bool = field(default=True, kw_only=True, metadata={"serializable": True})
    prefix: Optional[str] = field(default=None, kw_only=True, metadata={"serializable": True})
    force_disable_check_same_thread: Optional[bool] = field(
        default=False,
        kw_only=True,
        metadata={"serializable": True},
    )
    timeout: Optional[int] = field(default=5, kw_only=True, metadata={"serializable": True})
    distance: str = field(default=DEFAULT_DISTANCE, kw_only=True, metadata={"serializable": True})
    collection_name: str = field(kw_only=True, metadata={"serializable": True})
    vector_name: Optional[str] = field(default=None, kw_only=True, metadata={"serializable": True})
    content_payload_key: str = field(default=CONTENT_PAYLOAD_KEY, kw_only=True, metadata={"serializable": True})
    _client: Optional[QdrantClient] = field(
        default=None, kw_only=True, alias="client", metadata={"serializable": False}
    )

    @lazy_property()
    def client(self) -> QdrantClient:
        return import_optional_dependency("qdrant_client").QdrantClient(
            location=self.location,
            url=self.url,
            host=self.host,
            path=self.path,
            port=self.port,
            prefer_grpc=self.prefer_grpc,
            grpc_port=self.grpc_port,
            api_key=self.api_key,
            https=self.https,
            prefix=self.prefix,
            force_disable_check_same_thread=self.force_disable_check_same_thread,
            timeout=self.timeout,
        )

    def delete_vector(self, vector_id: str) -> None:
        """Delete a vector from the Qdrant collection based on its ID.

        Parameters:
            vector_id (str | id): ID of the vector to delete.
        """
        deletion_response = self.client.delete(
            collection_name=self.collection_name,
            points_selector=import_optional_dependency("qdrant_client.http.models").PointIdsList(points=[vector_id]),
        )
        if deletion_response.status == import_optional_dependency("qdrant_client.http.models").UpdateStatus.COMPLETED:
            logging.info("ID %s is successfully deleted", vector_id)

    def query_vector(
        self,
        vector: list[float],
        *,
        count: Optional[int] = None,
        namespace: Optional[str] = None,
        include_vectors: bool = False,
        **kwargs,
    ) -> list[BaseVectorStoreDriver.Entry]:
        """Query the Qdrant collection based on a query vector.

        Parameters:
            vector (list[float]): Query vector.
            count (Optional[int]): Optional number of results to return.
            namespace (Optional[str]): Optional namespace of the vectors.
            include_vectors (bool): Whether to include vectors in the results.

        Returns:
            list[BaseVectorStoreDriver.Entry]: List of Entry objects.
        """
        # Create a search request
        request = {"collection_name": self.collection_name, "query_vector": vector, "limit": count}
        request = {k: v for k, v in request.items() if v is not None}
        results = self.client.search(**request)

        # Convert results to QueryResult objects
        return [
            BaseVectorStoreDriver.Entry(
                id=str(result.id),
                vector=result.vector if include_vectors else [],  # pyright: ignore[reportArgumentType]
                score=result.score,
                meta={k: v for k, v in result.payload.items() if k not in ["_score", "_tensor_facets"]},
            )
            for result in results
            if result.payload is not None
        ]

    def upsert_vector(
        self,
        vector: list[float],
        *,
        vector_id: Optional[str] = None,
        namespace: Optional[str] = None,
        meta: Optional[dict] = None,
        content: Optional[str] = None,
        **kwargs,
    ) -> str:
        """Upsert vectors into the Qdrant collection.

        Parameters:
            vector (list[float]): The vector to be upserted.
            vector_id (Optional[str]): Optional vector ID.
            namespace (Optional[str]): Optional namespace for the vector.
            meta (Optional[dict]): Optional dictionary containing metadata.
            content (Optional[str]): The text content to be included in the payload.

        Returns:
            str: The ID of the upserted vector.
        """
        if vector_id is None:
            vector_id = str(uuid.uuid5(uuid.NAMESPACE_DNS, str(vector)))

        if meta is None:
            meta = {}

        if content:
            meta[self.content_payload_key] = content

        points = import_optional_dependency("qdrant_client.http.models").Batch(
            ids=[vector_id],
            vectors=[vector],
            payloads=[meta] if meta else None,
        )

        self.client.upsert(collection_name=self.collection_name, points=points)
        return vector_id

    def load_entry(self, vector_id: str, *, namespace: Optional[str] = None) -> Optional[BaseVectorStoreDriver.Entry]:
        """Load a vector entry from the Qdrant collection based on its ID.

        Parameters:
            vector_id (str): ID of the vector to load.
            namespace (str, optional): Optional namespace of the vector.

        Returns:
            Optional[BaseVectorStoreDriver.Entry]: Vector entry if found, else None.
        """
        results = self.client.retrieve(collection_name=self.collection_name, ids=[vector_id])
        if results:
            entry = results[0]
            if entry.payload is None:
                entry.payload = {}
            return BaseVectorStoreDriver.Entry(
                id=str(entry.id),
                vector=entry.vector if entry.vector is not None else [],  # pyright: ignore[reportArgumentType]
                meta={k: v for k, v in entry.payload.items() if k not in ["_score", "_tensor_facets"]},
            )
        return None

    def load_entries(self, *, namespace: Optional[str] = None, **kwargs) -> list[BaseVectorStoreDriver.Entry]:
        """Load vector entries from the Qdrant collection.

        Parameters:
            namespace: Optional namespace of the vectors.

        Returns:
            List of points.
        """
        results = self.client.retrieve(
            collection_name=self.collection_name,
            ids=kwargs.get("ids", []),
            with_payload=kwargs.get("with_payload", True),
            with_vectors=kwargs.get("with_vectors", True),
        )

        return [
            BaseVectorStoreDriver.Entry(
                id=str(entry.id),
                vector=entry.vector if kwargs.get("with_vectors", True) else [],  # pyright: ignore[reportArgumentType]
                meta={k: v for k, v in entry.payload.items() if k not in ["_score", "_tensor_facets"]},
            )
            for entry in results
            if entry.payload is not None
        ]

_client = field(default=None, kw_only=True, alias='client', metadata={'serializable': False}) class-attribute instance-attribute
api_key = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
collection_name = field(kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
content_payload_key = field(default=CONTENT_PAYLOAD_KEY, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
distance = field(default=DEFAULT_DISTANCE, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
force_disable_check_same_thread = field(default=False, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
grpc_port = field(default=6334, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
host = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
https = field(default=True, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
location = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
path = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
port = field(default=6333, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
prefer_grpc = field(default=False, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
prefix = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
timeout = field(default=5, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
url = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute
vector_name = field(default=None, kw_only=True, metadata={'serializable': True}) class-attribute instance-attribute

client()#

Source Code in griptape/drivers/vector/qdrant_vector_store_driver.py

@lazy_property()
def client(self) -> QdrantClient:
    return import_optional_dependency("qdrant_client").QdrantClient(
        location=self.location,
        url=self.url,
        host=self.host,
        path=self.path,
        port=self.port,
        prefer_grpc=self.prefer_grpc,
        grpc_port=self.grpc_port,
        api_key=self.api_key,
        https=self.https,
        prefix=self.prefix,
        force_disable_check_same_thread=self.force_disable_check_same_thread,
        timeout=self.timeout,
    )

delete_vector(vector_id)#

Delete a vector from the Qdrant collection based on its ID.

Parameters#

Name	Type	Description	Default
vector_id	str I id	ID of the vector to delete.<br/>	required

Source Code in griptape/drivers/vector/qdrant_vector_store_driver.py

def delete_vector(self, vector_id: str) -> None:
    """Delete a vector from the Qdrant collection based on its ID.

    Parameters:
        vector_id (str | id): ID of the vector to delete.
    """
    deletion_response = self.client.delete(
        collection_name=self.collection_name,
        points_selector=import_optional_dependency("qdrant_client.http.models").PointIdsList(points=[vector_id]),
    )
    if deletion_response.status == import_optional_dependency("qdrant_client.http.models").UpdateStatus.COMPLETED:
        logging.info("ID %s is successfully deleted", vector_id)

load_entries(*, namespace=None, **kwargs)#

Load vector entries from the Qdrant collection.

Parameters#

Name	Type	Description	Default
namespace	Optional[str]	Optional namespace of the vectors.<br/>	None

Returns#

Type	Description
<a href="../../../data/artifacts.mdx#list" title="List (list)"><code class="language-python">list[Entry]</code></a>	List of points.<br/>

Source Code in griptape/drivers/vector/qdrant_vector_store_driver.py

def load_entries(self, *, namespace: Optional[str] = None, **kwargs) -> list[BaseVectorStoreDriver.Entry]:
    """Load vector entries from the Qdrant collection.

    Parameters:
        namespace: Optional namespace of the vectors.

    Returns:
        List of points.
    """
    results = self.client.retrieve(
        collection_name=self.collection_name,
        ids=kwargs.get("ids", []),
        with_payload=kwargs.get("with_payload", True),
        with_vectors=kwargs.get("with_vectors", True),
    )

    return [
        BaseVectorStoreDriver.Entry(
            id=str(entry.id),
            vector=entry.vector if kwargs.get("with_vectors", True) else [],  # pyright: ignore[reportArgumentType]
            meta={k: v for k, v in entry.payload.items() if k not in ["_score", "_tensor_facets"]},
        )
        for entry in results
        if entry.payload is not None
    ]

load_entry(vector_id, *, namespace=None)#

Load a vector entry from the Qdrant collection based on its ID.

Parameters#

Name	Type	Description	Default
vector_id	str	ID of the vector to load.<br/>	required
namespace	str	Optional namespace of the vector.<br/>	None

Returns#

Type	Description
<a href="./#griptape.drivers.vector.BaseVectorStoreDriver.Entry" title="Entry (griptape.drivers.vector.BaseVectorStoreDriver.Entry)"><code class="language-python">Optional[Entry]</code></a>	Optional[BaseVectorStoreDriver.Entry]: Vector entry if found, else None.<br/>

Source Code in griptape/drivers/vector/qdrant_vector_store_driver.py

def load_entry(self, vector_id: str, *, namespace: Optional[str] = None) -> Optional[BaseVectorStoreDriver.Entry]:
    """Load a vector entry from the Qdrant collection based on its ID.

    Parameters:
        vector_id (str): ID of the vector to load.
        namespace (str, optional): Optional namespace of the vector.

    Returns:
        Optional[BaseVectorStoreDriver.Entry]: Vector entry if found, else None.
    """
    results = self.client.retrieve(collection_name=self.collection_name, ids=[vector_id])
    if results:
        entry = results[0]
        if entry.payload is None:
            entry.payload = {}
        return BaseVectorStoreDriver.Entry(
            id=str(entry.id),
            vector=entry.vector if entry.vector is not None else [],  # pyright: ignore[reportArgumentType]
            meta={k: v for k, v in entry.payload.items() if k not in ["_score", "_tensor_facets"]},
        )
    return None

query_vector(vector, *, count=None, namespace=None, include_vectors=False, **kwargs)#

Query the Qdrant collection based on a query vector.

Parameters#

Name	Type	Description	Default
vector	<a href="../../../data/artifacts.mdx#list" title="List (list)"><code class="language-python">list[float]</code></a>	Query vector.<br/>	required
count	Optional[int]	Optional number of results to return.<br/>	None
namespace	Optional[str]	Optional namespace of the vectors.<br/>	None
include_vectors	bool	Whether to include vectors in the results.<br/>	False

Returns#

Type	Description
<a href="../../../data/artifacts.mdx#list" title="List (list)"><code class="language-python">list[Entry]</code></a>	list[BaseVectorStoreDriver.Entry]: List of Entry objects.<br/>

Source Code in griptape/drivers/vector/qdrant_vector_store_driver.py

def query_vector(
    self,
    vector: list[float],
    *,
    count: Optional[int] = None,
    namespace: Optional[str] = None,
    include_vectors: bool = False,
    **kwargs,
) -> list[BaseVectorStoreDriver.Entry]:
    """Query the Qdrant collection based on a query vector.

    Parameters:
        vector (list[float]): Query vector.
        count (Optional[int]): Optional number of results to return.
        namespace (Optional[str]): Optional namespace of the vectors.
        include_vectors (bool): Whether to include vectors in the results.

    Returns:
        list[BaseVectorStoreDriver.Entry]: List of Entry objects.
    """
    # Create a search request
    request = {"collection_name": self.collection_name, "query_vector": vector, "limit": count}
    request = {k: v for k, v in request.items() if v is not None}
    results = self.client.search(**request)

    # Convert results to QueryResult objects
    return [
        BaseVectorStoreDriver.Entry(
            id=str(result.id),
            vector=result.vector if include_vectors else [],  # pyright: ignore[reportArgumentType]
            score=result.score,
            meta={k: v for k, v in result.payload.items() if k not in ["_score", "_tensor_facets"]},
        )
        for result in results
        if result.payload is not None
    ]

upsert_vector(vector, *, vector_id=None, namespace=None, meta=None, content=None, **kwargs)#

Upsert vectors into the Qdrant collection.

Parameters#

Name	Type	Description	Default
vector	<a href="../../../data/artifacts.mdx#list" title="List (list)"><code class="language-python">list[float]</code></a>	The vector to be upserted.<br/>	required
vector_id	Optional[str]	Optional vector ID.<br/>	None
namespace	Optional[str]	Optional namespace for the vector.<br/>	None
meta	Optional[dict]	Optional dictionary containing metadata.<br/>	None
content	Optional[str]	The text content to be included in the payload.<br/>	None

Returns#

Name	Type	Description
str	str	The ID of the upserted vector.<br/>

Source Code in griptape/drivers/vector/qdrant_vector_store_driver.py

def upsert_vector(
    self,
    vector: list[float],
    *,
    vector_id: Optional[str] = None,
    namespace: Optional[str] = None,
    meta: Optional[dict] = None,
    content: Optional[str] = None,
    **kwargs,
) -> str:
    """Upsert vectors into the Qdrant collection.

    Parameters:
        vector (list[float]): The vector to be upserted.
        vector_id (Optional[str]): Optional vector ID.
        namespace (Optional[str]): Optional namespace for the vector.
        meta (Optional[dict]): Optional dictionary containing metadata.
        content (Optional[str]): The text content to be included in the payload.

    Returns:
        str: The ID of the upserted vector.
    """
    if vector_id is None:
        vector_id = str(uuid.uuid5(uuid.NAMESPACE_DNS, str(vector)))

    if meta is None:
        meta = {}

    if content:
        meta[self.content_payload_key] = content

    points = import_optional_dependency("qdrant_client.http.models").Batch(
        ids=[vector_id],
        vectors=[vector],
        payloads=[meta] if meta else None,
    )

    self.client.upsert(collection_name=self.collection_name, points=points)
    return vector_id

qdrant

Contents

qdrant#

Attributes#

client()#

delete_vector(vector_id)#

Parameters#

load_entries(*, namespace=None, **kwargs)#

Parameters#

Returns#

load_entry(vector_id, *, namespace=None)#

Parameters#

Returns#

query_vector(vector, *, count=None, namespace=None, include_vectors=False, **kwargs)#

Parameters#

Returns#

upsert_vector(vector, *, vector_id=None, namespace=None, meta=None, content=None, **kwargs)#

Parameters#

Returns#