Description
n8n-nodes-aws-sqs-extended
🔧 Extended AWS SQS operations for n8n – Delete Messages, Queue Monitoring & Batch Operations
Extended AWS SQS functionality for n8n that complements the native AWS SQS node with additional operations like Delete Messages and Queue Monitoring.
Features
- Delete Messages: Remove messages from SQS queues after processing
- Queue Monitoring: Advanced trigger with customizable polling intervals
- Message Receipts: Handle message receipts and acknowledgments
- Production Ready: Optimized for production workloads
- Native Integration: Works alongside n8n's built-in AWS SQS Send node
Installation
Via n8n Community Nodes (Recommended)
- Go to Settings → Community Nodes in your n8n instance
- Click Install and enter:
n8n-nodes-aws-sqs-extended - Click Install and wait for the installation to complete
Via npm
npm install n8n-nodes-aws-sqs-extended
Requirements
- n8n version 0.198.0 or higher
- Node.js 16.0.0 or higher
- AWS account with SQS access
Quick Start
AWS Credentials Setup
- Go to Settings → Credentials in n8n
- Click Add Credential and select AWS
- Configure your AWS credentials:
- Access Key ID: Your AWS access key
- Secret Access Key: Your AWS secret key
- Region: Your AWS region (e.g.,
us-east-1)
Basic Usage
Deleting Messages
{
"queueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/my-queue",
"receiptHandle": "AQEBwJnKyrHigUMZj6rYigCgxlaS3SLy0a..."
}
Monitoring Queues
{
"queueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/my-queue",
"pollingInterval": 30,
"maxMessages": 10,
"deleteAfterProcessing": true
}
Available Nodes
AWS SQS Delete
Delete messages from SQS queues after processing.
Key Parameters:
- Queue URL (full SQS queue URL)
- Receipt Handle (from received message)
AWS SQS Trigger
Monitor SQS queues and trigger workflows when messages arrive.
Key Parameters:
- Queue URL for monitoring
- Polling interval (configurable)
- Maximum messages per poll
- Auto-delete after processing option
Use Cases
Message Processing Workflow
{
"nodes": [
{
"name": "Receive Message",
"type": "n8n-nodes-base.awsSqs"
},
{
"name": "Process Message",
"type": "n8n-nodes-base.function"
},
{
"name": "Delete Message",
"type": "n8n-nodes-aws-sqs-extended.awsSqsExtendedDelete",
"parameters": {
"queueUrl": "{{$node['Receive Message'].json.queueUrl}}",
"receiptHandle": "{{$node['Receive Message'].json.receiptHandle}}"
}
}
]
}
AWS IAM Permissions
Your AWS user needs the following permissions:
{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": [
"sqs:DeleteMessage",
"sqs:ReceiveMessage",
"sqs:ListQueues",
"sqs:GetQueueAttributes"
],
"Resource": "arn:aws:sqs:*:*:*"
}
]
}
Configuration
Error Handling
All nodes support n8n's standard error handling:
- Enable "Continue on Fail" to handle errors gracefully
- Use error outputs to build robust workflows
- Monitor execution logs for troubleshooting
Development
Build from Source
# Clone the repository
git clone https://github.com/adejaimejr/n8n-nodes-aws-sqs-extended.git
# Install dependencies
npm install
# Build the project
npm run build
# Run tests
npm test
Project Structure
n8n-nodes-aws-sqs-extended/
├── nodes/
│ ├── AwsSqsDelete/
│ └── AwsSqsTrigger/
├── dist/
├── package.json
└── README.md
Resources
Support
Need help? Join our community:
FAQ
Q: Can I use this with FIFO queues?
A: Yes, all nodes work with both Standard and FIFO SQS queues.
Q: How does this differ from the native AWS SQS node?
A: This package provides extended functionality (Delete, Monitor) that complements the native Send Message functionality.
Q: What happens if a message operation fails?
A: The node will return an error, but you can enable "Continue on Fail" to handle this gracefully.
Contributing
We welcome contributions! Please see our Contributing Guide for details.
Found a bug 🐛 or have a feature idea? Create an issue.
License
This project is licensed under the MIT License – see the LICENSE file for details.
About
Created by Adejaime Junior for the n8n community.
