先删除KEY,防止内容冗余。
This commit is contained in:
@@ -48,6 +48,7 @@ class GroupMemberChange:
|
||||
print("First time processing, saving current data to Redis")
|
||||
members_current = self.get_current_members(group_id)
|
||||
self.r.set(f"group:group_member_count:{group_id}", membercount_current)
|
||||
self.r.delete(f"group:group_members:{group_id}")
|
||||
self.r.hset(f"group:group_members:{group_id}", mapping=members_current) # 存储当前成员信息
|
||||
|
||||
# 更新本地缓存
|
||||
@@ -97,6 +98,7 @@ class GroupMemberChange:
|
||||
print(f"Updating Redis with current membercount and members")
|
||||
self.r.set(f"group:group_member_count:{group_id}", membercount_current)
|
||||
|
||||
self.r.delete(f"group:group_members:{group_id}")
|
||||
# 更新 Redis 中的成员信息,确保在成员变化时也更新
|
||||
self.r.hset(f"group:group_members:{group_id}", mapping=members_current)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user