SQS Sink Node
Quick Reference
Queue URL
The full URL of the Amazon SQS queue to send messages to.
ex: https://sqs.us-east-1.amazonaws.com/123456789012/my-queue
AWS Region
The AWS region where your SQS queue is located.
ex: us-east-1
Encoding Type The format used to serialize each record as a message body.
Use Credentials AWS credentials used to authenticate with SQS. Leave blank to use the default credential chain.
Message Group ID Expression (FIFO queues only)
An expression evaluated against each record to produce the FIFO message group ID.
ex: $.tenant_id
Deduplication ID Expression (FIFO queues only)
An expression evaluated against each record to produce the message deduplication ID.
ex: $.event_id
Overview
The SQS Sink node sends records from your workflow as messages to an Amazon SQS queue. Each record in the pipeline becomes one SQS message. Messages are sent in batches for efficiency.
Both standard and FIFO queues are supported.
Configuration
| Field | Description | Required | Default |
|---|---|---|---|
| Queue URL | The full URL of the SQS queue. You can find this in the AWS SQS console under your queue's details. | Yes | — |
| AWS Region | The AWS region where your queue is hosted (e.g. us-east-1, eu-west-2). | Yes | — |
| Encoding Type | Defines how each record is serialized into the message body. Options: CSV, JSON Object, JSON Array, JSON Lines, String Line, Text, XML. More info here. | Yes | — |
| Use Credentials | Select or create an AWS Access Key credential for authentication. If left blank, the default AWS credential chain is used. | No | — |
| Message Group ID Expression | For FIFO queues only. Enter an expression that returns a string used as the MessageGroupId. Records with the same group ID are processed in order. | No | — |
| Deduplication ID Expression | For FIFO queues only. Enter an expression that returns a unique string per message to prevent duplicates. Only needed if content-based deduplication is not enabled on the queue. | No | — |
FIFO Queues
If your queue name ends in .fifo, it is a FIFO queue. You must set a Message Group ID Expression to control message ordering. Optionally set a Deduplication ID Expression if content-based deduplication is not enabled on the queue.
For standard queues, leave both FIFO fields empty.
Related Nodes
- SQS Source: Read messages from an SQS queue
- Kafka Sink: Send records to a Kafka topic