h8ddlZddlZddlZddlmZmZmZmZmZm Z m Z ddl m Z ddl mZmZmZmZddlmZddlmZmZmZmZddlmZGdd eZGd d eZGd d eZGddeeZGddeZGddeZ y)N) AsyncIteratorIterableMappingOptionalSequenceTupleType)Redis) ConnectionConnectionPool EncodableT SSLConnection)AsyncSentinelCommands)ConnectionError ReadOnlyError ResponseError TimeoutError) str_if_bytesc eZdZy)MasterNotFoundErrorN__name__ __module__ __qualname__a/var/www/html/retail-simulation-api/retail/lib/python3.12/site-packages/redis/asyncio/sentinel.pyrrrrc eZdZy)SlaveNotFoundErrorNrrrrr r rrr c veZdZfdZdZfdZdZdZ ddddd ed e e d e e d e effd Z xZ S)SentinelManagedConnectionc P|jd|_t| di|y)Nconnection_poolr)popr$super__init__)selfkwargs __class__s rr'z"SentinelManagedConnection.__init__s%%zz*;< "6"rc|j}d|jjd|jjd|j}|j r!d|j d|j }||z }|dzS)N<. (service=z,host=z,port=z)>)r$r*rr service_namehostport)r(pools host_infos r__repr__z"SentinelManagedConnection.__repr__s}##))*!DNN,C,C+D))* ,  99  6$))=I NA4xrc"K|\|_|_t| d{|jj rI|j dd{t|jd{dk7r tdyy7d777w)NPINGPONGz PING failed) r0r1r&connectr$check_connection send_commandr read_responser)r(addressr*s r connect_toz$SentinelManagedConnection.connect_to*s& 49go    0 0##F+ + +$"4"4"6676A%m44B 1 +6s3!BB .BB B0B 1B B Bc~K|jry|jjr:|j|jj d{d{y|jj 23d{} |j|d{cS7P7F7$7 #t $rY8wxYw6twN)_readerr$ is_masterr>get_master_address rotate_slavesrr )r(slaves r_connect_retryz(SentinelManagedConnection._connect_retry2s <<     ) )//(<(<(O(O(Q"QR R R#33AAC e!%!777 #R R 7& D % $sxA B=B B=B!B=:B6>B#?B6B=B'B%B'B=!B=#B6%B'' B30B=2B33 B=clK|jj|jdd{S7w)Nc,tjdS)Nr)asynciosleep)errors rz3SentinelManagedConnection.connect..Bs '--*r)retrycall_with_retryrFr(s rr9z!SentinelManagedConnection.connect?s3ZZ//    *    s +424FT)disconnect_on_error push_requestdisable_decodingtimeoutrPrQcK t|||||d{S7#t$r<|jjr$|j d{7t dwxYww)N)rRrSrPrQz"The previous master is now a slave)r&r<rr$rB disconnectr)r(rRrSrPrQr*s rr<z'SentinelManagedConnection.read_responseEsy .!1$7) /   ##-- oo'''%&JKK  s1A*" "A*"2A'AA''A*)FN) rrrr'r5r>rFr9boolrfloatr< __classcell__r*s@rr"r"sm# 5 % "'#' 04', % &e_  tn rr"c eZdZy)SentinelManagedSSLConnectionNrrrrr[r[`rrr[cTeZdZdZfdZdZfdZdeffd ZdZ de fd Z xZ S) SentinelConnectionPoolz Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. c ^|jd|jddrtnt|d<|jdd|_|jdd|_t |di|tj||jd<||_ ||_ d|_ d|_y) Nconnection_classsslFrBTr:r$r)getr%r[r"rBr:r&r'weakrefproxyconnection_kwargsr/sentinel_managermaster_addressslave_rr_counter)r(r/rer)r*s rr'zSentinelConnectionPool.__init__ls%+ZZ ::eU+-. & !" K6 & +=u E "6"4;MM$4G01( 0" $rc d|jjd|jjd|jd|jxrdxsdd S)Nr,r-r.(masterrEz))>)r*rrr/rBrOs rr5zSentinelConnectionPool.__repr__~sV))*!DNN,C,C+D))*!DNN,Gx,R7+SSV X rc>t|d|_d|_yr@)r&resetrfrg)r(r*s rrlzSentinelConnectionPool.resets  " $r connectionc|j xs3|jxr%|j|j|jfk(}|xrt||Sr@)rBrfr0r1r&owns_connection)r(rmcheckr*s rroz&SentinelConnectionPool.owns_connectionsRNN" NN Xt22z 6XX <0<>""n4&4#ooo>>>X ?s!)A2A.;A2'A0(A20A2returncK|jj|jd{}|r|j't j dt |dz |_tt |D]6}|jdzt |z|_||j}|8 |jd{td|j77!#t$rY'wxYww)zRound-robin slave balancerNrzNo slave found for ) rediscover_slavesr/rgrandomrandintlenrangerCrr )r(slaves_rEs rrDz$SentinelConnectionPool.rotate_slavess,,<)>)Bc&k(Q%t445 (  //11 1!#6t7H7H6K!LMMP2"   sF)C9C&BC93C*C(C*C9(C** C63C95C66C9) rrr__doc__r'r5rlr rorCrrDrXrYs@rr]r]ds6%$ % =*= N]Nrr]ceZdZdZ ddZdZdZdedede fd Z defd Z d e e deeeeffd Zdedeeeeffd ZeefdedeedeefdZeefdedeedeefdZy)Sentinela~ Redis Sentinel cluster client >>> from redis.sentinel import Sentinel >>> sentinel = Sentinel([('localhost', 26379)], socket_timeout=0.1) >>> master = sentinel.master_for('mymaster', socket_timeout=0.1) >>> await master.set('foo', 'bar') >>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1) >>> await slave.get('foo') b'bar' ``sentinels`` is a list of sentinel nodes. Each node is represented by a pair (hostname, port). ``min_other_sentinels`` defined a minimum number of peers for a sentinel. When querying a sentinel, if it doesn't meet this threshold, responses from that sentinel won't be considered valid. ``sentinel_kwargs`` is a dictionary of connection arguments used when connecting to sentinel instances. Any argument that can be passed to a normal Redis connection can be specified here. If ``sentinel_kwargs`` is not specified, any socket_timeout and socket_keepalive options specified in ``connection_kwargs`` will be used. ``connection_kwargs`` are keyword arguments that will be used when establishing a connection to a Redis server. Nc |5|jDcic]\}}|jds||}}}||_|Dcgc]\}}td||d|jc}}|_||_||_ycc}}wcc}}w)Nsocket_)r0r1r)items startswithsentinel_kwargsr sentinelsmin_other_sentinelsrd) r(rrrrdkvhostnamer1s rr'zSentinel.__init__s  "!2!8!8!:!:Aall9>U1!:  /#, "+$  Cxd Cd.B.B C"+ $7 !2  sA>A>"Bc K|jddt|jdd}d|jvr|jd|r8t j |j j|i|d{y|j Dcgc]'}tj|j|i|)}}tj|d{y7\cc}w7 w)z Execute Sentinel command in sentinel nodes. once - If set to True, then execute the resulting command on a single node at random, rather than across the entire sentinel cluster. keysNonceFT) r%rVrarrxchoicerexecute_commandrITaskgather)r(argsr)rsentineltaskss rrzSentinel.execute_commands  64 FJJvu-. V[[] " JJv  ?&--/??PP P P!% .H 5X55tFvFG . ..%( ( ( Q )s0BC-C$C-,C&C-C+C-&C-c"g}|jD]F}|j|jjdd|jjdHd|jd|jj ddj |dS) Nr0:r1r,r-z (sentinels=[,z])>)rappendr$rdr*rjoin)r(sentinel_addressesrs rr5zSentinel.__repr__sH  % %++==fEFa++==fEFH ' q!8!8 9388$678 = rstater/rtcJ|dr |ds|dry|d|jkryy)NrBis_sdownis_odownFznum-other-sentinelsT)r)r(rr/s rcheck_master_statezSentinel.check_master_states5[!U:%6% :K & '$*B*B BrcKt}t|jD]|\}} |jd{}|j|}|s3|j||sF||jdc|jd<|j|<|d|dfcSd}t|dkDrddj|}td ||7#tt f$r }|j |d|Yd}~d}~wwxYww) z Asks sentinel servers for the Redis master's address corresponding to the service labeled ``service_name``. Returns a pair (address, port) or raises MasterNotFoundError if no master is found. Nz - ripr1z : z, zNo master found for ) list enumeratersentinel_mastersrrrrarrzrr) r(r/collected_errors sentinel_normasterser error_infos rrszSentinel.discover_masters 6%.t~~%> !K  ( 9 9 ;;KK -E00 ENN1%?q!4>>+#>T{E&M11&?  1 $tyy)9:; sK&D CCCD D (A-D CD&D<D DD r|c`g}|D]&}|ds|dr|j|d|df(|S)z1Remove slaves that are in an ODOWN or SDOWN staterrrr1)r)r(r| slaves_aliverEs r filter_slaveszSentinel.filter_slaves$sH EZ E*$5   teFm < =rcK|jD]3} |j|d{}|j |}|s1|cSgS7#tttf$rYPwxYww)z;Returns a list of alive slaves for service ``service_name``N)rsentinel_slavesrrrr)r(r/rr|s rrwzSentinel.discover_slaves/smH '77 EE''/F ' F#]LA  s=A#A AA A#A#A  A A#A  A# redis_classconnection_pool_classc d|d<t|j}|j||||fi|}|j|S)a Returns a redis client instance for the ``service_name`` master. A :py:class:`~redis.sentinel.SentinelConnectionPool` class is used to retrieve the master's address before establishing a new connection. NOTE: If the master's address has changed, any cached connections to the old master are closed. By default clients will be a :py:class:`~redis.Redis` instance. Specify a different class to the ``redis_class`` argument if you desire something different. The ``connection_pool_class`` specifies the connection pool to use. The :py:class:`~redis.sentinel.SentinelConnectionPool` will be used by default. All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Redis connections. TrBdictrdupdate from_poolr(r/rrr)rdr$s r master_forzSentinel.master_for=sP:#{ !7!78  (/ dXFWX$$_55rc d|d<t|j}|j||||fi|}|j|S)a Returns redis client instance for the ``service_name`` slave(s). A SentinelConnectionPool class is used to retrieve the slave's address before establishing a new connection. By default clients will be a :py:class:`~redis.Redis` instance. Specify a different class to the ``redis_class`` argument if you desire something different. The ``connection_pool_class`` specifies the connection pool to use. The SentinelConnectionPool will be used by default. All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Redis connections. FrBrrs r slave_forzSentinel.slave_forbsP0${ !7!78  (/ dXFWX$$_55r)rN)rrrr~r'rr5rstrrVrrsrrrrr rrwr r]r rrrrrrrs> 3,*  CDW#W: w'  % J./ 0    % J./ 0 "$)>T #6#6%[#6 $$:; #6P$)>T 66%[6 $$:; 6rr)!rIrxrbtypingrrrrrrr redis.asyncio.clientr redis.asyncio.connectionr r r rredis.commandsrredis.exceptionsrrrr redis.utilsrrr r"r[r]rrrrrs TTT& 1XX$ /   C CL #