Sửa lỗi Redis Streams 'NOGROUP No such consumer group' trong XREADGROUP

TL;DR: Cách khắc phục nhanh

Nếu bạn gặp lỗi NOGROUP, điều đó có nghĩa là bạn đang cố gắng đọc từ một consumer group chưa được tạo. Redis không tự động tạo các consumer group khi bạn gọi XREADGROUP.

Chạy lệnh sau trong Redis CLI của bạn để tạo group và stream cùng một lúc:

XGROUP CREATE mystream mygroup $ MKSTREAM

• mystream: Tên stream của bạn.
• mygroup: Tên consumer group bạn muốn tạo.
• $: Yêu cầu Redis chỉ tiêu thụ các tin nhắn mới đến từ thời điểm này trở đi (sử dụng 0 để đọc từ đầu).
• MKSTREAM: Một flag tùy chọn nhưng rất được khuyến khích, giúp tạo stream nếu nó chưa tồn tại.

Nguyên nhân gốc rễ

Khi làm việc với Redis Streams, có hai cách để đọc dữ liệu: XREAD (đơn giản, không trạng thái) và XREADGROUP (có quản lý, có trạng thái). Khác với XREAD, XREADGROUP yêu cầu một Consumer Group để theo dõi tin nhắn nào đã được chuyển đến và xác nhận.

Lỗi NOGROUP No such consumer group 'mygroup' for key name 'mystream' xảy ra vì Redis yêu cầu bạn phải định nghĩa rõ ràng một group trước khi bất kỳ consumer nào cố gắng tham gia vào đó. Nếu mã ứng dụng của bạn cố gắng thực thi XREADGROUP trước khi lệnh XGROUP CREATE chạy thành công, thao tác sẽ thất bại.

Các tình huống phổ biến dẫn đến lỗi này:

• Stream đã tồn tại, nhưng group chưa bao giờ được tạo.
• Stream đã bị xóa hoặc hết hạn, kéo theo dữ liệu metadata của consumer group bị mất.
• Script triển khai ứng dụng của bạn đã bỏ qua bước khởi tạo.
• Bạn đang kết nối tới một cơ sở dữ liệu Redis mới (ví dụ: sau khi di chuyển hoặc flush) nơi group không tồn tại.

Các phương pháp khắc phục từng bước

1. Tạo thủ công qua Redis CLI

Nếu bạn đang debug cục bộ hoặc trong môi trường staging, cách nhanh nhất là tạo group thủ công. Kết nối tới instance của bạn và chạy:

# Tạo group 'mygroup' cho stream 'mystream'
# Ký tự '$' nghĩa là bắt đầu đọc từ cuối stream
XGROUP CREATE mystream mygroup $

Nếu bản thân stream chưa tồn tại, lệnh trên sẽ thất bại với lỗi ERR no such key. Để xử lý cả hai cùng lúc, hãy sử dụng lệnh con MKSTREAM được giới thiệu từ Redis 6.2:

XGROUP CREATE mystream mygroup $ MKSTREAM

2. Triển khai bằng mã nguồn (Thiết lập Idempotent)

Trong môi trường production, bạn nên xử lý việc này bên trong mã nguồn ứng dụng. Vì nhiều worker có thể khởi động cùng lúc, bạn cần một cách để đảm bảo group tồn tại mà không làm ứng dụng bị crash nếu group đó đã được tạo bởi một worker khác.

Dưới đây là một pattern phổ biến sử dụng khối try-catch (ví dụ Python/redis-py):

import redis

r = redis.Redis(host='localhost', port=6379, decode_responses=True)
stream_name = "mystream"
group_name = "mygroup"

try:
    # Thử tạo group
    r.xgroup_create(stream_name, group_name, id="$", mkstream=True)
except redis.exceptions.ResponseError as e:
    if "BUSYGROUP" in str(e):
        print("Group đã tồn tại, bỏ qua bước tạo.")
    else:
        raise e

# Bây giờ đã an toàn để đọc
messages = r.xreadgroup(group_name, "consumer-1", {stream_name: ">"})

Bằng cách bắt lỗi BUSYGROUP, mã của bạn trở nên idempotent, nghĩa là nó có thể chạy nhiều lần một cách an toàn.

Xác minh cách khắc phục

Để xác nhận rằng consumer group của bạn đã được thiết lập chính xác, hãy sử dụng lệnh XINFO. Đây là tiêu chuẩn vàng để kiểm tra metadata của stream.

Kiểm tra tất cả các group của một stream cụ thể:

XINFO GROUPS mystream

Bạn sẽ thấy kết quả tương tự như sau:

1) 1) "name"
   2) "mygroup"
   3) "consumers"
   4) (integer) 1
   5) "pending"
   6) (integer) 0
   7) "last-delivered-id"
   8) "1714550000000-0"

Nếu danh sách trống hoặc tên group bị thiếu, lệnh XREADGROUP sẽ tiếp tục thất bại.

Các lỗi thường gặp cần tránh

• Phân biệt chữ hoa chữ thường: Các key và tên group trong Redis có phân biệt chữ hoa chữ thường. 'MyGroup' không giống với 'mygroup'.
• Database Index: Nếu bạn sử dụng nhiều database (ví dụ: SELECT 1), hãy đảm bảo lệnh tạo và lệnh đọc của bạn đang nhắm tới cùng một database index.
• Xóa Stream: Sử dụng DEL mystream sẽ xóa stream và tất cả các consumer group liên quan. Nếu bạn cần xóa dữ liệu nhưng vẫn giữ lại group, hãy sử dụng XTRIM hoặc XDEL để thay thế.

Tài liệu tham khảo thêm

• Tài liệu Redis: XGROUP CREATE
• Tài liệu Redis: XREADGROUP
• Giới thiệu về Redis Streams