3 уdeу@s<ddlZddlZddlmZddlmZGddДdeГZdS)щN)┌ BaseCache)┌RedisSerializerc @sТeZdZdZeГZd/ejeej e eeej e ejdЬdd ДZej eed ЬddДZeje d ЬddДZejejd ЬddДZe ejdЬddДZe ejejdЬddДZd0e ejej eej edЬddДZd1e ejej eedЬddДZd2eje ejfej eejejdЬddДZe edЬd d!ДZe ejejdЬd"d#ДZe edЬd$d%ДZed&Ьd'd(ДZd3e eej ed*Ьd+d,ДZd4e eej ed*Ьd-d.ДZdS)5┌ RedisCacheaUses the Redis key-value store as a cache backend. The first argument can be either a string denoting address of the Redis server or an object resembling an instance of a redis.Redis class. Note: Python Redis API already takes care of encoding unicode strings on the fly. :param host: address of the Redis server or an object which API is compatible with the official Python Redis client (redis-py). :param port: port number on which Redis server listens for connections. :param password: password authentication for the Redis server. :param db: db (zero-based numeric index) on Redis Server to connect. :param default_timeout: the default timeout that is used if no timeout is specified on :meth:`~BaseCache.set`. A timeout of 0 indicates that the cache never expires. :param key_prefix: A prefix that should be added to all keys. Any additional keyword arguments will be passed to ``redis.Redis``. ┌ localhostщыNrщ,)┌host┌port┌password┌db┌default_timeout┌ key_prefix┌kwargsc Ksжtj||Г|dkrtdГВt|tГrТyddl}Wn,tk r^} ztdГ| ВWYdd} ~ XnX|jddГrttdГВ|j f||||dЬ|ЧО|_ n||_ |pЮd|_dS)Nz)RedisCache host parameter may not be Nonerzno redis module foundZdecode_responsesz0decode_responses is not supported by RedisCache.)rr r r┌)r┌__init__┌ ValueError┌ isinstance┌str┌redis┌ImportError┌RuntimeError┌getZRedis┌_clientr ) ┌selfrr r rrr rr┌errйr·E/var/www/agendate/envp3/lib/python3.6/site-packages/cachelib/redis.pyr s zRedisCache.__init__)┌timeout┌returncCstj||Г}|dkrd}|S)Nrщщ )r┌_normalize_timeout)rrrrrr!;szRedisCache._normalize_timeout)┌valuercCstjdtddН|jj|ГS)Nzs'dump_object' is deprecated and will be removed in the future.This is a proxy call to 'RedisCache.serializer.dumps'щ)┌ stacklevel)┌warnings┌warn┌DeprecationWarning┌ serializer┌dumps)rr"rrr┌dump_objectAs zRedisCache.dump_objectcCstjdtddН|jj|ГS)Nzs'load_object' is deprecated and will be removed in the future.This is a proxy call to 'RedisCache.serializer.loads'r#)r$)r%r&r'r(┌loads)rr"rrr┌load_objectJs zRedisCache.load_object)┌keyrcCs|j|jj|j|ГГS)N)r,rrr )rr-rrrrSszRedisCache.get)┌keysrcsBИjrЗfddД|DГ}nddД|DГ}ЗfddДИjj|ГDГS)Ncsg|]}Иj|СqSr)r )┌.0r-)rrr· Xsz'RedisCache.get_many..cSsg|]}|СqSrr)r/┌krrrr0Zscsg|]}Иj|ГСqSr)r,)r/┌x)rrrr0[s)r rZmget)rr.┌ prefixed_keysr)rr┌get_manyVszRedisCache.get_many)r-r"rrcCsP|j|Г}|j|Г}|dkr4|jj|j||dН}n|jj|j|||dН}|S)Nr)┌namer")r5r"┌timer )r!r*r┌setr ┌setex)rr-r"r┌dump┌resultrrrr7]s zRedisCache.setcCs@|j|Г}|j|Г}|jj|j||dНo>|jj|j||dНS)N)r5r")r5r6)r!r*rZsetnxr Zexpire)rr-r"rr9rrr┌addjs zRedisCache.add)┌mappingrrcCsМ|j|Г}|jjddН}xR|jГD]F\}}|j|Г}|dkrR|j|j||dНq"|j|j|||dНq"W|jГ}ddДt |j Г|ГDГS) NF)Ztransactionr)r5r")r5r"r6cSsg|]\}}|r|СqSrr)r/r1Zwas_setrrrr0Аsz'RedisCache.set_many..r )r!rZpipeline┌itemsr*r7r r8┌execute┌zipr.)rr<r┌piper-r"r9┌resultsrrr┌set_manyqs zRedisCache.set_manycCst|jj|j|ГГS)N)┌boolr┌deleter )rr-rrrrDВszRedisCache.deletecsN|sgSИjr"ЗfddД|DГ}nddД|DГ}Иjj|ОЗfddД|DГS)Ncsg|]}Иj|СqSr)r )r/r-)rrrr0Йsz*RedisCache.delete_many..cSsg|]}|СqSrr)r/r1rrrr0Лscsg|]}Иj|Гs|СqSr)┌has)r/r1)rrrr0Нs)r rrD)rr.r3r)rr┌delete_manyЕszRedisCache.delete_manycCst|jj|j|ГГS)N)rCr┌existsr )rr-rrrrEПszRedisCache.has)rcCs@d}|jr.|jj|jdГ}|r8|jj|О}n |jjГ}t|ГS)Nr┌*)r rr.rDZflushdbrC)r┌statusr.rrr┌clearТs zRedisCache.clearr)r-┌deltarcCs|jj|j||dНS)N)r5┌amount)r┌incrr )rr-rKrrr┌incЬszRedisCache.inccCs|jj|j||dНS)N)r5rL)rrMr )rr-rKrrr┌decЯszRedisCache.dec)rrNrrN)N)N)N)r)r)┌__name__┌ __module__┌__qualname__┌__doc__rr(┌_t┌Any┌int┌Optionalrrr!┌bytesr*r,r┌Listr4rCr7r;┌DictrBrDrFrErJrNrOrrrrrs2 r)┌typingrTr%Z cachelib.baserZcachelib.serializersrrrrrr┌s