Ih,9ddlZddlZddlZddlmZmZmZmZmZm 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__O/var/www/html/planif/env/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"rcd|jjd|jj}|jr!d|jd|j}||z }|dzS)N<.z,host=z,port=z)>)r*rrhostport)r(s host_infos r__repr__z"SentinelManagedConnection.__repr__s]))*!DNN,C,C+D E 99  6$))=I NA4xrc"K|\|_|_t| d{|jj rI|j dd{t|jd{dk7r tdyy7d777w)NPINGPONGz PING failed) r.r/r&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_retry.s <<     ) )//(<(<(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..>s'--*r)retrycall_with_retryrCr(s rr6z!SentinelManagedConnection.connect;s3ZZ//    *    s +424FT)disconnect_on_error push_requestdisable_decodingtimeoutrMrNcK t|||||d{S7#t$r<|jjr$|j d{7t dwxYww)N)rOrPrMrNz"The previous master is now a slave)r&r9rr$r? disconnectr)r(rOrPrMrNr*s rr9z'SentinelManagedConnection.read_responseAsy .!1$7) /   ##-- oo'''%&JKK  s1A*" "A*"2A'AA''A*)FN) rrrr'r2r;rCr6boolrfloatr9 __classcell__r*s@rr"r"sm#5 % "'#' 04', % &e_  tn rr"c eZdZy)SentinelManagedSSLConnectionNrrrrrXrX\rrrXcTeZdZdZfdZdZfdZdeffd 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_classsslFr?Tr7r$r)getr%rXr"r?r7r&r'weakrefproxyconnection_kwargs service_namesentinel_managermaster_addressslave_rr_counter)r(rbrcr)r*s rr'zSentinelConnectionPool.__init__hs%+ZZ ::eU+-. & !" K6 & +=u E "6"4;MM$4G01( 0" $rc d|jjd|jjd|jd|jxrdxsdd S)Nr,r-z (service=(masterrBz))>)r*rrrbr?rLs rr2zSentinelConnectionPool.__repr__zsV))*!DNN,C,C+D))*!DNN,Gx,R7+SSV X rc>t|d|_d|_yr=)r&resetrdre)r(r*s rrjzSentinelConnectionPool.resets  " $r connectionc|j xs3|jxr%|j|j|jfk(}|xrt||Sr=)r?rdr.r/r&owns_connection)r(rkcheckr*s rrmz&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 ) rcdiscover_slavesrbrerandomrandintlenranger@rr )r(slaves_rBs rrAz$SentinelConnectionPool.rotate_slavess,,<)>)Bc&k(Q%t445    //11 1!#6t7H7H6K!LMMP2"   sF)C9C&BC93C*C(C*C9(C** C63C95C66C9) rrr__doc__r'r2rjr rmr@rrArUrVs@rrZrZ`s6%$ % =*= N]NrrZceZdZdZ 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||}}}||_|D cgc]\}} td|| d|jc} }|_||_||_||_ycc}}wcc} }w)Nsocket_)r.r/r)items startswithsentinel_kwargsr sentinelsmin_other_sentinelsra_force_master_ip) r(rrrforce_master_iprakvhostnamer/s rr'zSentinel.__init__s  "!2!8!8!:Aall9>U1O /#, $  Cxd Cd.B.B C $7 !2 /  sBB"B c Kt|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. onceFNT) rSr^keysr%rvchoicerexecute_commandrFTaskgather)r(argsr)rsentineltaskss rrzSentinel.execute_commands FJJvu-. V[[] " JJv  ?&--/??PP P P!% 5X55tFvFGE..%( ( ( Q )s0A3C5C6C ,C5C C CCc"g}|jD]F}|j|jjdd|jjdHd|jd|jj ddj |dS) Nr.:r/r,r-z (sentinels=[,z])>)rappendr$rar*rjoin)r(sentinel_addressesrs rr2zSentinel.__repr__s H  % %++==fEFa++==fEFH   q!8!8 9388$678 = rstaterbrrcJ|dr |ds|dry|d|jkryy)Nr?is_sdownis_odownFznum-other-sentinelsT)r)r(rrbs rcheck_master_statezSentinel.check_master_states5[!U:%6% :K & '$*B*B BrcJKt}t|jD]\}} |jd{}|j|}|s3|j||sF||jdc|jd<|j|<|j |jn|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 - ripr/z : z, zNo master found for ) list enumeratersentinel_mastersrrrr^rrrxrr) r(rbcollected_errors sentinel_normasterserr error_infos rrqzSentinel.discover_masters@ 6%.t~~%> ) !K  ( 9 9 ;;KK -E00 ENN1%?q!4>>+#>,,8))t 5=((' )*  1 $tyy)9:; sK&D#C1C/C1D#D#(BD#/C11D DD#D  D#rzc`g}|D]&}|ds|dr|j|d|df(|S)z1Remove slaves that are in an ODOWN or SDOWN staterrrr/)r)r(rz slaves_aliverBs r filter_slaveszSentinel.filter_slaves'sM  >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(rbrrzs rruzSentinel.discover_slaves2sr H '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. Sentinel client will detect failover and reconnect Redis clients automatically. 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. Tr?dictraupdate from_poolr(rbrrr)rar$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. Fr?rrs r slave_forzSentinel.slave_forgsP0${ !7!78  (/ dXFWX$$_55r)rNN)rrrr|r'rr2rstrrSrrqrrrrr rrur rZr rrrrrr~r~s> 00(  CD!W#!WF w'  % J./ 0    % J./ 0 "$)>T %6%6%[%6 $$:; %6T$)>T 66%[6 $$:; 6rr~)!rFrvr_typingrrrrrrr redis.asyncio.clientr redis.asyncio.connectionr r r rredis.commandsrredis.exceptionsrrrr redis.utilsrrr r"rXrZr~rrrrs TTT& 1XX$ /   ? ?D #