SQS Source Node
Quick Reference
Queue URL
The full URL of the Amazon SQS queue to read from.
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 of the messages in the queue.
Use Credentials AWS credentials used to authenticate with SQS. Leave blank to use the default credential chain.
Messages Per Batch
Number of messages to retrieve per request (max 10). Default: 10.
Wait Time (seconds)
How long to wait for messages to arrive before returning an empty response (long polling). Max 20 seconds. Default: 20.
Visibility Timeout (seconds)
How long a received message is hidden from other consumers while being processed. Default: 30.
Overview
The SQS Source node allows your workflow to continuously read messages from an Amazon SQS queue. It acts as the starting point of your pipeline, polling the queue for new messages and passing each one downstream for processing. Messages are automatically removed from the queue after they are successfully processed.
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 message body should be interpreted. 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 (environment variables, instance profile, etc.). | No | — |
| Messages Per Batch | How many messages to fetch in each request. Maximum allowed by SQS is 10. | No | 10 |
| Wait Time (seconds) | Seconds to wait for new messages before returning. Setting this above 0 enables long polling, which reduces empty responses and costs. Maximum is 20 seconds. | No | 20 |
| Visibility Timeout (seconds) | Seconds that a received message stays hidden from other consumers while your workflow processes it. If processing takes longer than this, the message may be received again. | No | 30 |
Related Nodes
- SQS Sink: Send processed records to an SQS queue
- Kafka Source: Consume streaming data from Kafka