需求

為了將抓取解析與資料儲存分開處理，需要將抓取的資料先快取起來，然後另起執行緒進行資料儲存；公司專案用過Redis處理需要快取的資料，那就他了；

1. 儲存資料；
2. 獲取資料；
3. 刪除資料；

Talk is cheap. Show me the code

import redis
from lufaxin.csdn.util import CfgUtil



class RedisUtil():
    __pool = None

    def __init__(self):
        # Redis地址
        host = CfgUtil.get_redis("redis_host"
 
)
        # Redis埠
        port = int(CfgUtil.get_redis("redis_port"))
        self.__pool = redis.ConnectionPool(host=host, port=port)

    # 儲存資料
    # expire：過期時間，單位秒
    def r_set(self, key, value, expire=None):
        redi = redis.Redis(connection_pool=self.__pool)
        redi.set(key, value, ex=expire)

    # 獲取資料
 

    def r_get(self, key):
        redi = redis.Redis(connection_pool=self.__pool)
        value = redi.get(key)
        if value is None:
            return None
        value = value.decode("UTF-8")
        return value

    # 刪除資料
    def r_del(self, key):
        redi = redis.Redis(connection_pool=self.__pool)
        redi.delete(key)
 

以上就是我們用到的快取工具類，需求相對比較簡單，不再贅述；

以上內容僅供練習，學習使用；