n8n-nodes-redis-mess

🚀 n8n Redis Message Processor - Advanced message handling and aggregation for Redis workflows

Professional Redis message processing solution for n8n workflows with intelligent message aggregation and real-time processing capabilities.

📦 Installation

npm install n8n-nodes-redis-mess

After installation, restart n8n to load the new nodes.

⚡ Key Features

• ✅ Smart Message Aggregation: Automatically collect and batch fragmented messages
• ✅ Dual Processing Strategies: Smart Wait and Immediate on Complete
• ✅ Real-time Processing: True waiting mechanism without external schedulers
• ✅ Redis Support: Compatible with local Redis and cloud services (Upstash, Redis Cloud)
• ✅ Connection Testing: Dedicated Redis connection testing node
• ✅ Flexible Key Management: Support for user ID, group ID, or custom combinations

🎯 Problem Solved

Before using n8n-nodes-redis-mess:

Trigger 1: "Hello"     → Process immediately → Response "?"
Trigger 2: "world"     → Process immediately → Response "?"
Trigger 3: "there!"    → Process immediately → Response "?"

After using n8n-nodes-redis-mess:

Trigger 1: "Hello"     → Store & wait
Trigger 2: "world"     → Store & wait
Trigger 3: "there!"    → Store & wait 5s → Aggregate: "Hello world there!" → Response

🚀 Quick Start

Step 1: Setup Redis

Option A - Upstash Redis (Recommended for beginners):

1. Sign up at upstash.com (free tier available)
2. Create a new Redis database
3. Copy connection string format: redis://default:xxx@xxx.upstash.io:6379

Option B - Local Redis:

# Docker
docker run -d -p 6379:6379 redis:alpine

# macOS
brew install redis && redis-server

# Ubuntu
sudo apt install redis-server

Bước 2: Tạo Credentials

1. Trong n8n, vào Credentials → New → Redis API
2. Chọn connection type:
   • Connection String: Paste connection string từ Upstash
   • Host & Port: Nhập localhost:6379 cho Redis local

Bước 3: Test Connection

1. Thêm node Redis Connection Test
2. Chọn credentials vừa tạo
3. Chọn Complete Test và execute
4. Xem kết quả: ✅ Connection successful!

Bước 4: Basic Workflow

[Manual Trigger] → [Redis Message Aggregator] → [Set] (để xem kết quả)

Cấu hình Redis Message Aggregator:

• Key: user123 (hoặc bất kỳ string nào)
• Message Content: Xin chào!
• Wait Time: 5 (giây)
• Strategy: Smart Wait

📚 Chi tiết Nodes

Redis Message Aggregator

Node chính để gom tin nhắn với 2 chiến lược đơn giản:

🧠 Smart Wait (Khuyến nghị)

Chờ thông minh - chỉ output khi chắc chắn không có tin nhắn mới.

Khi nào dùng: Chatbot, webhook nhận tin nhắn liên tiếp

Ví dụ:

// Input: 3 tin nhắn với key "user123"
// - "Xin" (10:00:00)
// - "chào" (10:00:03)
// - "bạn!" (10:00:06)

// Output sau 5 giây không có tin mới (10:00:11):
{
  "status": "messages_aggregated",
  "key": "user123",
  "aggregatedMessage": "Xin chào bạn!",
  "messageCount": 3,
  "trigger": "smart_timeout"
}

🎯 Immediate on Complete

Trả về ngay khi phát hiện tin nhắn kết thúc bằng từ được định nghĩa.

Khi nào dùng: Khi muốn response nhanh với những từ kết thúc cụ thể

Cấu hình:

• End Words: xong, rồi, nhé, ok, done (ngăn cách bởi dấu phẩy)

Ví dụ:

// End Words: "xong, rồi, nhé"
"Xin chào"     → Chưa hoàn chỉnh → Lưu & chờ
"bạn nhé"      → Hoàn chỉnh (kết thúc bằng "nhé") → Output ngay: "Xin chào bạn nhé"

Redis Connection Test

Node để test và troubleshoot Redis connection.

Test Types:

• Basic Connection: Chỉ test PING
• Read/Write Test: Test SET/GET/DEL
• Server Info: Lấy thông tin Redis server
• Complete Test: Chạy tất cả tests above

🔧 Cấu hình nâng cao

Key Patterns

Sử dụng key linh hoạt cho các tình huống khác nhau:

// Chat 1-1
key = 'user_123';

// Group chat
key = 'group_456';

// User trong group cụ thể
key = 'user_123_group_456';

// Session based
key = 'session_abc123';

// Multi-tenant
key = 'tenant_A_user_123';

Redis Options

Tùy chỉnh connection cho performance tốt hơn:

• Connection Timeout: 5000ms (mặc định)
• Command Timeout: 3000ms (mặc định)
• Max Retries: 1 (mặc định)

Strategy Selection Guide

Strategy	Use Case	Output Timing	Best For
Smart Wait	Chatbot responses	Sau X giây no new message	Real-time chat
Immediate on Complete	Quick responses	Khi detect end words	Fast interactions

💡 Workflow Examples

Example 1: Chatbot với Smart Wait

[Webhook] → [Redis Message Aggregator] → [OpenAI/ChatGPT] → [Response]

Cấu hình:

• Key: {{$json.userId}} (từ webhook payload)
• Message: {{$json.message}}
• Strategy: Smart Wait
• Wait Time: 3 giây

Example 2: Quick Response với End Words

[Webhook] → [Redis Message Aggregator] → [Filter: Complete Messages] → [Processing]

Cấu hình:

• Key: {{$json.groupId}}_{{$json.userId}}
• Strategy: Immediate on Complete
• End Words: xong, rồi, nhé, ok, done

🔍 Troubleshooting

❌ "Connection failed"

1. Dùng Redis Connection Test node để kiểm tra
2. Verify credentials và connection string
3. Check firewall/network access

❌ "Key và Message Content là bắt buộc"

• Đảm bảo cả 2 fields đều có giá trị
• Kiểm tra expressions nếu dùng dynamic values

❌ Không có output

• Cả 2 strategies đều output khi có kết quả
• Check Redis có tin nhắn không bằng Redis Connection Test
• Verify end words có match không (cho Immediate strategy)

❌ Tin nhắn không gom được

• Verify cùng Key được sử dụng
• Check Wait Time có phù hợp không
• Ensure Redis connection stable

📝 API Reference

Input Parameters

Parameter	Type	Required	Description
key	string	✅	Key để gom tin nhắn
messageContent	string	✅	Nội dung tin nhắn
waitTime	number	✅	Thời gian chờ (giây)
strategy	string	✅	Chiến lược xử lý
endWords	string	❌	Từ kết thúc ngăn cách bởi dấu phẩy (chỉ cho Immediate strategy)

Output (khi status = 'messages_aggregated')

{
  "status": "messages_aggregated",
  "key": "user123",
  "aggregatedMessage": "Xin chào bạn!",
  "messageCount": 3,
  "originalMessages": [
    {"content": "Xin", "timestamp": 1234567890},
    {"content": "chào", "timestamp": 1234567893},
    {"content": "bạn!", "timestamp": 1234567896}
  ],
  "trigger": "smart_timeout",
  "aggregatedAt": "2024-01-01T10:00:11.000Z"
}

🛡️ Security & Performance

• ✅ TTL automatic: Tin nhắn tự động expire
• ✅ Lock mechanism: Tránh race conditions
• ✅ Connection pooling: Efficient Redis usage
• ✅ Error handling: Comprehensive error messages

🤝 Support

• 📖 Documentation: GitHub Wiki
• 🐛 Issues: GitHub Issues
• 💬 Community: n8n Community
• 📧 Contact: support@redismess.dev

📄 License

MIT © 2024 Redis Message Team

---

⭐ Nếu package này hữu ích, đừng quên star trên GitHub!