Ջg$ldZddlZddlmZddlmZGddeeZGddeZGd d eZy) z flask_caching.backends.rediscache ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ The redis caching backend. :copyright: (c) 2018 by Peter Justin. :copyright: (c) 2010 by Thadeus Burgess. :license: BSD, see LICENSE for more details. N) RedisCache) BaseCachec@eZdZdZ ddZedZdZdZy)raUses 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``. Nc ltj||tj|f||||||d|y)N)default_timeout)hostportpassworddbr key_prefix)r__init__CachelibRedisCache)selfrr r r rr kwargss T/var/www/html/venv/lib/python3.12/site-packages/flask_caching/backends/rediscache.pyr zRedisCache.__init__)sF 4A##  +!  c  ddlm}|j t |j dd|j dd|j dd |j d }|r||d <|j d }|r||d <|j d} | r|| |jdd|d<||i|} | S#t$r}td|d}~wwxYw)Nr)from_urlno redis module foundCACHE_REDIS_HOST localhostCACHE_REDIS_PORTCACHE_REDIS_DB)rr r CACHE_REDIS_PASSWORDr CACHE_KEY_PREFIXr CACHE_REDIS_URLr )r r)redisr ImportError RuntimeErrorupdatedictgetpop) clsappconfigargsrredis_from_urler r redis_url new_classs rfactoryzRedisCache.factory?s ? 8  ZZ 2K@ZZ 2D9::.2  ::45 !)F: ZZ 23 #-F< JJ01 +I&**T4:PQF6N(( 1 ?67Q > ?sB?? C CCct|}|tk(rt|jdSdt j |zS)zDumps an object into a string for redis. By default it serializes integers as regular string and pickle dumps everything else. ascii!)typeintstrencodepickledumps)rvaluets r dump_objectzRedisCache.dump_object]s= K 8u:$$W- -fll5)))rc|sy|jr|Dcgc]}|j|z}}t|jdd}|$t|r|jj|S|jj |Scc}w)z= 3.0.0 and redis > 4, support this operationNunlink)r getattr _write_clientcallabler;delete)rkeyskeyr;s rr;zRedisCache.unlinkfs  ??59:cDOOc):D:++Xt<  (6"2,4%%,,d3 3(t!!(($// ;sB)rrNr,N) __name__ __module__ __qualname____doc__r classmethodr-r9r;rrrrs>.   ,:* 0rrc@eZdZdZ dfd ZedZxZS)RedisSentinelCacheaUses 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 sentinels: A list or a tuple of Redis sentinel addresses. :param master: The name of the master server in a sentinel configuration. :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.sentinel.Sentinel``. c <t||| ddl}|j ddr t d|xsdg}|jD cic]\} } | jdr| dd| } } } |jD cic]\} } | jds| | }} } |jjd |||| d |} | j||_ | j||_y#t$r} t d| d} ~ wwxYwcc} } wcc} } w) Nr rrrdecode_responses0decode_responses is not supported by RedisCache.z 127.0.0.1i g sentinel_ ) sentinelsr r sentinel_kwargsrH)superr redis.sentinelrr r# ValueErroritems startswithsentinelSentinel master_forr= slave_for _read_client)rrRmasterr r rr rrr*rAr7rSrY __class__s rr zRedisSentinelCache.__init__sF JP ? ! ::($ /OP P7"6!7 %lln U~~k* GUN  %lln U>>+. J  +5>>** +    &008$..v67 ?67Q > ?  s#C5!DD5 D> D  Dc |jt|jddg|jdd|jdd|jdd|jdd|jdd  ||i|S) NCACHE_REDIS_SENTINELSrOCACHE_REDIS_SENTINEL_MASTERmymasterrCACHE_REDIS_SENTINEL_PASSWORDrrr)rRr^r sentinel_passwordr r r!r"r#r%r&r'r(rs rr-zRedisSentinelCache.factorys  **%TUzz"?L$:DA"(**-Ld"S!::&8$?::.2   D#F##r)NNNrrBrCrDrErFr rGr- __classcell__r_s@rrJrJss60 )7V $ $rrJc6eZdZdZ dfd ZedZxZS)RedisClusterCacheaUses 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 rediscluster.RedisCluster class. Note: Python Redis API already takes care of encoding unicode strings on the fly. :param cluster: The redis cluster nodes address separated by comma. e.g. host1:port1,host2:port2,host3:port3 . :param password: password authentication for the Redis server. :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 ``rediscluster.RedisCluster``. c (t ||||jddr td ddlm}ddlm} |jdD cgc]} | jd } } | D cgc]-} || dj| d j/} } |jd d } |d| || d|}||_||_y#t$r}td|d}~wwxYwcc} wcc} w#t$r}td |d}~wwxYw)NrLrMrNr) RedisCluster) ClusterNodezno redis.cluster module found,:zQPlease give the correct cluster argument e.g. host1:port1,host2:port2,host3:port3skip_full_coverage_checkT) startup_nodesr rtrH)rTr r#rVrro redis.clusterrprr splitstrip IndexErrorr$r=r])rclusterr rr rrorpr*nodenodesrurtr_s rr zRedisClusterCache.__init__s9 JP ::($ /OP P G * 1 3:==3EF4djjoFEFJOBF DGMMOT!W]]_=M$*::.H$#O  '%=   %#5 G>?Q F GG ;  sL CC7C-)C7/2C2!C7 C* C%%C*- C77 D D  Dc |jt|jdd|jdd|jdd|jdd||i|S)NCACHE_REDIS_CLUSTERrhrCACHE_DEFAULT_TIMEOUTrBr)rzr rr rfrgs rr-zRedisClusterCache.factorysd  #8"=$:B? & +BC H!::&8"=   D#F##r)rhrhrBrhrirks@rrmrms).HJ%$N $ $rrm) rFr5cachelibrrflask_caching.backends.baserrJrmrHrrrsD 51]0.]0@O$O$dH$ H$r