...
Code Block | ||
---|---|---|
| ||
def delete(self, condition=None)->MutationResult:
"""
Delete entities by primary keys.
Example: client.delete("_id in [1,10,100]")
:param condition: an expression indicates whether an entity should be deleted
:type condition: str
"""
def delete(self, collection_name, expr, partition_name=None, timeout=None, **kwargs):
"""
Delete entities with an expression condition.
And return results to show which primary key is deleted successfully
:param collection_name: Name of the collection to delete entities from
:type collection_name: str
:param expr: The query expression
:type expr: str
:param partition_name: Name of partitions that contain entities
:type partition_name: str
:param timeout: An optional duration of time in seconds to allow for the RPC. When timeout
is set to None, client waits until server response or error occur
:type timeout: float
:return: list of ids of the deleted vectors.
:rtype: list
:raises:
RpcError: If gRPC encounter an error
ParamError: If parameters are invalid
BaseException: If the return result from server is not ok
""" |
Design Details
In Milvus, Proxy maintains 2 Pulsar channels for each collection:
...