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)

1. Go to Settings → Community Nodes in your n8n instance
2. Click Install and enter: n8n-nodes-aws-sqs-extended
3. 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

1. Go to Settings → Credentials in n8n
2. Click Add Credential and select AWS
3. 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

{
  "queue": "https://sqs.us-east-1.amazonaws.com/123456789012/my-queue",
  "interval": 30,
  "unit": "seconds",
  "deleteMessages": false,
  "visibilityTimeout": 30,
  "maxMessages": 1,
  "waitTimeSeconds": 20
}

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.

Queue Input Options:

• Select from List: Auto-loads available queues from your AWS account
• Enter URL Manually: Fallback option if auto-loading fails

Key Parameters:

• Interval: 🔄 How often to check the queue (frequency of polling cycles)
• Wait Time Seconds: ⏱️ How long each call waits for messages (long polling efficiency)
• Delete Messages: Disabled by default (safe monitoring)
• Visibility Timeout: 30 seconds (message lock duration)
• Max Messages: 1 message per poll (adjustable 1-10)

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

Understanding Interval vs Wait Time Seconds

São dois parâmetros independentes que trabalham juntos:

🔄 Interval (Intervalo de Polling)

• Função: Frequência entre verificações da fila
• Exemplo: 30 segundos = nova verificação a cada 30 segundos
• Controla: Quantas vezes por minuto o trigger executa

⏱️ Wait Time Seconds (Long Polling)

• Função: Duração de cada chamada individual para o SQS
• Exemplo: 20 segundos = cada chamada espera até 20s por mensagens
• Controla: Eficiência de cada chamada específica

🎯 Exemplo Prático:

• Interval: 30s + Wait Time: 20s
• A cada 30 segundos → faz uma chamada que aguarda até 20s por mensagens
• Se mensagens chegarem em 5s → retorna em 5s e aguarda 30s para próxima verificação
• Se não houver mensagens → retorna em 20s e aguarda 30s para próxima verificação

Configuração para Long Polling:

Wait Time Seconds controla o long polling do AWS SQS:

• 0 segundos: Short polling – Retorna imediatamente (pode retornar vazio)
• 1-20 segundos: Long polling – Aguarda até X segundos por mensagens
• Recomendado: 20 segundos – Máxima eficiência e redução de custos

Benefícios do Long Polling:

• ✅ Reduz número de chamadas API (menor custo)
• ✅ Reduz latência na detecção de mensagens
• ✅ Evita "empty receives" desnecessários
• ✅ Melhor eficiência de recursos

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

• AWS SQS Documentation
• n8n Community Nodes
• n8n Documentation
• Community Forum

Support

Need help? Join our community:

• GitHub Issues
• n8n Community Forum

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.