Ë V³h ãó —ddlmZddlZddlmZddlmZddlmZedd¬«ed d ¬«ed d ¬«Gd „de««««Z y)é)Ú annotationsN)Úversionchanged)ÚVersion)Ú RedisStoragez3.14.0z_ Dropped support for the :pypi:`redis-py-cluster` library which has been abandoned/deprecated. )ÚversionÚreasonz2.5.0aa Cluster support was provided by the :pypi:`redis-py-cluster` library which has been absorbed into the official :pypi:`redis` client. By default the :class:`redis.cluster.RedisCluster` client will be used however if the version of the package is lower than ``4.2.0`` the implementation will fallback to trying to use :class:`rediscluster.RedisCluster`. z4.3ztAdded support for using the redis client from :pypi:`valkey` if :paramref:`uri` has the ``valkey+cluster://`` schemac󚇗eZdZUdZddgZ ddiZded< ed«ed «d œZe jd f dˆfd „ Z dd „Z ˆxZ S)ÚRedisClusterStoragez¦ Rate limit storage with redis cluster as backend Depends on :pypi:`redis` (or :pypi:`valkey` if :paramref:`uri` starts with ``valkey+cluster://``). z redis+clusterzvalkey+clusterÚmax_connectionsièzdict[str, float | str | bool]ÚDEFAULT_OPTIONSz4.2.0z6.0)ÚredisÚvalkeyFc ó•—tjj|«}i}|jr|j|d<|jr|j|d<|j j d«dz}g}|j |djd«D]2} | jd«\} } |j| t| «f«Œ4||_ d|_ |jd«rdnd |_ i|j¥|¥|¥} |j|jj |_|D cgc]%} |j"j$j&| Ž‘Œ'}} |jd k(r.|j"j$j(d d |i| ¤Ž|_ n-|j"j$j*d d |i| ¤Ž|_ |jsJ‚|j-|«t/t0|f||fi|¤Žycc} w) a¸ :param uri: url of the form ``redis+cluster://[:password]@host:port,host:port`` If the uri scheme is ``valkey+cluster`` the implementation used will be from :pypi:`valkey`. :param key_prefix: the prefix for each key created in redis :param wrap_exceptions: Whether to wrap storage exceptions in :exc:`limits.errors.StorageError` before raising it. :param options: all remaining keyword arguments are passed directly to the constructor of :class:`redis.cluster.RedisCluster` :raise ConfigurationError: when the :pypi:`redis` library is not available or if the redis cluster cannot be reached. ÚusernameÚpasswordú@éNú,ú:rr Ú startup_nodes©)ÚurllibÚparseÚurlparserrÚnetlocÚfindÚsplitÚappendÚintÚ key_prefixÚstorageÚ startswithÚ target_serverr Ú dependenciesÚmoduleÚ dependencyÚclusterÚ ClusterNodeÚ RedisClusterÚ ValkeyClusterÚinitialize_storageÚsuperrÚ__init__)ÚselfÚurir Úwrap_exceptionsÚoptionsÚparsedÚ parsed_authÚsepÚ cluster_hostsÚlocÚhostÚportÚmerged_optionsÚcrÚ __class__s €új/var/www/catia.catastroantioquia-mas.com/tasa/lib/python3.12/site-packages/limits/storage/redis_cluster.pyr-zRedisClusterStorage.__init__8sàø€ô*—‘×&Ñ& sÓ+ˆØ57ˆ à ?Š?Ø&,§o¡oˆK˜ Ñ #Ø ?Š?Ø&,§o¡oˆK˜ Ñ #àm‰m× Ñ  Ó%¨Ñ)ˆØˆ Ø—=‘=  Ð&×,Ñ,¨SÓ1ò 4ˆCØŸ™ 3›‰JˆD$Ø × Ñ  $¬¨D« Ð!2Õ 3ð 4ð%ˆŒØˆŒ Ø),¯©¸Ô)A™XÀwˆÔØK˜D×0Ñ0ÐK°KÐKÀ7ÐKˆØ×+Ñ+¨D×,>Ñ,>Ñ?×FÑFˆŒØJWÖXÀQÐ<˜Ÿ™×0Ñ0×<Ñ<¸aÒ@ÐXˆ ÐXØ × Ñ  Ò (Ø?˜4Ÿ?™?×2Ñ2×?Ñ?ñØ+ðØ/=ñˆDLðA˜4Ÿ?™?×2Ñ2×@Ñ@ñØ+ðØ/=ñˆDŒLð|Š|Ј|Ø ×Ñ Ô$Ü Œl˜DÑ*¨3°ÑKÀ7ÓKùòYsÄ2*G=c ó@—|jd«}d}|jj«D]h}|jj|«}|j |«}|t |Dcgc]"}|j |jd««‘Œ$c}«z }Œj|Scc}w)aé Redis Clusters are sharded and deleting across shards can't be done atomically. Because of this, this reset loops over all keys that are prefixed with :paramref:`RedisClusterStorage.prefix` and calls delete on them one at a time. .. warning:: This operation was not tested with extremely large data sets. On a large production based system, care should be taken with its usage as it could be slow on very large data setsÚ*rzutf-8)Ú prefixed_keyr!Ú get_primariesÚget_redis_connectionÚkeysÚsumÚdeleteÚdecode)r.ÚprefixÚcountÚprimaryÚnoderBÚks r<ÚresetzRedisClusterStorage.resetns’€ð×"Ñ" 3Ó'ˆØˆØ—|‘|×1Ñ1Ó3ò IˆGØ—<‘<×4Ñ4°WÓ=ˆDØ—9‘9˜VÓ$ˆDØ ”SÀ$ÖG¸Q˜$Ÿ+™+ a§h¡h¨wÓ&7Õ8ÒGÓHÑ H‰Eð Iðˆ ùòHsÁ''B ) r/Ústrr rLr0Úboolr1zfloat | str | boolÚreturnÚNone)rNz int | None)Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚSTORAGE_SCHEMEr Ú__annotations__rÚ DEPENDENCIESrÚPREFIXr-rKÚ __classcell__)r;s@r<r r s›ø…ñ2ð&Ð'7Ð8€NØ.ð ˜4ð6€OÐ2óðIñ˜Ó!Ù˜%“.ñ€Lð'×-Ñ-Ø %ð 4Là ð4Lðð4Lðð 4Lð &ð 4Lð õ 4L÷lór ) Ú __future__rrÚdeprecated.sphinxrÚpackaging.versionrÚlimits.storage.redisrr rrYr<úr^snðÝ"ã å,Ý%å-ñØ ð ôñØ ð ô ñØ ð Côô]˜,ó]óó óñ0]rY