hR1ddlZddlZddlmZddlmZddlmZmZm Z ddl m Z m Z m Z mZddlmZGdde ZGd d e ZGd d eZGd dee ZGddeZGddeZdS)N)Redis)SentinelCommands) ConnectionConnectionPool SSLConnection)ConnectionError ReadOnlyError ResponseError TimeoutError) str_if_bytesceZdZdS)MasterNotFoundErrorN__name__ __module__ __qualname__J/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/redis/sentinel.pyrr DrrceZdZdS)SlaveNotFoundErrorNrrrrrrrrrcFeZdZfdZdZfdZdZdZdfd ZxZ S) SentinelManagedConnectionc n|d|_tjdi|dS)Nconnection_poolr)poprsuper__init__)selfkwargs __class__s rrz"SentinelManagedConnection.__init__s;%zz*;<<""6"""""rc|j}t|jd|jd}|jrd|jd|j}||z}|S)N z,host=z,port=)rtyper service_namehostport)r pools host_infos r__repr__z"SentinelManagedConnection.__repr__s]#Dzz" C CT-> C C C 9 ===$)==II Arc|\|_|_t|jjrI|dt|dkrtddSdS)NPINGPONGz PING failed) r'r(rconnectrcheck_connection send_commandr read_responser)r addressr"s r connect_toz$SentinelManagedConnection.connect_to s& 49    0 5   f % % %D..0011V;;%m444 5 5;;rc|jrdS|jjr.||jdS|jD])} ||cS#t $rY&wxYwtN)_sockr is_masterr5get_master_address rotate_slavesrr)r slaves r_connect_retryz(SentinelManagedConnection._connect_retry(s :  F   ) % OOD0CCEE F F F F F-;;==  ??511111&H$ $s A77 BBcD|j|jdS)NcdSr7r)errors rz3SentinelManagedConnection.connect..6sTr)retrycall_with_retryr=)r s rr0z!SentinelManagedConnection.connect5s!z))$*=?Q?QRRRrFc t|S#t$r1|jjr#|t dwxYw)N)disable_decodingz"The previous master is now a slave)rr3r rr9 disconnectr)r rEr"s rr3z'SentinelManagedConnection.read_response8sr 77((:J(KK K   #- L !!!%&JKKK  s !%;A )F) rrrrr,r5r=r0r3 __classcell__r"s@rrrs#####55555 % % %SSS          rrceZdZdS)SentinelManagedSSLConnectionNrrrrrJrJGrrrJcHeZdZdZfdZdZfdZfdZdZdZ 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 p|d|ddrtnt|d<|dd|_|dd|_t jdi|tj ||j d<||_ ||_ dS) Nconnection_classsslFr9Tr1rr) getrrJrr9r1rrweakrefproxyconnection_kwargsr&sentinel_manager)r r&rTr!r"s rrzSentinelConnectionPool.__init__Ss%+ZZ zz%'' + ( (* & & !"  K66 & +=u E E""6"""4;M$4G4G01( 0rc\|jrdnd}t|jd|jd|dS)Nmasterr<r$())r9r%rr&)r roles rr,zSentinelConnectionPool.__repr__as=>6xxwt**%KK0AKKDKKKKrcdtd|_d|_dSr7)rresetmaster_addressslave_rr_counter)r r"s rr[zSentinelConnectionPool.resetes*  " $rc|j p|jo|j|j|jfk}t }|o||Sr7)r9r\r'r(rowns_connection)r connectioncheckparentr"s rr_z&SentinelConnectionPool.owns_connectionjsTN" N Xt2z 6XX ;// ;;;rc|j|j}|jr(|j|kr||_|d|S)NF)inuse_connections)rTdiscover_masterr&r9r\rF)r r\s rr:z)SentinelConnectionPool.get_master_addressqsW.>>t?PQQ > 9"n44&4#%888rc#K|j|j}|r|j*t jdt |dz |_tt |D]2}|jdzt |z|_||j}|V3 |Vn#t$rYnwxYwtd|j)zRound-robin slave balancerNrzNo slave found for ) rTdiscover_slavesr&r]randomrandintlenranger:rr)r slaves_r<s rr;z$SentinelConnectionPool.rotate_slaves{s&66t7HII  $,(.q#f++/(J(J%3v;;''  )-)>)Bc&kk(Q%t45  ))++ + + + +"    D  !Lt7H!L!LMMMs%B<< C C ) rrr__doc__rr,r[r_r:r;rGrHs@rrLrLKs 1 1 1 1 1LLL%%%%% <<<<<NNNNNNNrrLcZeZdZdZ 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)rvhostnamer(r s r z%Sentinel.__init__..sB   $ (D 9 9D$8 9 9   r)itemsr{ sentinelsmin_other_sentinelsrS)r rrr{rSs` rrzSentinel.__init__s  "!2!8!8!:!:O /    "+   $7 !2rct|dd}d|vr|d|r%t j|jj|i|n|jD]}|j|i|dS)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. onceFT)boolrPkeysrrichoicerexecute_command)r argsr!rsentinels rrzSentinel.execute_commands FJJvu--.. V[[]] " " JJv     : 9FM$. ) ) 94 J6 J J J J N : :(($9&9999trcg}|jD]4}|d|jj5t |jdd|dS)Nz {host}:{port}z )rappend format_maprrSr%rjoin)r sentinel_addressesrs rr,zSentinel.__repr__s|  H  % %**8+C+UVV    t**%SS388%> 2 2 !K "3355#\2    KK --E 200 EE 2N1%?q!4>+#>T{E&M1111!"I"I"IJJJs0AAc|g}|D]6}|ds|dr||d|df7|S)z1Remove slaves that are in an ODOWN or SDOWN staterrrr()r)r rm slaves_aliver<s r filter_slaveszSentinel.filter_slavess\  > >EZ  E*$5    teFm < = = = =rc|jD]Q} ||}n#tttf$rY2wxYw||}|r|cSRgS)z;Returns a list of alive slaves for service ``service_name``)rsentinel_slavesrr r r)r r&rrms rrhzSentinel.discover_slavess  H !11,??#]LA    ''//F    s !;;c 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. Tr9rdictrSupdater r& redis_classconnection_pool_classr!rSs r master_forzSentinel.master_for sn:#{ !788  ((({11d&7    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. Fr9rrrs r slave_forzSentinel.slave_for3sn0${ !788  ((({11d&7    r)rN)rrrrorrr,rrerrhrrLrrrrrrqrqs> 3333,"TTTKKK.   4 $ $ $ $ R4       rrq)rirQ redis.clientrredis.commandsrredis.connectionrrrredis.exceptionsrr r r redis.utilsr rrrrJrLrqrrrrs ++++++FFFFFFFFFFXXXXXXXXXXXX$$$$$$     /           11111 111h     #