Ë
|
|
çúh¥: ã óþ d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlm Z m
|
Z
|
m Z d dl m Z mZmZmZ G d de « Z G d d
|
e « Z G d d e « Z G d dee « Z G d d« Z G d de
|
« Z G d de« Zy)é N)ÚOptional)ÚRedis)ÚSentinelCommands)Ú
|
ConnectionÚConnectionPoolÚ SSLConnection)ÚConnectionErrorÚ ReadOnlyErrorÚ ResponseErrorÚ TimeoutErrorc ó e Zd Zy)ÚMasterNotFoundErrorN©Ú__name__Ú
|
__module__Ú __qualname__© ó õa H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/sentinel.pyr r ó Ør r c ó e Zd Zy)ÚSlaveNotFoundErrorNr r r r r r r r r c ób e Zd Z fdZd Zd Zd Zd Z d ddddee d ee 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 óð | j }dt | « j dt | « j d|j d}| j
|
r!d| j
|
d| j }||z }|S )Nú<ú.ú (service=z%s)>z,host=z,port=)r Útyper r Ú service_nameÚhostÚport)r ÚpoolÚsÚ host_infos r Ú__repr__z"SentinelManagedConnection.__repr__ s{ Ø×#Ñ#àT
|
×%Ñ%Ð& a¬¨T«
|
×(;Ñ(;Ð'<Ø×)Ñ)Ð*¨$ð 0ð
|
ð 99Ø §¡ ¨6°$·)±)°Ð=IØI AØr c óp |\ | _ | _ | j | j j d¬« y )NF)Ú check_healthÚretry_socket_connect)r) r* Úconnect_check_healthr Úcheck_connection)r Úaddresss r Ú
|
connect_toz$SentinelManagedConnection.connect_to( s5 Ø &Ñ 49à ×!Ñ!Ø ×-Ñ-×>Ñ>Ø!&ð "õ
|
r c ó* | j ry | j j r*| j | j j « « y | j j « D ] } | j |« c S t # t $ r Y )w xY w©N)Ú_sockr Ú is_masterr5 Úget_master_addressÚ rotate_slavesr r )r Úslaves r Ú_connect_retryz(SentinelManagedConnection._connect_retry0 s Ø ::Ø Ø × Ñ × )Ò )Ø OOD× 0Ñ 0× CÑ CÓ EÕ Fà ×-Ñ-×;Ñ;Ó=ò ð Ø ??¨5Ó1Ò1ð ô
|
%Ð $øô 'ò Ù ð ús Á,B BÂBc óP | j j | j d « S )Nc ó y r7 r )Úerrors r ú<lambda>z3SentinelManagedConnection.connect.<locals>.<lambda>> s r )ÚretryÚcall_with_retryr= ©r s r Úconnectz!SentinelManagedConnection.connect= s Øzz×)Ñ)¨$×*=Ñ*=Ñ?QÓRÐRr F)Údisconnect_on_errorÚ push_requestrF rG c ó¨ t | |||¬« S # t $ r3 | j j r| j « t d« w xY w)N)Údisable_decodingrF rG z"The previous master is now a slave)r Ú read_responser
|
r r9 Ú
|
disconnectr )r rI rF rG r" s r rJ z'SentinelManagedConnection.read_response@ sc ø ð Ü7Ñ(Ø!1Ø$7Ø )ð )ó ð øô
|
ò Ø×#Ñ#×-Ò-ð Ô!Ü%Ð&JÓKÐKØ ð ús <A)F) r r r r r. r5 r= rE r ÚboolrJ Ú __classcell__©r" s @r r r sU ø ô#ò ò
|
ò %òSð
|
ðð /4Ø',ò ð & d^ð ð
|
tn÷ ñ r r c ó e Zd Zy)Ú SentinelManagedSSLConnectionNr r r r rP rP Y r r rP c ó$ e Zd Zd Zd Zd Zd Zy)ÚSentinelConnectionPoolProxyc ó t j |« | _ || _ || _ || _ || _ | j « y r7 )ÚweakrefÚrefÚconnection_pool_refr9 r3 r( Úsentinel_managerÚreset)r r r9 r3 r( rW s r r z$SentinelConnectionPoolProxy.__init__^ s= ô $+§;¡;¨Ó#?Ô Ø"Ø 0Ô Ø (ÔØ 0Ô Ø
|
|
r c ó d | _ d | _ y r7 )Úmaster_addressÚslave_rr_counterrD s r rX z!SentinelConnectionPoolProxy.resetm s Ø "ÔØ $Õ r c óÜ | j j | j « }| j r:| j |k7 r+|| _ | j « }||j d¬« |S )NF)Úinuse_connections)rW Údiscover_masterr( r9 rZ rV rK )r rZ r s r r: z.SentinelConnectionPoolProxy.get_master_addressq sg Ø ×.Ñ.×>Ñ>¸t×?PÑ?PÓQØ >>d× 1Ñ 1°^Ò CØ"0DÔ ð #× 6Ñ 6Ó 8OØ Ð*Ø ×*Ñ*¸UÐ*ÔCØ Ð r c # óÊ K | j j | j « }|r| j 't j
|
dt |« dz
|
« | _ t t |« « D ]5 }| j dz t |« z | _ || j }| 7 | j « t d| j « # t $ r Y #w xY ww)Nr é zNo slave found for ) rW Údiscover_slavesr( r[ ÚrandomÚrandintÚlenÚranger: r r )r ÚslavesÚ_r< s r r; z)SentinelConnectionPoolProxy.rotate_slaves| sØ è ø Ø×&Ñ&×6Ñ6°t×7HÑ7HÓIÙ Ø×$Ñ$Ð,Ü(.¯©°q¼#¸f»+ȹ/Ó(JÔ%Ü3v;Ó'ò Ø)-×)>Ñ)>ÀÑ)BÄcÈ&ÃkÑ(QÔ%Ø t× 4Ñ 4Ñ5Ø ð ð
|
Ø×)Ñ)Ó+Ò +ô !Ð#6°t×7HÑ7HÐ6KÐ!LÓMÐMøô #ò Ù ð üs* B'C#Â*C Â<C#à C à C#à C à C#N)r r r r rX r: r; r r r rR rR ] s ò ò %ò óNr rR c óX e Zd ZdZ fdZd Z fdZed « Z fdZ d Z
|
d 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 | | j | j
|
||¬« | _ t | $ d i |¤ | j | j d< || _ || _ y )
|
NÚconnection_classÚsslFr9 Tr3 )r r9 r3 r( rW r r ) Úgetr rP r r9 r3 rR Úproxyr r Úconnection_kwargsr( rW )r r( rW r! r" s r r z SentinelConnectionPool.__init__ s¶ ø Ø%+§Z¡ZØ ð ::e UÔ+õ -ä.ó &
|
Ð!Ñ"ð K°Ó6Ø &§
|
¡
|
Ð+=¸uÓ EÔ Ü0Ø ØnnØ !× 2Ñ 2Ø%Ø -ô
|
|
ô ÑÑ"6Ò"Ø48·J±J× Ñ Ð 0Ñ1Ø (ÔØ 0Õ r c ó | j rdnd}dt | « j dt | « j d| j d| d S )NÚmasterr< r$ r% r& ú(z))>)r9 r' r r r( )r Úroles r r. z SentinelConnectionPool.__repr__¬ sR Ø >>x¨wàT
|
×%Ñ%Ð& a¬¨T«
|
×(;Ñ(;Ð'<Ø×)Ñ)Ð*¨!¨D¨6°ð 6ð
|
r c óV t | « | j j « y r7 )r rX rn )r r" s r rX z SentinelConnectionPool.reset³ s ø Ü Ø
|
|
×ÑÕr c ó. | j j S r7 )rn rZ rD s r rZ z%SentinelConnectionPool.master_address· s àzz×(Ñ(Ð(r c óÆ | j xs3 | j xr% | j |j |j fk( }t « }|xr |j |« S r7 )r9 rZ r) r* r Úowns_connection)r Ú
|
connectionÚcheckÚparentr" s r rw z&SentinelConnectionPool.owns_connection» sZ ø ØNNÐ"ò
|
Ø NNÒ Xt× 2Ñ 2°z·±È
|
ÏÉÐ6XÑ Xð ô ØÒ;×/Ñ/°
|
Ó;Ð;r c ó6 | j j « S r7 )rn r: rD s r r: z)SentinelConnectionPool.get_master_address s Øzz×,Ñ,Ó.Ð.r c ó6 | j j « S )zRound-robin slave balancer)rn r; rD s r r; z$SentinelConnectionPool.rotate_slavesÅ s àzz×'Ñ'Ó)Ð)r ) r r r Ú__doc__r r. rX ÚpropertyrZ rw r: r; rM rN s @r ri ri s: ø ñô1ò.
|
ôð ñ)ó ð)ô<ò/ö*r ri c óZ e Zd ZdZ d dZd Zd Zd Zd Zd Z d Z
|
e e fd
|
Z e e fd Zy) Ú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.
|
Nc ó |5|j « D ci c] \ }}|j d« s|| }}}|| _ |D cg c] \ }} t || fi | j ¤ c} }| _ || _ || _ || _ y c c}}w c c} }w )NÚsocket_)ÚitemsÚ
|
startswithÚsentinel_kwargsr Ú sentinelsÚmin_other_sentinelsro Ú_force_master_ip)
|
r r r r
Úforce_master_ipro ÚkÚvÚhostnamer* s
|
r r zSentinel.__init__ç s ð Ð "à!2×!8Ñ!8Ó!:÷ Ù A¸a¿l¹lÈ9Õ>U1ð Oñ ð /Ô ð #,÷
|
á $ô (DÑ 9 D×$8Ñ$8Ó 9ó
|
ð $7Ô Ø!2Ô Ø /Õ ùó ùó
|
|
s B°BÁ!B
|
c ól t |j dd« « }t |j dd« « }|r: t j | j « j
|
|i |¤}|r|gS |rdS dS g }| j D ]# }|j |j
|
|i |¤« % |r|S t |« 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.
|
ÚonceFÚreturn_responsesT)rL r rb Úchoicer Úexecute_commandÚappendÚall)r Úargsr! r r ÚresponseÚ responsesÚsentinels r r zSentinel.execute_commandÿ sÁ ô FJJv uÓ-Ó.ô §
|
¡
|
Ð+=¸uÓ EÓFÐá ØDv}} T§^¡^Ó4×DÑDÀdÐUÈfÑUHÙ Ø zÐ!á 'tÐ2¨UÐ2à Ø ò HHØ × Ñ Ð 5X× 5Ñ 5°tÐ F¸vÑ FÕ Gð Hñ Ø Ð ä9~Ð r c ó g }| j D ]6 }|j dj |j j « « 8 dt | « j dt | « j ddj |« dS )Nz {host}:{port}r$ r% z (sentinels=[ú,z])>) r r Ú
|
format_mapr ro r' r r Újoin)r Úsentinel_addressesr s r r. zSentinel.__repr__ s Ø ÐØ ò HØ × %Ñ %Ø ×*Ñ*¨8×+CÑ+C×+UÑ+UÓVõ ð ð
|
T
|
×%Ñ%Ð& a¬¨T«
|
×(;Ñ(;Ð'<Ø388Ð$6Ó7Ð8¸ð =ð
|
r c óJ |d r
|
|d s|d ry|d | j k ryy)Nr9 Úis_sdownÚis_odownFznum-other-sentinelsT)r )r Ústater( s r Úcheck_master_statezSentinel.check_master_state& s5 Ø[Ò! U¨:Ò%6¸%À
|
Ò:KØà Ð&Ñ '¨$×*BÑ*BÒ BØØr c ó. t « }t | j « D ] \ }} |j « }|j |« }|s+| j ||« s>|| j d c| j d< | j |< | j | j n|d }||d fc S d} t |« dkD rddj |« } t d || « # t t
|
f$ r }|j | d|« Y d}~ïd}~ww xY w)
|
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 - Nr Úipr* Ú z : z, zNo master found for ) ÚlistÚ enumerater Úsentinel_mastersr r r rm r¡ r rd r r )
|
r r( Úcollected_errorsÚ sentinel_nor ÚmastersÚer r£ Ú
|
error_infos
|
r r^ zSentinel.discover_master. s7 ô 6ÐÜ%.¨t¯~©~Ó%>ò )Ñ !Kð Ø"×3Ñ3Ó5ð 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Ð(=Ô>Üûð ús §C%Ã%DÃ4DÄDc ó` 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 rf Ú slaves_aliver< s r Ú filter_slaveszSentinel.filter_slavesQ sK à Øò >EØZÒ E¨*Ò$5ØØ × Ñ t¡¨e°F©mÐ <Õ =ð >ð Ðr c ó® | j D ]+ } |j |« }| j |« }|s)|c S g S # t t t f$ r Y Fw xY w)z;Returns a list of alive slaves for service ``service_name``)r Úsentinel_slavesr r r r¯ )r r( r rf s r ra zSentinel.discover_slavesZ sf à ò Hð Ø!×1Ñ1°,Ó?ð ×'Ñ'¨Ó/FÚØ ð ð øô $¤]´LÐAò Ùð ús =½AÁAc ó d|d< t | j « }|j |« |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.
|
Tr9 ©Údictro ÚupdateÚ from_pool©r r( Ú redis_classÚconnection_pool_classr! ro s r Ú
|
master_forzSentinel.master_forf sP ð> #{ÑÜ ×!7Ñ!7Ó 8ÐØ× Ñ Ô(Ø×$Ñ$Ù ! ,°Ñ JÐ8IÑ Jó
|
ð
|
r c ó d|d< t | j « }|j |« |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.
|
Fr9 r³ r· s r Ú slave_forzSentinel.slave_for sP ð0 ${ÑÜ ×!7Ñ!7Ó 8ÐØ× Ñ Ô(Ø×$Ñ$Ù ! ,°Ñ JÐ8IÑ Jó
|
ð
|
r )r NN)r r r r} r r r. r¡ r^ r¯ ra r ri rº r¼ r r r r r Ê sR ñð> Ø Ø ó 0ò0 ò8
|
òò!WòF ò
|
ð Ø 4ó $
|
ðR Ø 4ô
|
r r )rb rT Útypingr Ú redis.clientr Úredis.commandsr Úredis.connectionr r r Úredis.exceptionsr r
|
r r r r r rP rR ri r r r r ú<module>r s ðÛ Û Ý å Ý +ß FÑ F÷ó ô /ô ô ô ô>
|
ô >ôB Ð#<¸mô ÷-Nñ -Nô`:*^ô :*ôz_
|
Ð õ _
|
r
|
