Milvus Delete

Milvus Delete
Certified
Delete rows from a Milvus collection

Deletes rows by a list of primary key IDs, or by a scalar filter expression. Exactly one of ids or filter must be set.

yaml
type: io.kestra.plugin.milvus.Delete

Examples

Delete rows by primary key ID.

yaml
id: milvus_delete
namespace: company.team

tasks:
  - id: delete_rows
    type: io.kestra.plugin.milvus.Delete
    uri: http://localhost:19530
    token: "{{ secret('MILVUS_TOKEN') }}"
    collectionName: documents
    ids: [1, 2, 3]

Delete rows matching a scalar filter expression.

yaml
id: milvus_delete_by_filter
namespace: company.team

tasks:
  - id: delete_rows
    type: io.kestra.plugin.milvus.Delete
    uri: http://localhost:19530
    token: "{{ secret('MILVUS_TOKEN') }}"
    collectionName: documents
    filter: "city == 'Berlin'"

Properties

collectionName *string

Collection name

The name of the collection to delete rows from.

uri *string

Milvus server URI

The URI of the Milvus server or Zilliz Cloud endpoint, e.g. http://localhost: 19530.

assets

Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.

Definitions

io.kestra.core.models.assets.AssetsDeclaration

assetFailureBehaviorstring

Possible Values

IGNOREFAILWARN

Asset failure behavior

Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.

enableAutobooleanstring

Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.

inputsarray

The assets consumed as inputs.

io.kestra.core.models.assets.AssetIdentifier

id*string

Min length1

typestring

outputs

The assets produced as outputs.

io.kestra.plugin.ee.assets.Dataset

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.plugin.ee.assets.File

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.plugin.ee.assets.Table

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.plugin.ee.assets.VM

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.core.models.assets.External

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.core.models.assets.Custom

id*string

Min length1

Max length150

type*string

Min length1

Custom asset type

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

databaseName string

Database name

The Milvus database to operate against. Defaults to the server's default database when not set.

filter string

Scalar filter expression

A Milvus boolean filter expression; every row matching it is deleted. Mutually exclusive with ids. Unset by default.

ids array

Primary key IDs to delete

A list of primary key values to delete. Mutually exclusive with filter. Unset by default.

partitionName string

Partition name

Optional partition to scope the delete to. Defaults to every partition.

password string

Password

Password for a self-hosted Milvus instance with username/password authentication enabled.

token string

API token

The API token for authentication, typically used with Zilliz Cloud or a Milvus instance with token-based auth enabled.

username string

Username

Username for a self-hosted Milvus instance with username/password authentication enabled. Leave unset if using a token or an unauthenticated instance.

Outputs

deletedCount integer

Default0

Number of deleted rows