PluginsPlugin Nats

Request​Request

Send a request to a NATS subject and wait for a reply.

yaml
type: "io.kestra.plugin.nats.Request"

Send a request to the subject and wait for the reply (using username/password authentication).

yaml
id: nats_request_reply
namespace: company.team

tasks:
  - id: request
    type: io.kestra.plugin.nats.Request
    url: nats://localhost:4222
    username: nats_user
    password: nats_password
    subject: "greet.bob"
    from:
      headers:
        someHeaderKey: someHeaderValue
      data: "Hello from Kestra!"
    requestTimeout: 2000
Properties

Structured data items, either as a map, a list of map, a URI, or a JSON string.

Structured data items can be defined in the following ways:

  • A single item as a map (a document).
  • A list of items as a list of maps (a list of documents).
  • A URI, supported schemes are kestra for internal storage files, file for host local files, and nsfile for namespace files.
  • A JSON String that will then be serialized either as a single item or a list of items.

Subject to send the request to

Min length 1

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

Plaintext authentication password

Default PT5S
Format duration

Timeout in milliseconds to wait for a response.

Defaults to 5000 ms.

Token authentification

Plaintext authentication username

Response received from the request, or null if timed out/no responders.