diff --git a/message_storage/message_to_db.py b/message_storage/message_to_db.py index 5444f0c..79645b4 100644 --- a/message_storage/message_to_db.py +++ b/message_storage/message_to_db.py @@ -21,7 +21,7 @@ class MessageStorage: def _get_redis_connection(self): """从连接池获取 Redis 连接""" - return redis.Redis(connection_pool=self.redis_pool) + return redis.Redis(connection_pool=self.redis_pool, decode_responses=True) def archive_message(self, msg: WxMsg): # 连接到数据库