NATS Request
CertifiedRequest/Reply over a NATS subject
NATS Request
Request/Reply over a NATS subject
Sends a single request message to the rendered subject and waits for a reply. Headers are preserved, non-string payloads are JSON-encoded, and the timeout defaults to 5 seconds.
type: io.kestra.plugin.nats.core.RequestExamples
Send a request to the subject and wait for the reply (using username/password authentication).
id: nats_request_reply
namespace: company.team
tasks:
- id: request
type: io.kestra.plugin.nats.core.Request
url: nats://localhost:4222
username: nats_user
password: "{{ secret('NATS_PASSWORD') }}"
subject: "greet.bob"
from:
headers:
someHeaderKey: someHeaderValue
data: "Hello from Kestra!"
requestTimeout: PT2S
Properties
from *RequiredNon-dynamicobject
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
kestrafor internal storage files,filefor host local files, andnsfilefor namespace files. - A JSON String that will then be serialized either as a single item or a list of items.
subject *Requiredstring
Subject to request
Rendered subject used for the request.
url *Requiredstring
1URL 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
creds string
Credentials files authentification
password string
Plaintext authentication password
pluginDefaultsRef Non-dynamicstring
Reference (ref) of the pluginDefaults to apply to this task.
requestTimeout string
PT5SRequest timeout
Duration to wait for a reply; defaults to PT5S.
token string
Token authentification
username string
Plaintext authentication username
Outputs
response string
Reply payload
UTF-8 reply string, or null when no responder or timeout.
