o 2'hЧу@s4ddlZddlmZddlmZGddДdeГZdS)щN)┌ BaseCache)┌RedisSerializerc@sрeZdZUdZdZejed<dZejed<e ГZ d4d ejd edeje ded edejeje ejge ffdejfddДZde fddДZdejedefddДZde dejfddДZde dejejfddДZd5de dejdejedejfdd ДZd5de dejdejedejfd!d"ДZ d5d#eje ejfdejedejejfd$d%ДZde defd&d'ДZde dejejfd(d)ДZde defd*d+ДZdefd,d-ДZd6de d/edejfd0d1ДZd6de d/edejfd2d3ДZ dS)7┌ 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┌ localhostщыrщ,┌host┌port┌password┌db┌default_timeout┌ key_prefix┌kwargsc Ksиtа||б|durtdГВt|tГrGzddl}Wnty*} ztdГ| Вd} ~ ww|аddбr5tdГВ|j d||||dЬ|дО|_ |_n||_|_ |pPd|_dS) Nz)RedisCache host parameter may not be Nonerzno redis module foundZdecode_responsesz0decode_responses is not supported by RedisCache.)r rrr ┌й) r┌__init__┌ ValueError┌ isinstance┌str┌redis┌ImportError┌RuntimeError┌getZRedisrrr) ┌selfr rrr rrrr┌errrr·DC:\Users\shubh\Videos\agent\nova\Lib\site-packages\cachelib/redis.pyr!s& А zRedisCache.__init__┌returncCst|jtГr |jS|абSйN)rrrйrrrr┌_get_prefix<s zRedisCache._get_prefix┌timeoutcCstа||б}|dkrd}|S)zиNormalize 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"rrrr$AszRedisCache._normalize_timeout┌keycCs |jа|jа|абЫ|ЫЭббSr)┌ serializer┌loadsrrr!йrr%rrrrLs zRedisCache.get┌keyscs<Иjr ЗfddД|DГ}nt|Г}ЗfddДИjа|бDГS)Ncєg|] }ИабЫ|ЫЭСqSrйr!й┌.0r%r rr┌ Sєz'RedisCache.get_many..csg|]}Иjа|бСqSr)r&r')r-┌xr rrr.Vє)r┌listrZmgetйrr)Z prefixed_keysrr r┌get_manyQszRedisCache.get_many┌valuecCs`|а|б}|jа|б}|dkr|jj|абЫ|ЫЭ|dН}|S|jj|абЫ|ЫЭ||dН}|S)Nr#й┌namer5йr7r5┌time)r$r&┌dumpsr┌setr!┌setex)rr%r5r"┌dump┌resultrrrr;Xs ¤ zRedisCache.setcCs^|а|б}|jа|б}|jj|абЫ|ЫЭ|dН}|r-|dkr-|jj|абЫ|ЫЭ|dН|S)Nr6r#)r7r9)r$r&r:rZsetnxr!Zexpire)rr%r5r"r=┌createdrrr┌addes zRedisCache.add┌mappingcCsЦ|а|б}|jjddН}|абD]*\}}|jа|б}|dkr,|j|абЫ|ЫЭ|dНq|j|абЫ|ЫЭ||dНq|а б}ddДt |аб|ГDГS)NF)Ztransactionr#r6r8cSsg|]\}}|r|СqSrr)r-┌kZwas_setrrrr.r1z'RedisCache.set_many..)r$rZpipeline┌itemsr&r:r;r!r<┌execute┌zipr))rrAr"┌piper%r5r=┌resultsrrr┌set_manyps zRedisCache.set_manycCєt|jа|абЫ|ЫЭбГSr)┌boolr┌deleter!r(rrrrKБєzRedisCache.deletecsN|sgSИjrЗfddД|DГ}nddД|DГ}Иjj|ОЗfddД|DГS)Ncr*rr+r,r rrr.Иr/z*RedisCache.delete_many..cSsg|]}|СqSrrйr-rBrrrr.Кscsg|] }Иа|бs|СqSr)┌hasrMr rrr.Мs)rrrKr3rr r┌delete_manyДszRedisCache.delete_manycCrIr)rJr┌existsr!r(rrrrNОrLzRedisCache.hascCsHd}|jr|jа|абdб}|r|jj|О}t|ГS|jаб}t|ГS)Nr┌*)rrr)r!rrKZflushdbrJ)r┌statusr)rrr┌clearСs zRedisCache.clearщ┌deltacCs|jj|абЫ|ЫЭ|dНSйN)r7┌amountйr┌incrr!йrr%rUrrr┌incЫrLzRedisCache.inccCs|jj|абЫ|ЫЭ|dНSrVrXrZrrr┌decЮszRedisCache.dec)rrNrr Nr)rT)!┌__name__┌ __module__┌__qualname__┌__doc__r┌_t┌Any┌__annotations__rrr&┌int┌Optionalr┌Union┌Callablerr!r$r┌Listr4r;r@┌DictrHrJrKrOrNrSr[r\rrrrrs\ ∙■¤№√·∙ °&& ■ r)┌typingraZ cachelib.baserZcachelib.serializersrrrrrr┌s