Ë
|
|
çúh: ã ó d dl Z d dlZd dlZd dlmZmZmZmZmZm Z m
|
Z
|
d dl m Z d dl mZmZmZmZ d dlmZ d dlmZmZmZmZ G d de« Z G d d
|
e« Z G d d e« Z G d dee« Z G d de« Z G d de« Z y)é N)Ú AsyncIteratorÚIterableÚMappingÚOptionalÚSequenceÚTupleÚType)ÚRedis)Ú
|
ConnectionÚConnectionPoolÚ
|
EncodableTÚ SSLConnection)ÚAsyncSentinelCommands)ÚConnectionErrorÚ ReadOnlyErrorÚ ResponseErrorÚ TimeoutErrorc ó e Zd Zy)ÚMasterNotFoundErrorN©Ú__name__Ú
|
__module__Ú __qualname__© ó õi H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/sentinel.pyr r ó Ør r c ó e Zd Zy)ÚSlaveNotFoundErrorNr r r r r r r r r c ór e Zd Z fdZd Zd Zd Zd Z ddddd ed
|
e e
|
d e e
|
d e e f fd Z xZ S )ÚSentinelManagedConnectionc óP |j d« | _ t | di |¤ y )NÚconnection_poolr )Úpopr# ÚsuperÚ__init__)ÚselfÚkwargsÚ __class__s r r& z"SentinelManagedConnection.__init__ s% ø Ø %zzÐ*;Ó <Ô Ü ÑÑ"6Ó"r c óÆ d| j j d| j j }| j r!d| j d| j }||z }|dz S )Nú<ú.z,host=z,port=z)>)r) r r ÚhostÚport)r' ÚsÚ host_infos r Ú__repr__z"SentinelManagedConnection.__repr__# s] Ø×)Ñ)Ð*¨!¨D¯N©N×,CÑ,CÐ+DÐ EØ 99Ø §¡ ¨6°$·)±)°Ð=IØ NAØ4xr c ó K |\ | _ | _ | j | j j d¬« d { y 7 w)NF)Ú check_healthÚretry_socket_connect)r- r. Úconnect_check_healthr# Úcheck_connection)r' Úaddresss r Ú
|
connect_toz$SentinelManagedConnection.connect_to* sC è ø Ø &Ñ 49Ø×'Ñ'Ø ×-Ñ-×>Ñ>Ø!&ð (ó
|
÷
|
ò
|
ús :A¼A½Ac ó~ K | j ry | j j r:| j | j j « d { « d { y | j j « 2 3 d { } | j |« d { c S 7 P7 F7 $7 # t $ r Y 8w xY w6 t w©N)Ú_readerr# Ú is_masterr8 Úget_master_addressÚ rotate_slavesr r )r' Úslaves r Ú_connect_retryz(SentinelManagedConnection._connect_retry1 s¬ è ø Ø <<Ø Ø × Ñ × )Ò )Ø//¨×(<Ñ(<×(OÑ(OÓ(Q×"QÓR× RÑ Rà #× 3Ñ 3× AÑ AÓ C÷ ð eð Ø!%§ ¡ °Ó!7×7Ò7ð #RøÐ Røð øà7ùÜ&ò Ù ð úð Dô
|
%Ð $ùsx A B=ÁB Á B=ÁB!Á B=Á:B6Á>B#Á?B6ÂB=ÂB'ÂB%ÂB'Â B=Â!B=Â#B6Â%B'Â' B3Â0B=Â2B3Â3
|
B=c ól K | j j | j d « d { S 7 w)Nc ó, t j d« S )Nr )ÚasyncioÚsleep)Úerrors r ú<lambda>z3SentinelManagedConnection.connect.<locals>.<lambda>A s '--¨Ó* r )ÚretryÚcall_with_retryr@ ©r' s r Úconnectz!SentinelManagedConnection.connect> s3 è ø ØZZ×/Ñ/Ø × Ñ Ù *ó
|
÷
|
ð
|
ð
|
ús +42®4FT)Údisconnect_on_errorÚ push_requestÚdisable_decodingÚtimeoutrK rL c óØ K t | ||||¬« d { S 7 # t $ r< | j j r$| j « d { 7 t d« w xY ww)N)rM rN rK rL z"The previous master is now a slave)r% Ú read_responser r# r< Ú
|
disconnectr )r' rM rN rK rL r) s r rP z'SentinelManagedConnection.read_responseD sy øè ø ð Ü Ñ.Ø!1Ø Ø$7Ø )ð /ó ÷ ð ð ùô ò Ø×#Ñ#×-Ò-ð ooÓ'×'Ñ'Ü%Ð&JÓKÐKØ ð üs1 A*
" " A* " ¢2A'ÁAÁA'Á'A*)FN) r r r r& r1 r8 r@ rJ Úboolr ÚfloatrP Ú __classcell__©r) s @r r! r! sm ø ô#òò
|
ò %ò
|
ð "'Ø#'ðð
|
04Ø',ò à ðð % ðð
|
& e_ð ð tn÷ ñ r r! c ó e Zd Zy)Ú SentinelManagedSSLConnectionNr r r r rW rW _ r r rW c óT e Zd ZdZ fdZd Z fdZdef fd Zd Z 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 ó^ |j d|j dd« rt nt « |d< |j dd« | _ |j dd« | _ t | di |¤ t j | « | j d< || _ || _ d | _ d | _ y ) NÚconnection_classÚsslFr< Tr6 r# r )Úgetr$ rW r! r< r6 r% r& ÚweakrefÚproxyÚconnection_kwargsÚ service_nameÚsentinel_managerÚmaster_addressÚslave_rr_counter)r' ra rb r( r) s r r& z SentinelConnectionPool.__init__k s¤ ø Ø%+§Z¡ZØ ð ::e UÔ+õ -ä.ó &
|
Ð!Ñ"ð K°Ó6Ø &§
|
¡
|
Ð+=¸uÓ EÔ Ü ÑÑ"6Ò"Ü4;·M±MÀ$Ó4G× Ñ Ð 0Ñ1Ø (ÔØ 0Ô Ø "ÔØ $Õ r c ó¨ d| j j d| j j d| j d| j xr dxs d d S )Nr+ r, z (service=ú(Úmasterr? z))>)r) r r ra r< rI s r r1 z SentinelConnectionPool.__repr__} sV à×)Ñ)Ð*¨!¨D¯N©N×,CÑ,CÐ+DØ×)Ñ)Ð*¨!¨D¯N©NÒ,G¸xÒ,RÈ7Ð+SÐSVð Xð
|
r c ó> t | « d | _ d | _ y r: )r% Úresetrc rd )r' r) s r ri z SentinelConnectionPool.reset s ø Ü Ø "ÔØ $Õ r Ú
|
connectionc ó® | j xs3 | j xr% | j |j |j fk( }|xr t | |« S r: )r< rc r- r. r% Úowns_connection)r' rj Úcheckr) s r rl z&SentinelConnectionPool.owns_connection sR ø ØNNÐ"ò
|
Ø NNÒ Xt× 2Ñ 2°z·±È
|
ÏÉÐ6XÑ Xð ð Ò<Ñ0°Ó<Ð<r c óè K | j j | j « d { }| j r0| j |k7 r!|| _ | j d¬« d { |S 7 B7 w)NF)Úinuse_connections)rb Údiscover_masterra r< rc rQ )r' rc s r r= z)SentinelConnectionPool.get_master_address sj è ø Ø #× 4Ñ 4× DÑ DÀT×EVÑEVÓ W×WØ >>Ø×"Ñ" nÒ4Ø&4Ô#ð oo¸oÓ>×>Ð>Ø Ð ð Xøð ?ús! )A2«A.¬;A2Á'A0Á(A2Á0A2Úreturnc óö K | j j | j « d{ }|r| j 't j
|
dt |« dz
|
« | _ t t |« « D ]6 }| j dz t |« z | _ || j }| 8 | j « d{ t d| j « 7 º7 !# t $ r Y 'w xY ww)zRound-robin slave balancerNr é zNo slave found for ) rb Údiscover_slavesra rd ÚrandomÚrandintÚlenÚranger= r r )r' ÚslavesÚ_r? s r r> z$SentinelConnectionPool.rotate_slaves sè è ø à×,Ñ,×<Ñ<¸T×=NÑ=NÓO×OÙ Ø×$Ñ$Ð,Ü(.¯©°q¼#¸f»+ȹ/Ó(JÔ%Ü3v;Ó'ò Ø)-×)>Ñ)>ÀÑ)BÄcÈ&ÃkÑ(QÔ%Ø t× 4Ñ 4Ñ5Ø ð ð
|
Ø ×/Ñ/Ó1×1Ó 1ô !Ð#6°t×7HÑ7HÐ6KÐ!LÓMÐMð Pøð 2ùÜ"ò Ù ð üsF )C9«C&¬BC9Â3C* ÃC(ÃC* ÃC9Ã(C* Ã* C6Ã3C9Ã5C6Ã6C9) r r r Ú__doc__r& r1 ri r rl r= r r> rT rU s @r rY rY c s6 ø ñô%ò$
|
ô %ð
|
=¨*õ =ò ðN ]÷ Nr rY c óÜ e Zd ZdZ ddZd Zd Zdedede fd Z
|
defd
|
Z d e e deeeef fd Zdedeeeef fd Zeefdedee dee fdZeefdedee dee fdZy)Ú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|j « D ci c] \ }}|j d« s|| }}}|| _ |D cg c] \ }} t d|| d| j ¤ c} }| _ || _ || _ || _ y c c}}w c c} }w )NÚsocket_)r- r. r )ÚitemsÚ
|
startswithÚsentinel_kwargsr
|
Ú sentinelsÚmin_other_sentinelsr` Ú_force_master_ip)
|
r' r r r Úforce_master_ipr` ÚkÚvÚhostnamer. s
|
r r& zSentinel.__init__Ç s£ ð Ð "à!2×!8Ñ!8Ó!:÷ Ù A¸a¿l¹lÈ9Õ>U1ð Oñ ð /Ô ð #,÷
|
á $ô Ð Cx dÑ C¨d×.BÑ.BÓ Có
|
ð $7Ô Ø!2Ô Ø /Õ ùó ùó
|
|
s B°BÁ"B c
|
óÚ K t |j dd« « }t |j dd« « }|rB t j | j « j
|
|i |¤ d{ }|r|gS |rdS dS | j D cg c]' }t j |j
|
|i |¤« ) }}t j | d{ }|r|S t |« S 7 tc c}w 7 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.
|
ÚonceFÚreturn_responsesNT)
|
rR r$ ru Úchoicer Úexecute_commandrC ÚTaskÚgatherÚall) r' Úargsr( r r ÚresponseÚsentinelÚtasksÚ responsess r r zSentinel.execute_commandß sö è ø ô FJJv uÓ-Ó.ô §
|
¡
|
Ð+=¸uÓ EÓFÐá Ø JV]]¨4¯>©>Ó :× JÑ JØð Ø ñ ÷ Hñ Ø zÐ!á 'tÐ2¨UÐ2ð !NNö
|
àô LLÐ1×1Ñ1°4ÐB¸6ÑBÕ Cð
|
ð
|
ô "..¨%Ð0×0 á Ø Ð ä9~Ð ð#úò
|
ð 1ús0 A+C+Á-C"Á. C+Â ,C$Â7C+ÃC)ÃC+Ã$C+c ó" g }| j D ]F }|j |j j d d|j j d « H d| j d| j j
|
ddj |« dS ) Nr- ú:r. r+ r, z (sentinels=[ú,z])>)r Úappendr# r` r) r Újoin)r' Úsentinel_addressesr s r r1 zSentinel.__repr__ÿ s Ø ÐØ ò HØ × %Ñ %Ø×+Ñ+×=Ñ=¸fÑEÐFÀaØ×+Ñ+×=Ñ=¸fÑEÐFðHõ ð ð Ð q § ¡ ×!8Ñ!8Ð 9Ø388Ð$6Ó7Ð8¸ð =ð
|
r Ústatera rq c óJ |d r
|
|d s|d ry|d | j k ryy)Nr< Úis_sdownÚis_odownFznum-other-sentinelsT)r )r' r ra s r Úcheck_master_statezSentinel.check_master_state s5 Ø[Ò! U¨:Ò%6¸%À
|
Ò:KØà Ð&Ñ '¨$×*BÑ*BÒ BØØr c óJ K t « }t | j « D ] \ }} |j « d{ }|j |« }|s3| j ||« sF|| j d c| j d< | j |< | j | j n|d }||d fc S d} t |« dkD rddj |« } t d || « 7 ²# t t
|
f$ r }|j | d|« Y d}~ùd}~ww xY ww)
|
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 - r Úipr. Ú z : z, zNo master found for ) ÚlistÚ enumerater Úsentinel_mastersr r r r] r¡ r
rw r r )
|
r' ra Úcollected_errorsÚ sentinel_nor ÚmastersÚer r£ Ú
|
error_infos
|
r rp zSentinel.discover_master s@ è ø ô 6ÐÜ%.¨t¯~©~Ó%>ò )Ñ !Kð Ø (× 9Ñ 9Ó ;×;ð KK Ó-EÚ×0Ñ0°¸ ÕEð ØNN 1Ñ%ð ?qÑ! 4§>¡>°+Ñ#>ð ×,Ñ,Ð8ð ×)Ò)à tð ð
|
5 =Ð(Ò(ð' )ð*
|
Ü Ð Ó 1Ò $Ø tyyÐ)9Ó :Ð ;Ð<JÜ!Ð$8¸ Ð8HÈÈ Ð"UÓVÐVð- <ùÜ#¤\Ð2ò Ø ×'Ñ'¨8¨*°C¸°uÐ(=Ô>Üûð üsK &D#©C1¼C/½C1ÁD#ÁD#Á(BD#Ã/C1Ã1D Ä DÄD#ÄD Ä D#ry c ó` g }|D ]& }|d s|d r|j |d |d f« ( |S )z1Remove slaves that are in an ODOWN or SDOWN stater r r£ r. )r )r' ry Ú slaves_aliver? s r Ú filter_slaveszSentinel.filter_slaves6 sM ð Øò >EØZÒ E¨*Ò$5ØØ × Ñ t¡¨e°F©mÐ <Õ =ð >ð Ðr c óÊ K | j D ]3 } |j |« d{ }| j |« }|s1|c S g S 7 # t t t f$ r Y Pw xY ww)z;Returns a list of alive slaves for service ``service_name``N)r Úsentinel_slavesr r r r¯ )r' ra r ry s r rt zSentinel.discover_slavesA sr è ø ð ò Hð Ø '× 7Ñ 7¸ Ó E×Eð ×'Ñ'¨Ó/FÚØ ð ð ð FùÜ#¤]´LÐAò Ùð üs= A#A §A¨A ¬A#Á A#ÁA Á A Á A#Á A Á A#Ú redis_classÚconnection_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_pool©r' ra r² r³ r( r` r# s r Ú
|
master_forzSentinel.master_forO sP ð> #{ÑÜ ×!7Ñ!7Ó 8ÐØ× Ñ Ô(á/° ¸dÑXÐFWÑXà×$Ñ$ _Ó5Ð5r c ó 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< rµ r¹ s r Ú slave_forzSentinel.slave_forv sP ð0 ${ÑÜ ×!7Ñ!7Ó 8ÐØ× Ñ Ô(á/° ¸dÑXÐFWÑXà×$Ñ$ _Ó5Ð5r )r NN)r r r r{ r& r r1 r¶ ÚstrrR r¡ rp r r r r r r¯ rt r
|
rY r rº r¼ r r r r} r} ª sÿ ñð> Ø Ø ó 0ò0 ò@
|
|
ð¨ð ¸Cð ÀDó ð!W°#ó !WðF Ø wÑ'ð à %
|
JÐ.Ñ/Ñ 0ó ð Ø ð à %
|
JÐ.Ñ/Ñ 0ó ð" $)Ø>Tñ %6àð%6ð %[ð%6ð $Ð$:Ñ ;ó %6ðT $)Ø>Tñ 6àð 6ð %[ð 6ð $Ð$:Ñ ;ô 6r r} ) rC ru r^ Útypingr r r r r r r Úredis.asyncio.clientr
|
Úredis.asyncio.connectionr r r r Úredis.commandsr Úredis.exceptionsr r r r r r r! rW rY r} r r r ú<module>rà s ðÛ Û Û ß T× TÑ Tå &÷ó õ 1÷ó ô /ô ô ô ô>
|
ô >ôB Ð#<¸mô ôDN^ô DNôNj6Ð$õ j6r
|
