我要评论pip安装包
pip install django-redis4.8.0
pip install python-memcached1.58
django setting.py 配置：
REDIS_HOST = '127.0.0.1'
REDIS_PORT = 6379
REDIS_NO = 11
REDIS_PASSWORD = 'Adminunicorn.yt' # 线上
REDIS_TIMEOUT = 60 * 60 * 24 * 1
CACHES = {
'default': {
'BACKEND': 'django_redis.cache.RedisCache',
'LOCATION': 'redis://' + REDIS_HOST + ':' + str(REDIS_PORT) + '/' + str(REDIS_NO),
"OPTIONS": {
"PASSWORD": REDIS_PASSWORD,
"IGNORE_EXCEPTIONS": True, # memcached 异常行为
"CONNECTION_POOL_KWARGS": {"max_connections": 100}, # 配置默认连接池
"PICKLE_VERSION": -3,
"CLIENT_CLASS": "django_redis.client.DefaultClient",
},
},
}
封装好的缓存工具类
# -*- coding:utf-8 -*-
"""
Created on 2018/12/03
@author: cjh
缓存工具类，操作redis
"""
import json
import datetime
from django.core.cache import cache
def exist_cache(key):
"""
判断缓存数据是否存在
:param key: 唯一标识
:return: 存在结果
"""
is_exist = False
if key in cache:
is_exist = True
return is_exist
def clear_cache(key):
"""
清除缓存数据
:param key：唯一标识
"""
if key in cache:
cache.delete(key)
def clear_pattern_cache(fuzzy_key):
"""
清除缓存数据
:param fuzzy_key：模糊标识
:return:
"""
cache.delete_pattern("*%s*" % fuzzy_key)
def write_data_to_cache(key, value, expire=None):
"""
将数据直接写入缓存
:param key：唯一标识
:param value：写入的数据
:param expire：失效时间（单位为秒），默认为不失效
"""
cache.set(key, value, timeout=expire)
def write_json_to_cache(key, value, expire=None):
"""
将数据转为json格式写入缓存
:param key：唯一标识
:param value：写入的数据
:param expire：失效时间（单位为秒），默认为不失效
"""
cache.set(key, json.dumps(value, cls=CJsonEncoder), timeout=expire)
def write_counter_to_cache(key, step=1, expire=None):
"""
计数器写入缓存
:param key：唯一标识
:param step：计数器每次递增的值（支持负数进行递减），默认每次递增1
:param expire：失效时间（单位为秒），默认为不失效
"""
if key in cache:
cache.incr(key, step)
else:
cache.set(key, 1, expire)
def read_pattern_data_from_cache(fuzzy_key):
"""
读取缓存
:param fuzzy_key：模糊标识
:return：缓存数据
"""
keys = cache.keys("*%s*" % fuzzy_key)
data = []
for key in keys:
data.append({
'key': key,
'value': cache.get(key)
})
return data
def read_data_from_cache(key):
"""
直接读取缓存
:param key：唯一标识
:return：缓存数据
"""
if key in cache:
data = cache.get(key)
else:
data = None
return data
def read_json_from_cache(key):
"""
读取json格式缓存
:param key：唯一标识
:return：缓存进行json解析后数据
"""
if key in cache:
data = json.loads(cache.get(key))
else:
data = None
return data
class CJsonEncoder(json.JSONEncoder):
"""
重写构造json类，遇到日期特殊处理
"""
def default(self, obj):
if isinstance(obj, datetime.datetime):
return obj.strftime('%Y-%m-%d %H:%M:%S')
elif isinstance(obj, datetime.date):
return obj.strftime("%Y-%m-%d")
else:
return json.JSONEncoder.default(self, obj)
def redis_caches():
"""
不失效缓存，key为加载此装饰器的函数名
:param:
:return:
"""
def _deco(func):
def __deco(*args, **kwargs):
redis_key = func.__name__
cache_info = read_data_from_cache(redis_key)
if not cache_info:
result = func(*args, **kwargs)
write_data_to_cache(redis_key, result)
else:
result = cache_info
return result
return __deco
return _deco
缓存装饰器使用方式
自己定义数据获取方式，使用上面的装饰器，即可实现自动缓存，直接调用就会拿到数据，当缓存中没有的时候，会先自动写入缓存，再返回缓存中的值。
@redis_caches()
def get_lot_device_type():
"""
获取物联网设备及类型
:return:
"""
equip_dict = dict()
for i in LotDevice.objects.filter(status='a').select_related('type'):
if i.gateway_address in equip_dict:
continue
else:
equip_dict[str(i.gateway_address)] = {'id': i.id,
'name': i.name,
'address': i.address,
'gateway_address': i.gateway_address,
'type_id': i.type_id,
'type_name': i.type.name if i.type else '',
'type_code': i.type.code if i.type else '',
'type_name_eng': i.type.name_eng if i.type else '',
}
return equip_dict
本文地址：https://blog.csdn.net/weixin_37923411/article/details/107095100
您可能感兴趣的文章:
如您对本文有疑问或者有任何想说的，请点击进行留言回复，万千网友为您解惑！
网友评论