Produce Produce

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

Produce messages to a NATS subject on a NATS server.

Examples

Produce a single message to kestra.publish subject, using user password authentication.

yaml
id: "produce"
type: "io.kestra.plugin.nats.Produce"
url: nats://localhost:4222
username: nats_user
password: nats_passwd
subject: kestra.publish
from:
  headers:
    someHeaderKey: someHeaderValue
  data: Some message

Produce 2 messages to kestra.publish subject, using user password authentication.

yaml
id: "produce"
type: "io.kestra.plugin.nats.Produce"
url: nats://localhost:4222
username: nats_user
password: nats_passwd
subject: kestra.publish
from:
  - headers:
      someHeaderKey: someHeaderValue
    data: Some message
  - data: Another message

Produce messages (1 / row) from an internal storage file to kestra.publish subject, using user password authentication.

yaml
id: "produce"
type: "io.kestra.plugin.nats.Produce"
url: nats://localhost:4222
username: nats_user
password: nats_passwd
subject: kestra.publish
from: {{outputs.someTaskWithOutputFile.uri}}

Properties

from

  • Type:
    • string
    • array
    • object
  • Dynamic: βœ”οΈ
  • Required: βœ”οΈ

Source of message(s) to send

Can be an internal storage uri, a map or a list.with the following format: headers, data

subject

  • Type: string
  • Dynamic: βœ”οΈ
  • Required: βœ”οΈ
  • Min length: 1

Subject to produce message to

url

  • Type: string
  • Dynamic: βœ”οΈ
  • Required: βœ”οΈ
  • 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

password

  • Type: string
  • Dynamic: βœ”οΈ
  • Required: ❌

Plaintext authentication password

username

  • Type: string
  • Dynamic: βœ”οΈ
  • Required: ❌

Plaintext authentication username

Outputs

messagesCount

  • Type: integer
  • Dynamic: ❓
  • Required: ❌

Number of messages produced

Was this page helpful?