Python 邊做邊學 8.7 工具類--快取工具(RedisUtil)
阿新 • • 發佈:2019-01-28
需求
為了將抓取解析與資料儲存分開處理,需要將抓取的資料先快取起來,然後另起執行緒進行資料儲存;公司專案用過Redis處理需要快取的資料,那就他了;
- 儲存資料;
- 獲取資料;
- 刪除資料;
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)
以上就是我們用到的快取工具類,需求相對比較簡單,不再贅述;
以上內容僅供練習,學習使用;