n8n-nodes-gomtin

🔥 Giải pháp tối ưu cho việc tập hợp và xử lý tin nhắn phân mảnh trong n8n

Một custom node mạnh mẽ giúp bạn thu thập, tổng hợp và xử lý các tin nhắn rời rạc từ nhiều nguồn khác nhau một cách thông minh và hiệu quả.

📦 Cài đặt

Thông qua n8n Community Nodes (Được khuyến nghị)

1. Truy cập Settings > Community Nodes trong n8n
2. Nhấn Install
3. Nhập n8n-nodes-gomtin
4. Xác nhận và cài đặt

Cài đặt thủ công

npm install n8n-nodes-gomtin

Khởi động lại n8n để tải các node mới.

🌟 Điểm nổi bật

• 🎯 Tập hợp tin nhắn thông minh: Tự động gộp các tin nhắn phân tán thành một khối hoàn chỉnh
• 🚀 Hai chế độ hoạt động: Chờ thông minh (Smart Wait) và Hoàn thành tức thì (Immediate Complete)
• ⚡ Xử lý thời gian thực: Node thực sự chờ đợi, không cần bộ lập lịch bên ngoài
• 🔗 Tích hợp Redis toàn diện: Hỗ trợ Redis local, cloud và các dịch vụ như Upstash
• 🔧 Kiểm tra kết nối: Node chuyên dụng để test và debug Redis
• 🎨 Khóa linh hoạt: Hỗ trợ user ID, session ID, hoặc bất kỳ pattern nào

🎯 Giải quyết vấn đề gì?

Tình huống thường gặp:

Message 1: "Tôi muốn"     → Xử lý riêng lẻ → Phản hồi không đầy đủ
Message 2: "đặt hàng"     → Xử lý riêng lẻ → Phản hồi không đầy đủ  
Message 3: "pizza size L" → Xử lý riêng lẻ → Phản hồi không đầy đủ

Với n8n-nodes-gomtin:

Message 1: "Tôi muốn"     → Lưu trữ & chờ đợi
Message 2: "đặt hàng"     → Lưu trữ & chờ đợi
Message 3: "pizza size L" → Tập hợp hoàn chỉnh → "Tôi muốn đặt hàng pizza size L"

🚀 Hướng dẫn nhanh

Bước 1: Thiết lập Redis

Lựa chọn A - Upstash Redis (Dành cho người mới bắt đầu):

1. Đăng ký tại upstash.com (có gói miễn phí)
2. Tạo database Redis mới
3. Sao chép connection string: redis://default:[email protected]:6379

Lựa chọn B - Redis cục bộ:

# Sử dụng Docker
docker run -d -p 6379:6379 redis:alpine

# Trên macOS
brew install redis && redis-server

# Trên Ubuntu
sudo apt install redis-server

Bước 2: Cấu hình Credentials

1. Trong n8n, vào Credentials → New → Redis API
2. Chọn phương thức kết nối:
   • Connection String: Dán connection string từ Upstash
   • Host & Port: Nhập localhost:6379 cho Redis local

Bước 3: Kiểm tra kết nối

1. Thêm node Redis Connection Test
2. Chọn credentials đã tạo
3. Chọn Complete Test và thực thi
4. Kiểm tra kết quả: ✅ Kết nối thành công!

Bước 4: Workflow cơ bản

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

Cấu hình Redis Message Aggregator:

• Key: session_001 (hoặc bất kỳ identifier nào)
• Message Content: Xin chào từ n8n!
• Wait Time: 3 (giây)
• Strategy: Smart Wait

📖 Chi tiết các Node

Redis Message Aggregator

Node chính để tập hợp tin nhắn với hai chiến lược xử lý:

🧠 Smart Wait (Chờ thông minh)

Chờ đợi một khoảng thời gian nhất định và chỉ xuất kết quả khi không có tin nhắn mới.

Phù hợp cho: Chatbot, webhook nhận tin nhắn liên tục, xử lý batch

Ví dụ thực tế:

// Đầu vào: 3 tin nhắn với key "order_session_123"
// - "Tôi cần" (14:30:00)
// - "đặt bàn" (14:30:02)
// - "cho 4 người" (14:30:05)

// Đầu ra sau 3 giây không có tin mới (14:30:08):
{
  "status": "messages_aggregated",
  "key": "order_session_123",
  "aggregatedMessage": "Tôi cần đặt bàn cho 4 người",
  "messageCount": 3,
  "trigger": "smart_timeout",
  "processingTime": "3.2s"
}

🎯 Immediate on Complete (Hoàn thành tức thì)

Xuất kết quả ngay lập tức khi phát hiện tin nhắn kết thúc bằng từ khóa định trước.

Phù hợp cho: Phản hồi nhanh, xử lý lệnh, interactive forms

Cấu hình:

• End Words: hoàn thành, xong, ok, done, finish (phân cách bằng dấu phẩy)

Ví dụ thực tế:

// End Words: "hoàn thành, xong, ok"
"Đặt pizza"        → Chưa hoàn chỉnh → Lưu & chờ
"size M xong"      → Hoàn chỉnh → Xuất ngay: "Đặt pizza size M xong"

Redis Connection Test

Node chuyên dụng để kiểm tra và troubleshoot kết nối Redis.

Các loại test:

• Basic Connection: Chỉ kiểm tra PING command
• Read/Write Test: Kiểm tra SET/GET/DEL operations
• Server Info: Lấy thông tin chi tiết Redis server
• Complete Test: Thực hiện tất cả các test trên

🔧 Cấu hình nâng cao

Patterns cho Key

Sử dụng key một cách linh hoạt cho nhiều tình huống:

// Chat cá nhân
key = 'user_12345';

// Chat nhóm
key = 'group_67890';

// User trong nhóm cụ thể
key = 'user_12345_in_group_67890';

// Theo session
key = 'session_abc123def';

// Multi-tenant application
key = 'tenant_companyA_user_12345';

// Theo thời gian
key = 'daily_summary_2024_01_15';

Tùy chỉnh Redis Connection

Điều chỉnh hiệu suất kết nối:

• Connection Timeout: 5000ms (mặc định)
• Command Timeout: 3000ms (mặc định)
• Max Retries: 1 (mặc định)
• Lazy Connect: true (kết nối khi cần)

Hướng dẫn chọn Strategy

| Strategy | Tình huống sử dụng | Thời điểm xuất kết quả | Tốt nhất cho | | --------------------- | --------------------- | ----------------------------- | ------------------------- | | Smart Wait | Xử lý batch, chatbot | Sau X giây không có tin mới | Tập hợp tin nhắn dài | | Immediate on Complete | Phản hồi tức thì | Khi phát hiện từ kết thúc | Lệnh nhanh, forms |

💡 Ví dụ Workflow thực tế

Ví dụ 1: Chatbot hỗ trợ khách hàng

[Webhook] → [Redis Message Aggregator] → [OpenAI GPT] → [Send Response]

Cấu hình:

• Key: customer_{{$json.userId}}
• Message: {{$json.userMessage}}
• Strategy: Smart Wait
• Wait Time: 4 giây

Ví dụ 2: Form đặt hàng nhanh

[Webhook] → [Redis Message Aggregator] → [Switch] → [Process Order]

Cấu hình:

• Key: order_{{$json.sessionId}}
• Strategy: Immediate on Complete
• End Words: xác nhận, đặt hàng, ok, done

Ví dụ 3: Tổng hợp báo cáo hàng ngày

[Schedule] → [Redis Message Aggregator] → [Generate Report] → [Email]

Cấu hình:

• Key: daily_report_{{$now.format('YYYY_MM_DD')}}
• Strategy: Smart Wait
• Wait Time: 60 giây

🔍 Xử lý sự cố

❌ "Kết nối thất bại"

1. Sử dụng Redis Connection Test để kiểm tra
2. Xác minh credentials và connection string
3. Kiểm tra firewall và quyền truy cập mạng
4. Thử kết nối từ máy local trước

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

• Đảm bảo cả hai trường đều có giá trị
• Kiểm tra expressions nếu sử dụng dynamic values
• Verify data từ node trước có đúng format không

❌ Không có output

• Cả hai strategies đều sẽ có output khi có kết quả
• Kiểm tra Redis có dữ liệu bằng Connection Test
• Verify end words có khớp không (cho Immediate strategy)
• Kiểm tra Wait Time có phù hợp không

❌ Tin nhắn không được tập hợp

• Xác minh cùng Key được sử dụng cho tất cả tin nhắn
• Kiểm tra Wait Time có đủ dài không
• Đảm bảo Redis connection ổn định
• Kiểm tra TTL settings

📝 Tham khảo API

Tham số đầu vào

| Tham số | Kiểu | Bắt buộc | Mô tả | | -------------- | ------ | -------- | --------------------------------------------------------------- | | key | string | ✅ | Khóa để nhóm 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 phân cách bằng dấu phẩy (chỉ cho Immediate strategy) |

Đầu ra (khi status = 'messages_aggregated')

{
  "status": "messages_aggregated",
  "key": "customer_12345",
  "aggregatedMessage": "Tôi muốn đặt pizza size L với extra cheese",
  "messageCount": 4,
  "originalMessages": [
    {"content": "Tôi muốn", "timestamp": 1704067200000},
    {"content": "đặt pizza", "timestamp": 1704067202000},
    {"content": "size L", "timestamp": 1704067204000},
    {"content": "với extra cheese", "timestamp": 1704067206000}
  ],
  "trigger": "smart_timeout",
  "aggregatedAt": "2024-01-01T10:00:11.000Z",
  "processingTime": "3.2s"
}

🛡️ Bảo mật & Hiệu suất

• ✅ TTL tự động: Tin nhắn tự động hết hạn để tiết kiệm bộ nhớ
• ✅ Cơ chế khóa: Tránh race conditions khi xử lý đồng thời
• ✅ Connection pooling: Sử dụng Redis hiệu quả
• ✅ Error handling: Thông báo lỗi chi tiết và hữu ích
• ✅ Data validation: Kiểm tra dữ liệu đầu vào nghiêm ngặt

🤝 Hỗ trợ & Cộng đồng

• 📖 Tài liệu: GitHub Repository
• 🐛 Báo lỗi: GitHub Issues
• 💬 Thảo luận: n8n Community Forum
• 📧 Liên hệ: [email protected]

📄 Giấy phép

MIT © Hoang Thanh Nga

⭐ Nếu package này hữu ích cho bạn, hãy star trên GitHub để ủng hộ!