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 *object
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 *string
Subject to request
Rendered subject used for the request.
url *string
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
assets
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.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset 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.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150creds string
Credentials files authentification
password string
Plaintext authentication password
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.
