o ]f9@s4ddlZddlmZddlmZGdddeZdS)N) BaseCache)RedisSerializerc@seZdZUdZdZejed<dZejed<e Z      d2d ejd e d ej e d e d e dej e dejfddZdej e de fddZde dejfddZde dejejfddZd3de dejdej e dejfddZd3de dejdej e dejfdd Z d3d!eje ejfdej e dejejfd"d#Zde defd$d%Zde dejejfd&d'Zde defd(d)Zdefd*d+Zd4de d-e dejfd.d/Zd4de d-e dejfd0d1ZdS)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``. N _read_client _write_client localhostr,hostportpassworddbdefault_timeout key_prefixkwargsc Kst|||durtdt|trGzddl}Wnty*} ztd| d} ~ ww|ddr5td|j d||||d||_ |_ n||_ |_ |pPd|_ dS) Nz)RedisCache host parameter may not be Nonerzno redis module founddecode_responsesz0decode_responses is not supported by RedisCache.)r r r r ) r__init__ ValueError isinstancestrredis ImportError RuntimeErrorgetRedisrrr) selfr r r r rrrrerrrrG/home/ubuntu/webapp/venv/lib/python3.10/site-packages/cachelib/redis.pyr!s&      zRedisCache.__init__timeoutreturncCst||}|dkr d}|S)zNormalize timeout by setting it to default of 300 if not defined (None) or -1 if explicitly set to zero. :param timeout: timeout to normalize. r)r_normalize_timeout)rr rrrr#<s zRedisCache._normalize_timeoutkeycCs|j|j|j|SN) serializerloadsrrrrr$rrrrGszRedisCache.getkeyscs<jr fdd|D}nt|}fddj|DS)Ncg|]}j|qSrr.0r$rrr Lz'RedisCache.get_many..csg|]}j|qSr)r&r')r-xr.rrr/O)rlistrmgetrr) prefixed_keysrr.rget_manyJszRedisCache.get_manyvaluecCsT||}|j|}|dkr|jj|j||d}|S|jj|j|||d}|S)Nr"namer8r:r8time)r#r&dumpsrsetrsetex)rr$r8r dumpresultrrrr>Qs   zRedisCache.setcCsR||}|j|}|jj|j||d}|r'|dkr'|jj|j||d|S)Nr9r")r:r<)r#r&r=rsetnxrexpire)rr$r8r r@createdrrradd\s   zRedisCache.addmappingcCs||}|jjdd}|D]$\}}|j|}|dkr)|j|j||dq|j|j|||dq| }ddt | |DS)NF) transactionr"r9r;cSsg|]\}}|r|qSrr)r-kwas_setrrrr/tr2z'RedisCache.set_many..) r#rpipelineitemsr&r=r>rr?executezipr))rrFr piper$r8r@resultsrrrset_manyes  zRedisCache.set_manycCt|j|j|Sr%)boolrdeleterr(rrrrSvzRedisCache.deletecsN|sgSjrfdd|D}ndd|D}jj|fdd|DS)Ncr*rr+r,r.rrr/}r0z*RedisCache.delete_many..cSsg|]}|qSrrr-rHrrrr/scsg|] }|s|qSr)hasrUr.rrr/s)rrrSr5rr.r delete_manyys zRedisCache.delete_manycCrQr%)rRrexistsrr(rrrrVrTzRedisCache.hascCsFd}|jr|j|jd}|r|jj|}t|S|j}t|S)Nr*)rrr)rrSflushdbrR)rstatusr)rrrclears  zRedisCache.cleardeltacCs|jj|j||dSN)r:amountrincrrrr$r^rrrincrTzRedisCache.inccCs|jj|j|| dSr_rarcrrrdecszRedisCache.dec)rrNrr Nr%)r])__name__ __module__ __qualname____doc__r_tAny__annotations__rrr&intOptionalrrr#rListr7r>rEDictrPrRrSrWrVr\rdrerrrrrsZ   &&      r)typingrj cachelib.basercachelib.serializersrrrrrrs