Consume
yaml
type: "io.kestra.plugin.amqp.Consume"
Consume messages from an AMQP queue.
Required a maxDuration or a maxRecords.
Examples
yaml
id: "consume"
type: "io.kestra.plugin.amqp.Consume"
url: amqp://guest:guest@localhost:5672/my_vhost
queue: kestramqp.queue
maxRecords: 1000
Properties
consumerTag
- Type: string
- Dynamic: ❓
- Required: ✔️
- Default:
Kestra
A client-generated consumer tag to establish context.
queue
- Type: string
- Dynamic: ✔️
- Required: ✔️
The queue to pull messages from.
serdeType
- Type: string
- Dynamic: ❓
- Required: ✔️
- Default:
STRING
- Possible Values:
STRING
JSON
Serializer / Deserializer used for the message
url
- Type: string
- Dynamic: ✔️
- Required: ✔️
The connection string
maxDuration
- Type: string
- Dynamic: ❓
- Required: ❌
- Format:
duration
The max duration waiting for new rows.
It's not an hard limit and is evaluated every second.
maxRecords
- Type: integer
- Dynamic: ❓
- Required: ❌
The max number of rows to fetch before stopping.
It's not an hard limit and is evaluated every second.
Outputs
count
- Type: integer
Number of row consumed.
uri
- Type: string
File URI containing consumed message.