XfBddlZddlmZddlmZGddeZdS)N) BaseCache)RedisSerializerceZdZUdZdZejed<dZejed<e Z d&d ejd e d ej e d e d e dej eje ejge ffdejfdZde fdZdej e de fdZde dejfdZde dejejfdZd'de dejdej e dejfdZd'de dejdej e dejfdZ d'deje ejfdej e dejejfdZde defdZde dejejfdZde defd Zdefd!Zd(de d#e dejfd$Zd(de d#e dejfd%Z dS)) 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 tj|||tdt|trl ddl}n"#t $r} td| d} ~ wwxYw|ddrtd|j d||||d|x|_ |_ n|x|_ |_ |pd|_ dS) Nz)RedisCache host parameter may not be Nonerzno redis module founddecode_responsesz0decode_responses is not supported by RedisCache.)r r rr) r__init__ ValueError isinstancestrredis ImportError RuntimeErrorgetRedisrrr) selfr r rrrrrrerrs B/var/www/piapp/venv/lib/python3.11/site-packages/cachelib/redis.pyrzRedisCache.__init__!s  4111 <HII I dC : E  E E E"#:;;D Ezz,d33 U !STTT5@U[6xB66BH66 D !2!26: 9D  2$*sA A! AA!returnclt|jtr|jn|SN)rrr)r s r" _get_prefixzRedisCache._get_prefix<s+)$/3?? VDOOT__EVEV timeoutc@tj||}|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)r r(s r"r+zRedisCache._normalize_timeoutAs) .tW== a<<Gr'keyc|j|j||Sr%) serializerloadsrrr&r r,s r"rzRedisCache.getLsG$$   ! !T%5%5%7%7">">"> ? ?   r'keyscjrfd|D}nt|}fdj|DS)Nc@g|]}|Srr&.0r,r s r" z'RedisCache.get_many..S0JJJc 0 0 2 29C99JJJr'cDg|]}j|Sr)r.r/)r6xr s r"r7z'RedisCache.get_many..Vs)XXXQ%%a((XXXr')rlistrmgetr r1 prefixed_keyss` r"get_manyzRedisCache.get_manyQs^ ? 'JJJJTJJJMM JJMXXXX$2C2H2H2W2WXXXXr'valuec<||}|j|}|dkr3|j|||}n3|j||||}|S)Nr*namer@rCr@time)r+r.dumpsrsetr&setex)r r,r@r(dumpresults r"rGzRedisCache.setXs))'22$$U++ b=='++((**1C11,FF'--((**1C11G.F r'c<||}|j|}|j|||}|r8|dkr2|j||||S)NrBr*)rCrE)r+r.rFrsetnxr&expire)r r,r@r(rIcreateds r"addzRedisCache.addes))'22$$U++$**$$&&---T+    Ww"}}   % %d.>.>.@.@+G#+G+Gg % V V Vr'mappingc||}|jd}|D]\}}|j|}|dkr.||||S|||||| }dt| |DS)NF) transactionr*rBrDcg|] \}}|| Srr)r6kwas_sets r"r7z'RedisCache.set_many..s!LLLjaGLLLLr') r+rpipelineitemsr.rFrGr&rHexecutezipr1)r rPr(piper,r@rIresultss r"set_manyzRedisCache.set_manyps))'22!**u*==!--// X XJC?((//D"}}!1!1!3!3:S::$GGGG 4#3#3#5#5 .r8r'cg|]}|Srr)r6rTs r"r7z*RedisCache.delete_many..s---1Q---r'c>g|]}||Sr)has)r6rTr s r"r7z*RedisCache.delete_many..s(<<rs}######000000XYXYXYXYXYXYXYXYXYXYr'