U Zf9@s4ddlZddlmZddlmZGdddeZdS)N) BaseCache)RedisSerializerc @seZdZUdZdZejed<dZejed<e Z d,eje ej e e e ej e ejd d d Zej e e d d dZe ejdddZe ejejdddZd-e ejej e ejdddZd.e ejej e ejdddZd/eje ejfej e ejejdddZe edddZe ejejddd Ze edd!d"Zed#d$d%Zd0e e ejd'd(d)Zd1e e ejd'd*d+ZdS)2 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|||dkrtdt|trz ddl}Wn,tk r^} ztd| W5d} ~ XYnX|ddrttd|j f||||d||_ |_ n ||_ |_ |pd|_ dS)Nz)RedisCache host parameter may not be Nonerzno redis module foundZdecode_responsesz0decode_responses is not supported by RedisCache.)r r r r ) r__init__ ValueError isinstancestrredis ImportError RuntimeErrorgetZRedisrrr) selfr r r r rrrrerrr2/tmp/pip-unpacked-wheel-7m7iy3r0/cachelib/redis.pyr!s(     zRedisCache.__init__)timeoutreturncCst||}|dkrd}|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)rrrrrr!<s zRedisCache._normalize_timeout)keyrcCs|j|j|j|SN) serializerloadsrrrrr"rrrrGszRedisCache.get)keysrcs<jrfdd|D}nt|}fddj|DS)Ncsg|]}j|qSrr.0r"rrr Lsz'RedisCache.get_many..csg|]}j|qSr)r$r%)r*xr+rrr,Os)rlistrZmgetrr'Z prefixed_keysrr+rget_manyJszRedisCache.get_many)r"valuerrcCsR||}|j|}|dkr6|jj|j||d}n|jj|j|||d}|S)Nr namer1r3r1time)r!r$dumpsrsetrsetex)rr"r1rdumpresultrrrr7Qs  zRedisCache.setcCsR||}|j|}|jj|j||d}|rN|dkrN|jj|j||d|S)Nr2r )r3r5)r!r$r6rZsetnxrZexpire)rr"r1rr9createdrrradd\s    zRedisCache.add)mappingrrcCs||}|jjdd}|D]H\}}|j|}|dkrR|j|j||dq |j|j|||dq | }ddt | |DS)NF)Z transactionr r2r4cSsg|]\}}|r|qSrr)r*kZwas_setrrrr,tsz'RedisCache.set_many..) r!rZpipelineitemsr$r6r7rr8executezipr')rr=rpiper"r1r9resultsrrrset_manyes  zRedisCache.set_manycCst|j|j|Sr#)boolrdeleterr&rrrrFvszRedisCache.deletecsN|sgSjr"fdd|D}ndd|D}jj|fdd|DS)Ncsg|]}j|qSrr(r)r+rrr,}sz*RedisCache.delete_many..cSsg|]}|qSrrr*r>rrrr,scsg|]}|s|qSr)hasrGr+rrr,s )rrrFr/rr+r delete_manyys zRedisCache.delete_manycCst|j|j|Sr#)rErexistsrr&rrrrHszRedisCache.has)rcCs@d}|jr.|j|jd}|r8|jj|}n |j}t|S)Nr*)rrr'rrFZflushdbrE)rstatusr'rrrclears zRedisCache.clear)r"deltarcCs|jj|j||dSN)r3amountrincrrrr"rOrrrincszRedisCache.inccCs|jj|j|| dSrPrRrTrrrdecszRedisCache.dec)rrNrr N)N)N)N)rN)rN)__name__ __module__ __qualname____doc__r_tAny__annotations__rrr$intOptionalrrr!rListr0r7r<DictrDrErFrIrHrMrUrVrrrrrsH       r)typingr[Z cachelib.baserZcachelib.serializersrrrrrrs