o ]f$@sZdZddlZddlmZddlmZGdddeeZGdddeZGd d d eZdS) 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@sBeZdZdZ      dddZed d Zd d Zd dZdS)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``. localhostNr,c Ks2tj||dtj|f||||||d|dS)N)default_timeout)hostportpassworddbr key_prefix)r__init__CachelibRedisCache)selfrr r r rr kwargsrZ/home/ubuntu/webapp/venv/lib/python3.10/site-packages/flask_caching/backends/rediscache.pyr )s  zRedisCache.__init__c Cszddlm}Wnty}ztd|d}~ww|t|dd|dd|ddd |d }|r;||d <|d }|rF||d <|d} | rY|| |ddd|d<||i|} | S)Nr)from_urlno redis module foundCACHE_REDIS_HOSTrCACHE_REDIS_PORTrCACHE_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_classrrrfactory?s0       zRedisCache.factorycCs,t|}|tkrt|dSdt|S)zDumps an object into a string for redis. By default it serializes integers as regular string and pickle dumps everything else. ascii!)typeintstrencodepickledumps)rvaluetrrr dump_object]szRedisCache.dump_objectcsV|sdSjrfdd|D}tjdd}|dur%t|r%jj|Sjj|S)z= 3.0.0 and redis > 4, support this operationNcsg|]}j|qSr)r ).0keyrrr kz%RedisCache.unlink..unlink)r getattr _write_clientcallabler;delete)rkeysr;rr8rr;fs  zRedisCache.unlink)rrNrrN) __name__ __module__ __qualname____doc__r classmethodr*r5r;rrrrrs   rcs:eZdZdZ      d fdd Zedd ZZS) 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``. Nrrc stj||dzddl}Wnty} ztd| d} ~ ww|ddr*td|p.dg}dd|D} d d|D}|jj d |||| d |} | ||_ | ||_ dS) Nr rrrdecode_responses0decode_responses is not supported by RedisCache.z 127.0.0.1i gcSs(i|]\}}|dr|dd|qS) sentinel_ N startswithr6r7r3rrr s  z/RedisSentinelCache.__init__..cSs i|] \}}|ds||qS)rLrNrPrrrrQs ) sentinelsr r sentinel_kwargsr)superr redis.sentinelrrr ValueErroritemssentinelSentinel master_forr= slave_for _read_client) rrRmasterr r rr rrr'rSrX __class__rrr s4      zRedisSentinelCache.__init__c CsZ|t|ddg|dd|dd|dd|dd|dd d ||i|S) NCACHE_REDIS_SENTINELSrKCACHE_REDIS_SENTINEL_MASTERmymasterrCACHE_REDIS_SENTINEL_PASSWORDrrr)rRr]r sentinel_passwordr r rrr r"r#r$r%rrrrr*s       zRedisSentinelCache.factory)NNNrrrGrArBrCrDr rEr* __classcell__rrr^rrFss+rFcs0eZdZdZ dfdd ZeddZZS) 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``. rGrc stj||d|ddrtdzddlm}ddlmWnty1}zt d|d}~wwzdd | d D}fd d |D} Wnt yX}ztd |d}~ww| d d} |d| || d|}||_ ||_dS)NrHrIrJr) RedisCluster ClusterNodezno redis.cluster module foundcSsg|]}|dqS):)splitr6noderrrr9r:z.RedisClusterCache.__init__..,cs&g|]}|d|dqS)r)striprorkrrr9szQPlease give the correct cluster argument e.g. host1:port1,host2:port2,host3:port3skip_full_coverage_checkT) startup_nodesr rtr)rTr r rVrrj redis.clusterrlrrrn IndexErrorr!r=r\) rclusterr rr rrjr'nodesrurtr^rkrr sB       zRedisClusterCache.__init__c CsD|t|dd|dd|dd|ddd||i|S)NCACHE_REDIS_CLUSTERrGrCACHE_DEFAULT_TIMEOUTrr)rxr rr rerfrrrr*s    zRedisClusterCache.factory)rGrGrrGrgrrr^rris 'ri) rDr1cachelibrrflask_caching.backends.baserrFrirrrrs  `R