Ջg:ddlZddlmZddlmZGddeZy)N) BaseCache)RedisSerializerceZdZUdZdZej ed<dZej ed<e Z d!dej de deje de d e d ejeje ejge ffd ej fd Zd e fdZdeje d e fdZde d ej fdZde d ej(ej fdZd"de dej deje d ej fdZd"de dej deje d ej fdZ d"dej0e ej fdeje d ej(ej fdZde d efdZde d ej(ej fdZde d efdZd efdZd#de de d ej fdZd#de de d ej fd Z y)$ 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_clienthostportpassworddbdefault_timeout key_prefixkwargsc btj||| tdt|trF ddl}|jddr td|jd||||d|x|_ |_ n|x|_ |_ |xsd|_ y#t $r} td| d} ~ wwxYw) 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 r rrrerrs A/var/www/html/venv/lib/python3.12/site-packages/cachelib/redis.pyrzRedisCache.__init__!s 41 <HI I dC  Ezz,d3 !STT5@U[[6xB6BH6 D !26: 9D  2$* E"#:;D EsB B. B))B.returncnt|jtr |jS|jSN)rrr)rs r _get_prefixzRedisCache._get_prefix<s*)$//3?DOO EI__EV timeoutc@tj||}|dk(rd}|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%s rr(zRedisCache._normalize_timeoutAs' ..tW= a<Gr$keyc|jj|jj|j |Sr") serializerloadsrrr#rr)s rrzRedisCache.getLs@$$    ! !T%5%5%7$8"> ?  r$keysc |jr"|Dcgc]}|j|}}n t|}|jj |Dcgc]}|j j |c}Scc}wcc}wr")rr#listrmgetr+r,)rr.r) prefixed_keysxs rget_manyzRedisCache.get_manyQsu ??EIJc 0 0 23C59JMJ JM262C2C2H2H2WXQ%%a(XXKYs A<"Bvaluec*|j|}|jj|}|dk(r1|jj |j ||}|S|jj |j |||}|S)Nr'namer5r8r5time)r(r+dumpsrsetr#setex)rr)r5r%dumpresults rr<zRedisCache.setXs))'2$$U+ b=''++((*+C51,F ''--((*+C51G.F r$c(|j|}|jj|}|jj |j ||}|r4|dk7r/|jj |j |||S)Nr7r')r8r:)r(r+r;rsetnxr#expire)rr)r5r%r>createds raddzRedisCache.addes))'2$$U+$$**$$&'u-T+  w"}    % %d.>.>.@-A#+Gg % Vr$mappingc|j|}|jjd}|jD]q\}}|jj |}|dk(r&|j |j||L|j|j|||s|j}t|j|D cgc] \}} | s | c} }Scc} }w)NF) transactionr'r7r9) r(rpipelineitemsr+r;r<r#r=executezipr.) rrEr%piper)r5r>resultskwas_sets rset_manyzRedisCache.set_manyps))'2!!**u*=!--/ XJC??((/D"}!1!1!3 4SE:$G 4#3#3#5"6se |jj |}t|S|jj }t|S)Nr*)rrr.r#rrSflushdbrR)rstatusr.s rclearzRedisCache.clearsy ??$$))$*:*:*rzs#0XYXYr$