🎈 perf: 当 PEL 消息过多时，休息1s再试，避免0等待的空循环。

Author: nowanti

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "usepy-plugin-redis"
-version = "0.1.4"
+version = "0.1.5"
 description = ""
 authors = ["miclon <jcnd@163.com>"]
 readme = "README.md"

src/usepy_plugin_redis/stream.py

@@ -184,6 +184,7 @@ def consume(
         # 计算需获取的消息数量
         need_count = prefetch - len(pending_messages) if pending_messages else prefetch
         if need_count <= 0:
+            time.sleep(1)  # 尚未ACK的消息过多，导致本次不获取，暂停1s再试
             return []
 
         result = []
@@ -236,4 +237,3 @@ def reject(self, message: RedisStreamMessage):
         Reject a message.
         """
         self.connection.xack(self.stream, self.group, message.id)
-