Pf8@ddlZddlZddlZddlmZmZmZmZmZm Z m Z ddl m Z ddl mZmZmZmZddlmZddlmZmZmZmZddlmZGdd eZGd d eZGd d eZGddeeZGddeZGddeZ dS)N) AsyncIteratorIterableMappingOptionalSequenceTupleType)Redis) ConnectionConnectionPool EncodableT SSLConnection)AsyncSentinelCommands)ConnectionError ReadOnlyError ResponseError TimeoutError) str_if_bytesceZdZdS)MasterNotFoundErrorN__name__ __module__ __qualname__H/var/www/html/env/lib/python3.11/site-packages/redis/asyncio/sentinel.pyrrDrrceZdZdS)SlaveNotFoundErrorNrrrrr r rrr c eZdZfdZdZfdZdZdZ dddd d ed e e d e e d e effdZ xZ S)SentinelManagedConnectionc n|d|_tjdi|dS)Nconnection_poolr)popr$super__init__)selfkwargs __class__s rr'z"SentinelManagedConnection.__init__s;%zz*;<<""6"""""rc|j}d|jjd|jjd|j}|jrd|jd|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}# ,) , ,DN,C , ,) , ,  9 ===$)==I NA4xrc<K|\|_|_td{V|jjrU|dd{Vt|d{VdkrtddSdS)NPINGPONGz PING failed) r0r1r&connectr$check_connection send_commandr read_responser)r(addressr*s r connect_toz$SentinelManagedConnection.connect_to*s& 49ggoo   0 5##F++ + + + + + + +$"4"4"6"6666666776AA%m444 5 5AArcPK|jrdS|jjr:||jd{Vd{VdS|j23d{V} ||d{VcS#t $rY1wxYw6tN)_readerr$ is_masterr>get_master_address rotate_slavesrr )r(slaves r_connect_retryz(SentinelManagedConnection._connect_retry2s <  F   ) %//(<(O(O(Q(Q"Q"Q"Q"Q"Q"QRR R R R R R R R R R#3AACC       e!%!7!7777777777&H D % $s+B 3B BBcTK|j|jdd{VS)Nc*tjdS)Nr)asynciosleep)errors rz3SentinelManagedConnection.connect..Bs'-**r)retrycall_with_retryrFr(s rr9z!SentinelManagedConnection.connect?sJZ//   * *         rFNT)disconnect_on_error push_requestdisable_decodingtimeoutrPrQcK t||||d{VS#t$r7|jjr)|d{Vt dwxYw)N)rRrSrPrQz"The previous master is now a slave)r&r<rr$rB disconnectr)r(rRrSrPrQr*s rr<z'SentinelManagedConnection.read_responseEs ..!1$7) /     #- L oo'''''''''%&JKKK  s *0AA1)FN) rrrr'r5r>rFr9boolrfloatr< __classcell__r*s@rr"r"s#####   55555 % % %   "'#' 04', % &e_  tn rr"ceZdZdS)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 |d|ddrtnt|d<|dd|_|dd|_t jdi|tj ||j d<||_ ||_ d|_ d|_dS) 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 zz%'' + ( (* & & !"  K66 & +=u E E""6"""4;M$4G4G01( 0" $rc dd|jjd|jjd|jd|jrdpdd S)Nr,r-r.(masterrEz))>)r*rrr/rBrOs rr5zSentinelConnectionPool.__repr__|sf X) X XDN,C X X) X X,0N,Gx,R7 X X X rcdtd|_d|_dSr@)r&resetrfrg)r(r*s rrlzSentinelConnectionPool.resets*  " $r connectionc|j p|jo|j|j|jfk}|o t |Sr@)rBrfr0r1r&owns_connection)r(rmcheckr*s rroz&SentinelConnectionPool.owns_connectionsON" N Xt2z 6XX <00<< ?"n44&4#ooo>>>>>>>>>rreturncK|j|jd{V}|r|j*t jdt |dz |_tt |D]3}|jdzt |z|_||j}|WV4 |d{VWVn#t$rYnwxYwtd|j)zRound-robin slave balancerNrzNo slave found for ) rediscover_slavesr/rgrandomrandintlenrangerCrr )r(slaves_rEs rrDz$SentinelConnectionPool.rotate_slavess!,<)Bc&kk(Q%t45  //11111111 1 1 1 1 1"    D  !Lt7H!L!LMMMs,C CC) rrr__doc__r'r5rlr rorCrrDrXrYs@rr]r]ds%%%%%    %%%%% =*====== N]NNNNNNNNrr]ceZdZdZ ddZdZdZdeded e fd Z defd Z d e e d eeeeffd Zded eeeeffdZeefdedeedeefdZeefdedeedeefdZdS)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. rNc |d|D}|_fd|D_|_|_dS)NcDi|]\}}|d||S)socket_) startswith).0kvs r z%Sentinel.__init__..s?Aall9>U>U1rc>g|]\}}td||djS))r0r1r)r sentinel_kwargs)rhostnamer1r(s r z%Sentinel.__init__..sE   $  Cxd C Cd.B C C   r)itemsr sentinelsmin_other_sentinelsrd)r(rrrrds` rr'zSentinel.__init__s  "!2!8!8!:!:O /    "+   $7 !2rcTKtdd}dvrd|r+t j|jjid{Vn(fd|jD}tj |d{VdS)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. onceFNc Ng|]!}tj|ji"Sr)rITaskexecute_command)rsentinelargsr)s rrz,Sentinel.execute_command..sF 5X5tFvFFGGrT) rVrakeysr%rxchoicerrrIgather)r(rr)rtaskss `` rrzSentinel.execute_commands FJJvu--.. V[[]] " " JJv     )?&-//?PPP P P P P P P P P $E.%( ( ( ( ( ( ( (trcg}|jD]<}||jjdd|jjd=d|jd|jjdd|dS) Nr0:r1r,r-z (sentinels=[,z])>)rappendr$rdr*rjoin)r(sentinel_addressesrs rr5zSentinel.__repr__s  H  % %+=fEHH+=fEHH      = = =!8 = =88$677 = = = rstater/rtc`|dr|ds|drdS|d|jkrdSdS)NrBis_sdownis_odownFznum-other-sentinelsT)r)r(rr/s rcheck_master_statezSentinel.check_master_statesJ[! U:%6 % :K 5 & '$*B B B5trc>Kt}t|jD]\}} |d{V}n8#tt f$r$}||d|Yd}~Qd}~wwxYw||}|rH|||r2||jdc|jd<|j|<|d|dfcSd}t|dkrdd |}td ||) 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_mastersn 66%.t~%>%> 2 2 !K  ( 9 9 ; ;;;;;;;#\2    ''8(=(=(=(=>>> KK --E 200 EE 2N1%?q!4>+#>T{E&M1111  1 $ $ >EZ  E*$5    teFm < = = = =rcK|jD]W} ||d{V}n#tttf$rY8wxYw||}|r|cSXgS)z;Returns a list of alive slaves for service ``service_name``N)rsentinel_slavesrrrr)r(r/rr|s rrwzSentinel.discover_slaves,s  H '77 EEEEEEEE#]LA    ''//F    s)AA redis_classconnection_pool_classc d|d<t|j}|||||fi|}||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:sb:#{ !788  (((// dXXFWXX$$_555rc d|d<t|j}|||||fi|}||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_for_sb0${ !788  (((// dXXFWXX$$_555r)rN)rrrr~r'rr5rstrrVrrsrrrrr rrwr r]r rrrrrrrs> 3333,(    CDW#WWWW: w'  % J./ 0       % J./ 0    "$)>T #6#6#6%[#6 $$:; #6#6#6#6P$)>T 666%[6 $$:; 666666rr)!rIrxrbtypingrrrrrrr redis.asyncio.clientr redis.asyncio.connectionr r r rredis.commandsrredis.exceptionsrrrr redis.utilsrrr r"r[r]rrrrrs TTTTTTTTTTTTTTTTTT&&&&&& 100000XXXXXXXXXXXX$$$$$$     /           CCCCC CCCL     #