在 Redis 中获取单个元素在 30 天内过期的集合的最干净方法？-解网

问：

我需要一个类似于 redis 中 Python 集的数据结构，并具有单个元素在插入 30 天后自动从集合中过期（弹出）的附加功能。基本上，这些是我想要从课堂上得到的抽象行为。

from abc import abstractmethod, ABC
from typing import Iterable 

class RedisSet(ABC):
    """Implement a set of strings with a remote redis host."""
    @abstractmethod
    def __init__(self, url:str):
        """
           Initialise the class at the remote redis url.
           The set of strings should be empty initially.            
        """
        raise NotImplementedError    
    @abstractmethod
    def add(self, new_elements:Iterable[str])->None:
        """Insert all the elements into the set."""
        raise NotImplementedError
    @abstractmethod
    def __contains__(self, elem:str)->bool:
        """Check membership."""
        raise NotImplementedError

那么，实现它的最干净的方法是什么？我不需要实现整个类，而是询问在 redis 中使用的正确数据类型和 API 是什么，因为我并不完全熟悉 redis 的全部功能。

我注意到 redis 有一个固定的数据类型，但似乎（如果我错了，很高兴得到纠正）它不支持任何生存时间（TTL）。相反，字典支持 TTL，但我必须为每个键使用占位符（不必要的开销），并且我不确定成员资格检查是否是恒定时间。value

注意

我不认为需要遍历这些元素，因此针对该操作进行优化是多余的。我所需要的只是会员资格检查。
我打算用作python客户端。它应该支持必要的 redis 操作。aioredis

任何关于正确的 redis 数据类型的想法，我应该查找其文档，我们将不胜感激。

python redis set hashset aioredis

from abc import abstractmethod, ABC
from typing import Iterable 

class RedisSet(ABC):
    """Implement a set of strings with a remote redis host."""
    @abstractmethod
    def __init__(self, url:str):
        """
           Initialise the class at the remote redis url.
           The set of strings should be empty initially.            
        """
        self.redis = // init the redis connection
        self.set_key = set_key
        
    @abstractmethod
    def add(self, new_elements:Iterable[str])->None:
        """Insert all the elements into the set."""
        const startTime = Date.now();
        const offset = 1000*60*60*24*30; // 30 days
        
        for elem in new_elements:
            await self.redis..zadd(self.set_key, Date.now() + offset, elem)

    @abstractmethod
    def __contains__(self, elem:str)->bool:
        """Check membership."""
        exists = await self.redis.zscore(self.set_key, elem)

        if score is None or score < time.time():
            return False
        
        return True

@Della Your solution is simpler, but don't forget you are using extra memory by using the expire feature. it is a feature that Redis needs to keep some data about the time of expiry and the key name. So I assume that your solution would use a bit more memory. It would be better to implement an MVP of these solutions and check their performance and memory usage. PS. You can put an empty string for value in your solution, and it would be minimal in size. PS. For checking the memory You can use . PS. A command for checking the serialization length INFO MemoryDEBUG OBJECT key

上一个：打印出一个元素的集合不会显示任何内容

下一个：如何在合并方面处理 Python Pandas Dataframe 中的无序标签集

在 Redis 中获取单个元素在 30 天内过期的集合的最干净方法？

Cleanest Way to Get a Set in Redis where Individual Elements Expire in 30 Days?

评论

评论