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

Credentials files authentification

Keys with revisions

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

Plaintext authentication password

Reference (ref) of the pluginDefaults to apply to this task.

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

Liquibase
Liquibase

Tasks that run Liquibase change management commands.

Data

2 tasks

6 blueprints

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

6 tasks

25 blueprints