AMQP Publish
CertifiedPublish a message to an AMQP exchange
AMQP Publish
Publish a message to an AMQP exchange
Publishes one or more messages to the configured exchange with a routing key, serializing the payload according to serdeType.
type: io.kestra.plugin.amqp.PublishExamples
id: amqp_publish
namespace: company.team
tasks:
- id: publish
type: io.kestra.plugin.amqp.Publish
host: localhost
port: 5672
username: guest
password: "{{ secret('AMQP_PASSWORD') }}"
virtualHost: /my_vhost
exchange: kestramqp.exchange
from:
- data: value-1
headers:
testHeader: KestraTest
timestamp: '2023-01-09T08:46:33.103130753Z'
- data: value-2
timestamp: '2023-01-09T08:46:33.115456977Z'
appId: unit-kestra
Properties
exchange *string
The exchange to publish the message to
from *stringarray
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.
io.kestra.plugin.amqp.models.Message
Identifier of the publishing application
MIME content encoding of the message body
MIME content type of the message body
Correlation identifier used to match replies to requests
Deserialized message body
Delivery mode: 1 for non-persistent, 2 for persistent
durationTime-to-live before the message expires
Arbitrary application-specific message headers
Application message identifier
Message priority, 0 to 9
Queue name replies should be sent to
date-timeTime the message was created
Application-specific message type
Identifier of the user that published the message
host *string
Broker host
Hostname or IP of the RabbitMQ broker; required unless using the deprecated url.
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
{}1150password string
Password
Password for the connection; required when the broker enforces authentication.
port string
5672Broker port
TCP port for AMQP connections; defaults to 5672.
routingKey string
The routing key
serdeType string
STRINGSTRINGJSONSerializer/deserializer used for the message payload
username string
Username
Username for the connection; uses broker default (often guest) when not set.
virtualHost string
/Virtual host
Broker virtual host path; defaults to /.
Outputs
messagesCount integer
Number of messages published
Metrics
published.records counter
recordsNumber of messages published to the AMQP exchange
