AWS SQS icon

AWS SQS

Consume and send messages to AWS SQS
Join our community

Actions5

Overview

This node allows sending messages to an AWS SQS (Simple Queue Service) queue. It is useful for integrating workflows with AWS SQS to enqueue messages for asynchronous processing or communication between distributed systems. For example, it can be used to send task requests, notifications, or data payloads to an SQS queue for later processing by other services or applications.

Use Case Examples

  1. Sending a JSON payload as a message to an SQS queue for processing by a backend service.
  2. Delaying a message delivery by specifying a delay time in seconds.
  3. Adding custom message attributes to provide metadata or additional context for the message.

Properties

Name Meaning
Queue Name or URL The name of the SQS queue or the full queue URL where the message will be sent.
Message Body The content of the message to be sent to the SQS queue.
Delay Seconds The amount of time in seconds to delay the message delivery (0 to 900 seconds).
Message Attributes Optional custom attributes to attach to the message, each with a name, type (String, Number, Binary), and value.

Output

JSON

  • messageId - The unique identifier assigned to the sent message by AWS SQS.
  • md5OfBody - The MD5 hash of the message body, used to verify message integrity.
  • sequenceNumber - The sequence number of the message, applicable for FIFO queues.

Dependencies

  • AWS SDK for JavaScript (v3) - specifically @aws-sdk/client-sqs

Troubleshooting

  • Ensure the provided queue name or URL is correct and the queue exists in the specified AWS region and account. An error 'SQS queue does not exist' indicates a mismatch.
  • Verify AWS credentials (access key, secret key, and optional session token) are correctly configured and have permissions to send messages to the target queue.
  • DelaySeconds must be between 0 and 900 seconds; values outside this range will cause errors.
  • Message attributes must be correctly formatted with valid names, types, and values to avoid message rejection.

Links

  • AWS SQS SendMessage API - Official AWS documentation for the SendMessage API used to send messages to an SQS queue.

Discussion