h:ddlZddlZddlZddlmZmZmZmZmZm Z m Z ddl m Z ddl mZmZmZmZddlmZddlmZmZmZmZGddeZGd d eZGd d eZGd deeZGddeZGddeZy)N) AsyncIteratorIterableMappingOptionalSequenceTupleType)Redis) ConnectionConnectionPool EncodableT SSLConnection)AsyncSentinelCommands)ConnectionError ReadOnlyError ResponseError TimeoutErrorc eZdZy)MasterNotFoundErrorN__name__ __module__ __qualname__x/var/www/fastuser/data/www/generator.snapmosaic.io/flask_app/venv/lib/python3.12/site-packages/redis/asyncio/sentinel.pyrrrrc eZdZy)SlaveNotFoundErrorNrrrrrrrrrc reZdZfdZdZdZdZdZ 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 NA4xrcK|\|_|_|j|jjdd{y7w)NF) check_healthretry_socket_connect)r-r.connect_check_healthr#check_connection)r'addresss r connect_toz$SentinelManagedConnection.connect_to*sC& 49''-->>!&(   s:AAAc~K|jry|jjr:|j|jj d{d{y|jj 23d{} |j|d{cS7P7F7$7 #t $rY8wxYw6twN)_readerr# is_masterr8get_master_address rotate_slavesrr)r'slaves r_connect_retryz(SentinelManagedConnection._connect_retry1s <<     ) )//(<(<(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..As'--*r)retrycall_with_retryr@r's rconnectz!SentinelManagedConnection.connect>s3ZZ//    *    s +424FT)disconnect_on_error push_requestdisable_decodingtimeoutrKrLcK t|||||d{S7#t$r<|jjr$|j d{7t dwxYww)N)rMrNrKrLz"The previous master is now a slave)r% read_responserr#r< disconnectr)r'rMrNrKrLr)s rrPz'SentinelManagedConnection.read_responseDsy .!1$7) /   ##-- oo'''%&JKK  s1A*" "A*"2A'AA''A*)FN) rrrr&r1r8r@rJboolrfloatrP __classcell__r)s@rr!r!sm#  % "'#' 04', % &e_  tn rr!c eZdZy)SentinelManagedSSLConnectionNrrrrrWrW_rrrWcTeZdZdZfdZdZfdZdeffd 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<Tr6r#r)getr$rWr!r<r6r%r&weakrefproxyconnection_kwargs service_namesentinel_managermaster_addressslave_rr_counter)r'rarbr(r)s rr&zSentinelConnectionPool.__init__ks%+ZZ ::eU+-. & !" K6 & +=u E "6"4;MM$4G01( 0" $rc d|jjd|jjd|jd|jxrdxsdd S)Nr+r,z (service=(masterr?z))>)r)rrrar<rIs rr1zSentinelConnectionPool.__repr__}sV))*!DNN,C,C+D))*!DNN,Gx,R7+SSV X rc>t|d|_d|_yr:)r%resetrcrd)r'r)s rrizSentinelConnectionPool.resets  " $r connectionc|j xs3|jxr%|j|j|jfk(}|xrt||Sr:)r<rcr-r.r%owns_connection)r'rjcheckr)s rrlz&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 ) rbdiscover_slavesrardrandomrandintlenranger=rr)r'slaves_r?s rr>z$SentinelConnectionPool.rotate_slavess,,<)>)Bc&k(Q%t445    //11 1!#6t7H7H6K!LMMP2"   sF)C9C&BC93C*C(C*C9(C** C63C95C66C9) rrr__doc__r&r1rir rlr=rr>rTrUs@rrYrYcs6%$ % =*= N]NrrYceZdZdZ 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_sentinelsr`_force_master_ip) r'rrrforce_master_ipr`kvhostnamer.s rr&zSentinel.__init__s  "!2!8!8!:Aall9>U1O /#, $  Cxd Cd.B.B C $7 !2 /  sBB"B c Kt|jdd}t|jdd}|rBtj|jj |i|d{}|r|gS|rdSdS|jDcgc]'}t j|j |i|)}}t j|d{}|r|St|S7tcc}w7w)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. onceFreturn_responsesNT) rRr$ruchoicerexecute_commandrCTaskgatherall) r'argsr(rrresponsesentineltasks responsess rrzSentinel.execute_commands FJJvu-.  +=u EF JV]]4>>:JJH  z!'t2U2!NN  LL1114B6B C  "..%00  9~# 1s0A+C+-C".C+ ,C$7C+C)C+$C+c"g}|jD]F}|j|jjdd|jjdHd|jd|jj ddj |dS) Nr-:r.r+r,z (sentinels=[,z])>)rappendr#r`r)rjoin)r'sentinel_addressesrs rr1zSentinel.__repr__s H  % %++==fEFa++==fEFH   q!8!8 9388$678 = rstaterarqcJ|dr |ds|dry|d|jkryy)Nr<is_sdownis_odownFznum-other-sentinelsT)r)r'rras rcheck_master_statezSentinel.check_master_state s5[!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]rrrwrr) r'racollected_errors sentinel_normasterserr error_infos rrpzSentinel.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#ryc`g}|D]&}|ds|dr|j|d|df(|S)z1Remove slaves that are in an ODOWN or SDOWN staterrrr.)r)r'ry slaves_aliver?s r filter_slaveszSentinel.filter_slaves6sM  >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'rarrys rrtzSentinel.discover_slavesAsr 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<dictr`update from_poolr'rarrr(r`r#s r master_forzSentinel.master_forOsP>#{ !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_forvsP0${ !7!78  (/ dXFWX$$_55r)rNN)rrrr{r&rr1rstrrRrrprrrrr rrtr rYr rrrrrr}r}s> 00@  CD!W#!WF w'  % J./ 0    % J./ 0 "$)>T %6%6%[%6 $$:; %6T$)>T 66%[6 $$:; 6rr})rCrur^typingrrrrrrr redis.asyncio.clientr redis.asyncio.connectionr r r rredis.commandsrredis.exceptionsrrrrrrr!rWrYr}rrrrs TTT& 1 /   > >B #