keJi:*ddlZddlZddlmZddlmZddlmZddlm Z m Z m Z ddl m Z mZmZmZGdde ZGd d e ZGd d e ZGd dee ZGddZGdde ZGddeZdS)N)Optional)Redis)SentinelCommands) ConnectionConnectionPool SSLConnection)ConnectionError ReadOnlyError ResponseError TimeoutErrorceZdZdS)MasterNotFoundErrorN__name__ __module__ __qualname__T/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/redis/sentinel.pyrrDrrceZdZdS)SlaveNotFoundErrorNrrrrrrrrrcneZdZfdZdZdZdZdZ d ddddee d ee ffd Z xZ S) SentinelManagedConnectionc n|d|_tjdi|dS)Nconnection_poolr)poprsuper__init__)selfkwargs __class__s rrz"SentinelManagedConnection.__init__s;%zz*;<<""6"""""rc|j}dt|jdt|jd|jd}|jrd|jd|j}||z}|S)N<. (service=z%s)>z,host=z,port=)rtyperr service_namehostport)r pools host_infos r__repr__z"SentinelManagedConnection.__repr__s# 0T % 0 0T (; 0 0) 0 0 0  9 ===$)==II Arcf|\|_|_||jjddS)NF) check_healthretry_socket_connect)r)r*connect_check_healthrcheck_connection)r addresss r connect_toz$SentinelManagedConnection.connect_to(sC& 49 !!->!& "     rc|jrdS|jjr.||jdS|jD])} ||cS#t $rY&wxYwtN)_sockr is_masterr5get_master_address rotate_slavesr r)r slaves r_connect_retryz(SentinelManagedConnection._connect_retry0s :  F   ) % OOD0CCEE F F F F F-;;==  ??511111&H$ $s A77 BBcD|j|jdS)NcdSr7r)errors rz3SentinelManagedConnection.connect..>sTr)retrycall_with_retryr=r s rconnectz!SentinelManagedConnection.connect=s!z))$*=?Q?QRRRrF)disconnect_on_error push_requestrFrGc t|||S#t$r1|jjr#|t dwxYw)N)disable_decodingrFrGz"The previous master is now a slave)r read_responser rr9 disconnectr )r rIrFrGr"s rrJz'SentinelManagedConnection.read_response@s 77((!1$7))     #- L !!!%&JKKK  s #';A")F) rrrrr.r5r=rErboolrJ __classcell__r"s@rrrs#####       % % %SSS /4', &d^  tn rrceZdZdS)SentinelManagedSSLConnectionNrrrrrPrPYrrrPc&eZdZdZdZdZdZdS)SentinelConnectionPoolProxyctj||_||_||_||_||_|dSr7)weakrefrefconnection_pool_refr9r3r(sentinel_managerreset)r rr9r3r(rWs rrz$SentinelConnectionPoolProxy.__init__^sF$+;#?#? " 0( 0 rc"d|_d|_dSr7)master_addressslave_rr_counterrDs rrXz!SentinelConnectionPoolProxy.resetms" $rc|j|j}|jr>|j|kr3||_|}||d|S)NF)inuse_connections)rWdiscover_masterr(r9rZrVrK)r rZrs rr:z.SentinelConnectionPoolProxy.get_master_addressqsq.>>t?PQQ > Dd1^CC"0D #6688O***U*CCCrc#K|j|j}|r|j*t jdt |dz |_tt |D]2}|jdzt |z|_||j}|V3 |Vn#t$rYnwxYwtd|j)NrzNo slave found for ) rWdiscover_slavesr(r[randomrandintlenranger:rr)r slaves_r<s rr;z)SentinelConnectionPoolProxy.rotate_slaves|s&66t7HII  $,(.q#f++/(J(J%3v;;''  )-)>)Bc&kk(Q%t45  ))++ + + + +"    D  !Lt7H!L!LMMMs%B<< C C N)rrrrrXr:r;rrrrRrR]sU   %%%   NNNNNrrRc^eZdZdZfdZdZfdZedZfdZ dZ dZ 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 ||j|j|||_tj d i||j|j d<||_ ||_ dS) Nconnection_classsslFr9Tr3)rr9r3r(rWrr) getrrPrr9r3rRproxyrrconnection_kwargsr(rW)r r(rWr!r"s rrzSentinelConnectionPool.__init__s%+ZZ ::eU++/,,. & & !" K66 & +=u E E0 n!2%-      ""6"""48J01( 0rc |jrdnd}dt|jdt|jd|jd|d S)Nmasterr<r$r%r&(z))>)r9r'rrr()r roles rr.zSentinelConnectionPool.__repr__sh>6xxw 6T % 6 6T (; 6 6) 6 6,0 6 6 6 rczt|jdSr7)rrXrn)r r"s rrXzSentinelConnectionPool.resets.   rc|jjSr7)rnrZrDs rrZz%SentinelConnectionPool.master_addresss z((rc|j p|jo|j|j|jfk}t }|o||Sr7)r9rZr)r*rowns_connection)r connectioncheckparentr"s rrwz&SentinelConnectionPool.owns_connectionsTN" N Xt2z 6XX ;// ;;;rc4|jSr7)rnr:rDs rr:z)SentinelConnectionPool.get_master_addresssz,,...rc4|jS)zRound-robin slave balancer)rnr;rDs rr;z$SentinelConnectionPool.rotate_slavessz'')))r) rrr__doc__rr.rXpropertyrZrwr:r;rMrNs@rriris11111.   ))X)<<<<<///*******rric\eZdZdZ d dZdZdZdZdZd Z d Z e e fd Z e e fd ZdS)Sentinelar 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) >>> master.set('foo', 'bar') >>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1) >>> 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|]\}}t||fijSr)rsentinel_kwargs)rhostnamer*r s r z%Sentinel.__init__..sB   $ (D 9 9D$8 9 9   r)itemsr sentinelsmin_other_sentinelsro_force_master_ip)r rrrforce_master_ipros` rrzSentinel.__init__s  "!2!8!8!:!:O /    "+   $7 !2 /rcnt|dd}t|dd}|r/tj|jj|i|}|r|gS|rdndSg}|jD]"}||j|i|#|r|St|S)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_responsesT)rLrrbchoicerexecute_commandappendall)r argsr!rrresponse responsessentinels rrzSentinel.execute_commands FJJvu--..  +=u E EFF  3Dv}T^44DdUfUUH 3 z!'2ttU2  H HH   5X5tFvFF G G G G   9~~rcg}|jD]4}|d|jj5dt |jdt |jdd|dS)Nz {host}:{port}r$r%z (sentinels=[,z])>) rr format_maprror'rrjoin)r sentinel_addressesrs rr.zSentinel.__repr__s  H  % %**8+C+UVV     =T % = =T (; = =88$677 = = = rc`|dr|ds|drdS|d|jkrdSdS)Nr9is_sdownis_odownFznum-other-sentinelsT)r)r stater(s rcheck_master_statezSentinel.check_master_state&sJ[! U:%6 % :K 5 & '$*B B B5trcNt}t|jD]\}} |}n8#tt f$r$}||d|Yd}~Kd}~wwxYw||}|rX|||rB||jdc|jd<|j|<|j |j n|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. z - Nripr*z : z, zNo master found for ) list enumeratersentinel_mastersr r rrmrrrdrr) r r(collected_errors sentinel_normasterserr error_infos rr^zSentinel.discover_master.sv 66%.t~%>%> ) ) !K "3355#\2    ''8(=(=(=(=>>> KK --E )00 EE )N1%?q!4>+#>,8))t 5=((((  1 $ $A3A..A3c|g}|D]6}|ds|dr||d|df7|S)z1Remove slaves that are in an ODOWN or SDOWN staterrrr*)r)r rf slaves_aliver<s r filter_slaveszSentinel.filter_slavesQs\  > >EZ  E*$5    teFm < = = = =rc|jD]Q} ||}n#tttf$rY2wxYw||}|r|cSRgS)z;Returns a list of alive slaves for service ``service_name``)rsentinel_slavesr r r r)r r(rrfs rrazSentinel.discover_slavesZs  H !11,??#]LA    ''//F    s !;;c d|d<t|j}||||||fi|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. Tr9dictroupdate from_poolr r( redis_classconnection_pool_classr!ros r master_forzSentinel.master_forfsd>#{ !788  ((($$ ! !, J J8I J J   rc 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. Fr9rrs r slave_forzSentinel.slave_forsd0${ !788  ((($$ ! !, J J8I J J   r)rNN)rrrr}rrr.rr^rrarrirrrrrrrs> 000008    !W!W!WF   4 $ $ $ $ R4       rr)rbrTtypingr redis.clientrredis.commandsrredis.connectionrrrredis.exceptionsr r r r rrrrPrRrirrrrrs ++++++FFFFFFFFFF     /           >>>>> >>>B     #