o QDi+@sHddlZddlZddlZddlZddlmZddlmZmZddl m Z ddl m Z m Z mZmZddlmZddlmZmZmZddlmZdd lmZdd lmZdd lmZdd lmZdd lm Z!ddl"m#Z#m$Z$m%Z%m&Z&m'Z'ddl(m)Z)ddl*m+Z+m,Z,ddl-m.Z.ee!eej/fZ0e1dZ2de3de3fddZ4GdddZ5dS)N) OrderedDict)IterableIterator)suppress)AnyOptionalUnioncast)settings)DEFAULT_TIMEOUT BaseCache get_key_func)ImproperlyConfigured) import_string)Redis)ConnectionError) ResponseError) TimeoutError) AbsExpiryT EncodableTExpiryTKeyTPatternT)pool)CompressorErrorConnectionInterrupted)CacheKeyz([*?[])sreturncCs td|S)Nz[\1]) special_resub)rr!T/var/www/Datamplify/venv/lib/python3.10/site-packages/django_redis/client/default.py glob_escape's r#c@sr eZdZdeeefdeddfddZdede fdd Z de fd d Z dd e de e edefddZ dd e de e edefddZ dd e de e edeeeffddZddedefddZddede eddfddZeddddfdedede ede ede ed e d!e de fd"d#Z $  dded%ede ede edef d&d'Zeddfdedede ede ede ede f d(d)Z   dded*e ede ede edef d+d,Z ddede ede ede fd-d.Z  ddedede ede ede f d/d0Z  ddedede ede ede f d1d2Z  dded3e!de ede ede f d4d5Z"  dded3e!de ede ede f d6d7Z#   8   ddede ede ed9ed:e d;e ede edZ$   ddede ed?e ede edef d@dAZ%    ddBede ed?e ede edCe edef dDdEZ&  ddFe'ede ede edefdGdHZ(dde eddfdIdJZ)dedefdKdLZ*dede+e,effdMdNZ- ddOedPe de+e edeffdQdRZ.  ddFe'ede ede ede/fdSdTZ0eddfdUeeefde ede ede eddf dVdWZ1 $   dded%ede ede edXe def dYdZZ2 $   dded%ede ede edXe def d[d\Z3 $  dded%ede ede edef d]d^Z4 ddede ede ede efd_d`Z5 ddede ede ede efdadbZ6 ddede ede ede fdcddZ7   ddeedCe ede ede ede8ef dfdgZ9 ddeede ede ede efdhdiZ: ddede ed?e edefdjdkZ; ddBede ed?e edefdldmZdddndFede ede ede?jefdtduZ@ddddvdwedFedxe edye ede edef dzd{ZAdddndFede ede ede?jefd|d}ZBdddndwedFede ede edef d~dZCdddndede ede ede e fddZD  ddedede ede ede f ddZE  ddede ede ede?jefddZF  ddededede ede ede f ddZG   ddede ede ede ede+e?jeff ddZH   ddede ede ede ede+e eff ddZIdddndedede ede edef ddZJ   ddede ede ede ede ede?jef ddZK   ddede ede ede ede ede8ef ddZLdddndFede ede ede?jefddZMdddndedFede ede edef ddZNdddZOdddZPeddfdede ede ede ede f ddZQ  ddededede ede edef ddZR  ddedede ede edef ddZS ddede edefddZT ddede ede efddZU  ddedede ede ede f ddZVdS) DefaultClientparamsbackendrNc Cs||_||_||_t|dpd|_|jsd}t|t|jtt t fs,|j d|_dgt |j|_ |di|_|jdd|_|jdd }t|}|jd d }t|}||jd |_||jd |_tj|jd |_dS) NREVERSE_KEY_FUNCTIONz%django_redis.util.default_reverse_keyzMissing connections string,OPTIONSREPLICA_READ_ONLYT SERIALIZERz0django_redis.serializers.pickle.PickleSerializer COMPRESSOR4django_redis.compressors.identity.IdentityCompressor)options)_backend_server_paramsr get reverse_keyr isinstancelisttuplesetsplitlen_clients_options_replica_read_onlyr _serializer _compressorrget_connection_factoryconnection_factory) selfserverr%r& error_messageserializer_pathserializer_clscompressor_pathcompressor_clsr!r!r"__init__,s4 zDefaultClient.__init__keycCs ||SN)has_key)rArIr!r!r" __contains__Ps zDefaultClient.__contains__cCs|jdddkS)Nr,r-)r;r2rAr!r!r"_has_compression_enabledSs z&DefaultClient._has_compression_enabledTwritetriedcsvdurgr%tt|jkr%fddtdt|jD}t|S|s.t|jdkr0dStdt|jdS)z Return a next index for read client. This function implements a default behavior for get a next read client for a replication setup. Overwrite this function if you want a specific behavior. Ncsg|]}|vr|qSr!r!).0irPr!r" isz7DefaultClient.get_next_client_index..r)r9r0rangerandomchoicerandint)rArOrP not_triedr!rSr"get_next_client_index[s  z#DefaultClient.get_next_client_indexcCs6|j||d}|j|dur|||j|<|j|Sz Method used for obtain a raw redis client. This function is used by almost all cache backend operations for obtain a native redis client/connection instance. rOrPNr[r:connectrArOrPindexr!r!r" get_clientqs  zDefaultClient.get_clientcCs:|j||d}|j|dur|||j|<|j||fSr\r^r`r!r!r"get_client_with_indexs z#DefaultClient.get_client_with_indexrracCs|j|j|S)z Given a connection index, returns a new raw redis client/connection instance. Index is used for replication setups and indicates that connection string should be used. In normal setups, index is 0. )r@r_r0)rArar!r!r"r_szDefaultClient.connectclientcCs.|dur |j|}|dur|j|dSdS)zK delegates the connection factory to disconnect the client N)r:r@ disconnect)rArardr!r!r"res  zDefaultClient.disconnectFvaluetimeoutversionnxxxc Cs |j||d}||} |tur|jj}|} g} z?|dur'|jd| d\}} |durLt|d}|dkrL|rA|j|||d WSt|j |||dWSt|j || |||d WSt y} z!| s{|j s{t | t |jkr{| | d}WYd} ~ qt|d | d} ~ ww) z Persist a value to the cache, and set an optional expiration time. Also supports optional nx parameter. If set to True - will use redis setnx instead of set. rhTNr]rrhrd)rdrh)ripxrj connection)make_keyencoder r/default_timeoutrcintrKbooldeleter7_main_exceptionsr<r9r0appendr)rArIrfrgrhrdrirjnkeynvalueoriginal_clientrPraer!r!r"r7s:     zDefaultClient.setrUdeltac Cs|dur |jdd}|dur|jj}|||}|j|||d}z |j|||d}Wnty<}zt|d|d}~ww|durKd|d} t| t |t r\|j| ||d} n |j|||d} |j | |||d |j ||d ||S) zh Adds delta to the cache version for the supplied key. Returns the new version. NTrOrmroKey ' ' not foundrk)rgrd)rd)rbr/rhrqr2ttlrwr ValueErrorr4r original_keyr7rv) rArIr}rhrdold_keyrfrr|rCnew_keyr!r!r" incr_versions*     zDefaultClient.incr_versioncCs|j|||||ddS)z Add a value to the cache, failing if the key already exists. Returns ``True`` if the object was added, ``False`` if not. T)rhrdri)r7)rArIrfrgrhrdr!r!r"add s zDefaultClient.adddefaultc Csl|dur |jdd}|j||d}z||}Wnty*}zt|d|d}~ww|dur1|S||S)zv Retrieve a value from the cache. Returns decoded value if key is found, the default if not. NFr~rkro)rbrqr2rwrdecode)rArIrrhrdrfr|r!r!r"r2s   zDefaultClient.getcCs,|dur |jdd}|j||d}||SNTr~rk)rbrqpersistrArIrhrdr!r!r"r3s  zDefaultClient.persistcCs>|tur|jj}|dur|jdd}|j||d}|||Sr)r r/rsrbrqexpirerArIrgrhrdr!r!r"r=s   zDefaultClient.expirecCsB|tur|jj}|dur|jdd}|j||d}t|||Sr)r r/rsrbrqrupexpirerr!r!r"rNs  zDefaultClient.pexpirewhencCs2|dur |jdd}|j||d}t|||Sz Set an expire flag on a ``key`` to ``when``, which can be represented as an integer indicating unix time or a Python datetime object. NTr~rk)rbrqru pexpireatrArIrrhrdr!r!r" pexpire_at_s zDefaultClient.pexpire_atcCs.|dur |jdd}|j||d}|||Sr)rbrqexpireatrr!r!r" expire_atqs  zDefaultClient.expire_at皙?sleepblockingblocking_timeout thread_localc Cs8|dur |jdd}|j||d}|j||||||dS)NTr~rk)rgrrrr)rbrqlock) rArIrhrgrrrrdrr!r!r"rs zDefaultClient.lockprefixc CsR|dur |jdd}z ||j|||dWSty(}zt|d|d}~ww)z. Remove a key from the cache. NTr~rhrro)rbrvrqrwr)rArIrhrrdr|r!r!r"rvs  zDefaultClient.deletepatternitersizec Cs|dur |jdd}|j|||d}z d}|}|j||dD] }|||d7}q ||WStyD} zt|d| d} ~ ww) z3 Remove all keys matching pattern. NTr~rrmatchcountrUro)rb make_patternpipeline scan_iterrvexecuterwr) rArrhrrdrrrrIr|r!r!r"delete_patterns    zDefaultClient.delete_patternkeysc sb|dur jdd}fdd|D}|sdSz|j|WSty0}zt|d|d}~ww)z/ Remove multiple keys at once. NTr~cg|] }j|dqSrkrqrQkrArhr!r"rTz-DefaultClient.delete_many..rro)rbrvrwr)rArrhrdr|r!rr" delete_manys   zDefaultClient.delete_manyc CsH|dur |jdd}z|WdSty#}zt|d|d}~ww)z' Flush all cache keys. NTr~ro)rbflushdbrwr)rArdr|r!r!r"clears  zDefaultClient.clearc Cshzt|}W|Sttfy3tt|j|}Wdn1s%wY|j|}Y|Sw)z) Decode the given value. N) rtr TypeErrorrrr> decompressr=loadsrArfr!r!r"rs  zDefaultClient.decodecCs0t|ts t|ts|j|}|j|S|S)z) Encode the given value. )r4rurtr=dumpsr>compressrr!r!r"rrs  zDefaultClient.encoderesult covert_to_setcsH|durdSt|tr|rfdd|DSfdd|DS|S)Nch|]}|qSr!rrQrfrMr!r" z8DefaultClient._decode_iterable_result..cg|]}|qSr!rrrMr!r"rTrz9DefaultClient._decode_iterable_result..)r4r5r)rArrr!rMr"_decode_iterable_results  z%DefaultClient._decode_iterable_resultc s|dur jdd}|stSt}tfdd|D}z|j|}Wnty7}zt|d|d}~wwt||D]\}} | durFq=| |||<q=|S)z% Retrieve many keys. NFr~c3s"|] }j|d|fVqdS)rkNrrrr!r" $s z)DefaultClient.get_many..ro)rbrmgetrwrzipr) rArrhrdrecovered_datamap_keysresultsr|rIrfr!rr"get_manys"  zDefaultClient.get_manydatac Csv|dur |jdd}z|}|D]\}}|j|||||dq|WdSty:}zt|d|d}~ww)a" Set a bunch of values in the cache at once from a dict of key/value pairs. This is much more efficient than calling set() multiple times. If timeout is given, that timeout will be used for the key; otherwise the default cache timeout will be used. NTr~rmro)rbritemsr7rrwr) rArrgrhrdrrIrfr|r!r!r"set_many1s  zDefaultClient.set_manyignore_key_checkc Cs |dur |jdd}|j||d}zaz!|sd}nd}||d||}|dur0d|d}t|WW|Styr} z3|j|||d } | d krRd|d}t|| |j|||d |}|j|||| |d WYd} ~ W|Sd} ~ wwty} zt |d | d} ~ ww) NTr~rkz local exists = redis.call('EXISTS', KEYS[1]) if (exists == 1) then return redis.call('INCRBY', KEYS[1], ARGV[1]) else return false end zW return redis.call('INCRBY', KEYS[1], ARGV[1]) rUrrrm)rhrgrdro) rbrqevalrrrr2r7rwr) rArIr}rhrdrluarfrCr|rgr!r!r"_incrJs8      zDefaultClient._incrcCs|j|||||dS)z Add delta to value in the cache. If the key does not exist, raise a ValueError exception. if ignore_key_check=True then the key will be created and set to the delta value by default. )rIr}rhrdrr)rArIr}rhrdrr!r!r"incrs zDefaultClient.incrcCs|j|| ||dS)zx Decreace delta to value in the cache. If the key does not exist, raise a ValueError exception. )rIr}rhrdr)rArIr}rhrdr!r!r"decrs zDefaultClient.decrcCb|dur |jdd}|j||d}||sdS||}|dkr#|S|dkr)dS|dkr/dSdS)z Executes TTL redis command and return the "time-to-live" of specified key. If key is a non volatile key, it returns None. NFr~rkrr)rbrqexistsrrArIrhrdtr!r!r"r   zDefaultClient.ttlcCr)z Executes PTTL redis command and return the "time-to-live" of specified key. If key is a non volatile key, it returns None. NFr~rkrrr)rbrqrpttlrr!r!r"rrzDefaultClient.pttlc CsX|dur |jdd}|j||d}z||dkWSty+}zt|d|d}~ww)z% Test if key exists. NFr~rkrUro)rbrqrrwr)rArIrhrdr|r!r!r"rKs  zDefaultClient.has_keysearchccsL|dur |jdd}|j||d}|j||dD] }||VqdS)zo Same as keys, but uses redis >= 2.8 cursors for make memory efficient keys iteration. NFr~rkr)rbrrr3r)rArrrdrhritemr!r!r" iter_keyss zDefaultClient.iter_keysc sb|dur jdd}j||d}z fdd||DWSty0}zt|d|d}~ww)z Execute KEYS command and return matched results. Warning: this can return huge number of results, in this case, it strongly recommended use iter_keys for it. NFr~rkcg|] }|qSr!r3rrrMr!r"rTrz&DefaultClient.keys..ro)rbrrrwr)rArrhrdrr|r!rMr"rs  zDefaultClient.keyscCsBt|tr|S|dur|jj}|dur|jj}t|j|||SrJ)r4rr/ key_prefixrhkey_func)rArIrhrr!r!r"rq s zDefaultClient.make_keycCsVt|tr|S|dur|jj}t|}|dur|jj}tt|}t|j|||SrJ)r4rr/rr#rhstrr)rArrhr version_strr!r!r"rs  zDefaultClient.make_patternrmvaluescJ|dur jdd}j||d}fdd|D}t|j|g|RS)NTr~rkcrr!rrrrMr!r"rT5rz&DefaultClient.sadd..)rbrqrtsadd)rArIrhrdrencoded_valuesr!rMr"r*  zDefaultClient.saddcCs0|dur |jdd}|j||d}t||SNFr~rk)rbrqrtscardrr!r!r"r8s zDefaultClient.scardc@|dur jdd}fdd|D}fdd|j|DS)NFr~crrrrQrIrr!r"rTMrz'DefaultClient.sdiff..crr!rrrMr!r"rNrz&DefaultClient.sdiff..)rbsdiffrArhrdrnkeysr!rr"rD zDefaultClient.sdiff) version_dest version_keysrddestrrcsL|dur jdd}j||d}fdd|D}t|j|g|RS)NTr~rkcrrrrrArr!r"rT\rz,DefaultClient.sdiffstore..)rbrqrt sdiffstore)rArrrrdrrr!rr"rPs  zDefaultClient.sdiffstorecr)NFr~crrrrrr!r"rThrz(DefaultClient.sinter..crr!rrrMr!r"rirz'DefaultClient.sinter..)rbsinterrr!rr"r_rzDefaultClient.sintercL|dur jdd}j|d}fdd|D}t|j|g|RS)NTr~rkcrrrrrr!r"rTvrz-DefaultClient.sinterstore..)rbrqrt sinterstore)rArrhrdrrr!rr"rk  zDefaultClient.sinterstorecsP|dur jdd}j||d}fdd|D}dd|j|g|RDS)NFr~rkcrr!rrQmemberrMr!r"rTrz,DefaultClient.smismember..cSsg|]}t|qSr!)rurr!r!r"rTs)rbrq smismember)rArIrhrdmembersencoded_membersr!rMr"rys  zDefaultClient.smismemberrcCs<|dur |jdd}|j||d}||}t|||Sr)rbrqrrru sismember)rArIrrhrdr!r!r"rs   zDefaultClient.sismembercs:|dur jdd}j||d}fdd||DS)NFr~rkcrr!rrrMr!r"rrz)DefaultClient.smembers..)rbrqsmembersrr!rMr"rs zDefaultClient.smemberssource destinationcCsH|dur |jdd}|j||d}||}||}t||||Sr)rbrqrrrusmove)rArrrrhrdr!r!r"rs    zDefaultClient.smovercCs8|dur |jdd}|j||d}|||}||Sr)rbrqspopr)rArIrrhrdryrr!r!r"rs    zDefaultClient.spopcCs<|dur |jdd}|j||d}|||}|j|ddS)NFr~rk)r)rbrq srandmemberr)rArIrrhrdrr!r!r"rs   zDefaultClient.srandmemberrcr)NTr~rkcrr!rrrMr!r"rTrz&DefaultClient.srem..)rbrqrtsrem)rArIrhrdrnmembersr!rMr"rrzDefaultClient.srem rc str |r d}t||durjdd}j||d}|j||r*td|nd|d\}}fdd|DS) N.Using match with compression is not supported.Fr~rkrrcrr!rrrMr!r"rrz&DefaultClient.sscan..)rNrrbrqsscanr rr) rArIrrrhrderr_msgcursorrr!rMr"r s   zDefaultClient.sscanccsv|r |r d}t||dur|jdd}|j||d}|j||r+td||nd|dD]}||Vq0dS)Nr Fr~rkrr)rNrrbrq sscan_iterr rrr)rArIrrrhrdr rfr!r!r"rs   zDefaultClient.sscan_itercr)NFr~crrrrrr!r"rTrz(DefaultClient.sunion..crr!rrrMr!r"rrz'DefaultClient.sunion..)rbsunionrr!rr"r rzDefaultClient.sunioncr)NTr~rkcrrrrrr!r"rT"rz-DefaultClient.sunionstore..)rbrqrt sunionstore)rArrhrdr encoded_keysr!rr"rrzDefaultClient.sunionstorecCs*|jdttdd}|r|dSdS)NCLOSE_CONNECTIONDJANGO_REDIS_CLOSE_CONNECTIONF)r;r2getattrr do_close_clients)rA close_flagr!r!r"close%s  zDefaultClient.closecCs4t|j}t|D]}|j|dq dg||_dS)zC default implementation: Override in custom client )raN)r9r:rVre)rA num_clientsidxr!r!r"r-s  zDefaultClient.do_close_clientscCsd|tur|jj}|dur|jdd}|j||d}|dur$t||St|d}t|||S)z2 Sets a new expiration for a key. NTr~rkrl) r r/rsrbrqrurrtrrr!r!r"touch6s   zDefaultClient.touchnamecCs>|dur |jdd}|j||d}||}t||||S)zu Set the value of hash name at key to value. Returns the number of fields added to the hash. NTr~rk)rbrqrrrthset)rArrIrfrhrdryrzr!r!r"rOs   zDefaultClient.hsetcC2|dur |jdd}|j||d}t|||S)zi Remove keys from hash name. Returns the number of fields deleted from the hash. NTr~rk)rbrqrthdelrArrIrhrdryr!r!r"ras zDefaultClient.hdelcCs"|dur |jdd}t||S)z: Return the number of items in hash name. NFr~)rbrthlen)rArrdr!r!r"r!qs zDefaultClient.hlenc sT|dur jdd}z fdd||DWSty)}zt|d|d}~ww)z5 Return a list of keys in hash name. NFr~crr!rrrMr!r"rTrz'DefaultClient.hkeys..ro)rbhkeysrwr)rArrdr|r!rMr"r"}s  zDefaultClient.hkeyscCr)zE Return True if key exists in hash name, else False. NFr~rk)rbrqruhexistsr r!r!r"r#s zDefaultClient.hexists)TN)r)rN)rUNN)NNN)NN)NNrTNNT)NNNNrJ)T)rUNNF)Nr NN)rN)W__name__ __module__ __qualname__dictrrr rHrrurLrNrr5rtr[rrbr6rcr_rer rfloatr7rrr2rrrrrrrrrvrrrrrrbytesrrrrrrrrrrrrKrrrrqrrrbuiltinsrrrrrrrrrrrr rrrrrrrrr!r"r#r!r!r!r"r$+sR$         < +          !      "   9                                   r$)6r*rWresocket collectionsrcollections.abcrr contextlibrtypingrrrr django.confr django.core.cache.backends.baser r r django.core.exceptionsrdjango.utils.module_loadingrredisrredis.exceptionsrRedisConnectionErrorrrRedisTimeoutError redis.typingrrrrr django_redisrdjango_redis.exceptionsrrdjango_redis.utilrrgrwcompilerrr#r$r!r!r!r"s8