Qdrant Get

Qdrant Get

Certified

Retrieve points by ID from a Qdrant collection

Fetches points from a collection by a list of point IDs. Supports FETCH, FETCH_ONE, and STORE output modes.

yaml
type: io.kestra.plugin.qdrant.Get

Get points by ID and return inline rows

yaml
id: qdrant_get
namespace: company.team

tasks:
  - id: get_points
    type: io.kestra.plugin.qdrant.Get
    host: "{{ secret('QDRANT_HOST') }}"
    apiKey: "{{ secret('QDRANT_API_KEY') }}"
    tlsEnabled: true
    collectionName: docs
    ids: [1, 2]
    withPayload: true
    fetchType: FETCH
Properties

Collection name

The name of the collection to retrieve points from.

The host of the Qdrant instance

The hostname or IP address of the Qdrant gRPC endpoint.

Point IDs to retrieve

List of point IDs to retrieve (numbers or UUID strings).

API key

The API key for authentication with Qdrant.

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

id*string
Min length1
typestring
outputs

The assets produced as outputs.

id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*string
Min length1

Custom asset type

descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
DefaultSTORE
Possible Values
STOREFETCHFETCH_ONENONE

Select fetch behavior

Output mode for query results: FETCH returns all rows inline, FETCH_ONE returns the first row, and STORE writes all rows to Kestra storage as an ION file and returns the URI (default: STORE).

Default6334

The port of the Qdrant instance

The gRPC port of the Qdrant instance (default 6334).

Defaultfalse

Enable TLS

Whether to use TLS/SSL for secure gRPC connection.

Defaulttrue

Include payload

Whether to include point payload metadata in the result (default: true).

Defaultfalse

Include vectors

Whether to include vector embeddings in the result (default: false).

Map containing the first row of fetched data.

Only populated if using fetchType=FETCH_ONE.

List containing the fetched data.

Only populated if using fetchType=FETCH.

The number of fetched rows.

Formaturi

Kestra's internal storage URI of the stored data.

Only populated if using fetchType=STORE.