NATS Get

NATS Get

Certified

Fetch values from NATS Key/Value bucket

Reads values by key or specific revisions from a NATS Key/Value bucket. Values are JSON-deserialized into objects; missing keys are ignored.

yaml
type: io.kestra.plugin.nats.kv.Get

Gets a value from a NATS Key/Value bucket by keys.

yaml
id: nats_kv_get
namespace: company.team

tasks:
  - id: get
    type: io.kestra.plugin.nats.kv.Get
    url: nats://localhost:4222
    username: nats_user
    password: "{{ secret('NATS_PASSWORD') }}"
    bucketName: my_bucket
    keys:
      - key1
      - key2

Gets a value from a NATS Key/Value bucket by keys with revisions.

yaml
id: nats_kv_get
namespace: company.team

tasks:
  - id: get
    type: io.kestra.plugin.nats.kv.Get
    url: nats://localhost:4222
    username: nats_user
    password: "{{ secret('NATS_PASSWORD') }}"
    bucketName: my_bucket
    keyRevisions:
      key1: 1
      key2: 3
Properties
Min length1

Bucket name

Rendered bucket identifier to read from.

SubTypestring

Keys to fetch

Rendered list of keys used when no specific revisions are provided.

Min length1

URL to connect to NATS server

The format is (nats://)server_url: port. You can also provide a connection token like so: nats://token@server_url: port

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

Credentials files authentification

Keys with revisions

Optional map of key to revision; when set, supersedes the keys list.

Plaintext authentication password

Token authentification

Plaintext authentication username

Key/value results

Map of returned keys to deserialized JSON objects; missing keys are omitted.

More Plugins in this Category

Ashby
Ashby

Ashby plugin for Kestra

Data

1 tasks

1 blueprints

SAP HANA
SAP HANA

Tasks that query SAP HANA using the official SAP HANA JDBC driver (ngdbc.jar).

Data

3 tasks

3 blueprints