Ë
|
|
çúh)' ã óª U d dl Z d dlmZmZ d dlmZ d dlmZ d dlm Z m
|
Z
|
m Z m Z d dl mZ d dlmZ d dlmZmZ d d lmZ d d
|
lmZ d Zd Zd ZdZ e j8 e « Z G d de« Z G d de« Z G d de « Z! G d de!« Z" G d de!« Z# G d de!« Z$ G d d e« Z%e%jL Z'e%e(d < G d d e « Z) G d d!e « Z*y)"é N)ÚABCÚabstractmethod)ÚEnum)Úsleep)ÚListÚOptionalÚTupleÚUnion)ÚRedis)Ú NoBackoff)ÚDEFAULT_TIMEOUTÚ
|
HttpClient)ÚUnhealthyDatabaseException)ÚRetryé é g à?i c ó" e Zd Zedefd« Zy)Ú HealthCheckÚreturnc ó y)z(Function to determine the health status.N© )ÚselfÚdatabases õl H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/multidb/healthcheck.pyÚ check_healthzHealthCheck.check_health ó ð ó N)Ú__name__Ú
|
__module__Ú __qualname__r Úboolr r r r r r s Øð ¨ò ó ñ r r c óp e Zd ZdZeedefd« « Zeedefd« « Z ede
|
e de fd« Z y)ÚHealthCheckPolicyz)
|
Health checks execution policy.
|
r c ó y)z*Number of probes to execute health checks.Nr ©r s r Úhealth_check_probesz%HealthCheckPolicy.health_check_probes! ó ð r c ó y)z"Delay between health check probes.Nr r% s r Úhealth_check_delayz$HealthCheckPolicy.health_check_delay' r' r Ú health_checksc ó y)z8Execute health checks and return database health status.Nr ©r r* r s r ÚexecutezHealthCheckPolicy.execute- r r N)r r r Ú__doc__Úpropertyr Úintr& Úfloatr) r r r! r- r r r r# r# st ñð Øð Sò ó ó ð ð Øð Eò ó ó ð ð ð T¨+Ñ%6ð ÀTò ó ñ r r# c óh e Zd ZdedefdZedefd« Zedefd« Ze de
|
e de fd« Z y )
|
ÚAbstractHealthCheckPolicyr& r) c ó@ |dk r t d« || _ || _ y )Né z*health_check_probes must be greater than 0)Ú
|
ValueErrorÚ_health_check_probesÚ_health_check_delay)r r& r) s r Ú__init__z"AbstractHealthCheckPolicy.__init__4 s& Ø Ò "Ü Ð IÓJÐ JØ$7Ô!Ø#5Õ r r c ó | j S ©N)r7 r% s r r& z-AbstractHealthCheckPolicy.health_check_probes: s à×(Ñ(Ð(r c ó | j S r; )r8 r% s r r) z,AbstractHealthCheckPolicy.health_check_delay> s à×'Ñ'Ð'r r* c ó y r; r r, s r r- z!AbstractHealthCheckPolicy.executeB s à r N)r r r r0 r1 r9 r/ r& r) r r r r! r- r r r r3 r3 3 sr ð6¨Cð 6ÀUó 6ð ð) Sò )ó ð)ð ð( Eò (ó ð(ð ð T¨+Ñ%6ð ÀTò ó ñ r r3 c óB e Zd ZdZdedef fd Zdee de fdZ
|
xZ S )ÚHealthyAllPolicyzM
|
Policy that returns True if all health check probes are successful.
|
r& r) c ó& t | ||« y r; ©Úsuperr9 ©r r& r) Ú __class__s r r9 zHealthyAllPolicy.__init__L ó ø Ü ÑÐ,Ð.@ÕAr r* r c óþ |D ]Z }t | j « D ]@ } |j |« s y || j dz
|
k s,t | j « B \ y# t $ r}t d||« d }~ww xY w)NFúUnhealthy databaser5 T©Úranger& r Ú Exceptionr r r8 )r r* r Ú health_checkÚattemptÚes r r- zHealthyAllPolicy.executeO s Ø )ò 4LÜ ×!9Ñ!9Ó:ò 4ðXØ'×4Ñ4°XÔ>Ú $ð ?ð
|
T× 5Ñ 5¸Ñ 9Ó9Ü$×2Ñ2Õ3ñ 4ð 4ð øô !ò XÜ4Ð5IÈ8ÐUVÓWÐWûðXús A!Á! A<Á* A7Á7A<© r r r r. r0 r1 r9 r r r! r- Ú __classcell__©rD s @r r? r? G s6 ø ñðB¨Cð BÀUõ Bð T¨+Ñ%6ð ÀT÷ r r? c óB e Zd ZdZdedef fd Zdee de fdZ
|
xZ S )ÚHealthyMajorityPolicyzW
|
Policy that returns True if a majority of health check probes are successful.
|
r& r) c ó& t | ||« y r; rA rC s r r9 z HealthyMajorityPolicy.__init__b rE r r* r c ó |D ] }| j dz dk( r| j dz }n| j dz dz }t | j « D ]I } |j |« s |dz }|dk r y|| j dz
|
k s5t | j « K y# t $ r!}|dz }|dk r t d||« Y d }~Rd }~ww xY w)Né r r5 FrG T)r& rI r rJ r r r8 )r r* r rK Úallowed_unsuccessful_probesrL rM s r r- z HealthyMajorityPolicy.executee sô Ø )ò 4LØ×'Ñ'¨!Ñ+¨qÒ0Ø.2×.FÑ.FÈÑ.JÑ+à/3×/GÑ/GÈ!Ñ/KÈqÑ.PÐ+ä ×!9Ñ!9Ó:ò 4ð
|
Ø'×4Ñ4°XÔ>Ø3°qÑ8Ð3Ø6¸!Ò;Ú#(ð T× 5Ñ 5¸Ñ 9Ó9Ü$×2Ñ2Õ3ñ 4ð 4ð* øô !ò Ø/°1Ñ4Ð/Ø2°aÒ7Ü 8Ø 0°(¸Aó ð ô 8ûðús ÁB  CÂ'CÃCrN rP s @r rR rR ] s6 ø ñðB¨Cð BÀUõ Bð T¨+Ñ%6ð ÀT÷ r rR c óB e Zd ZdZdedef fd Zdee de fdZ
|
xZ S )ÚHealthyAnyPolicyzT
|
Policy that returns True if at least one health check probe is successful.
|
r& r) c ó& t | ||« y r; rA rC s r r9 zHealthyAnyPolicy.__init__ rE r r* r c ó6 d}|D ]n }d }t | j « D ]C } |j |« rd} n-d} || j dz
|
k s/t | j « E |s|s|c S |rk|sn| |S # t $ r}t d||« }Y d }~Xd }~ww xY w)NFTrG r5 rH )r r* r Ú
|
is_healthyrK Ú exceptionrL rM s r r- zHealthyAnyPolicy.execute sº Ø
|
à )ò LØ Iä ×!9Ñ!9Ó:ò 4ð Ø#×0Ñ0°Ô:Ø%)
|
Ù à%*
|
ð T× 5Ñ 5¸Ñ 9Ó9Ü$×2Ñ2Õ3ð 4ñ ¡iØ!Ò!Ú ¢IØ ð+ ð. Ðøô !ò Ü :Ø,¨h¸ó!Iûðús £A8¸A8Á8 B BÂBrN rP s @r rX rX ~ s6 ø ñðB¨Cð BÀUõ Bð T¨+Ñ%6ð ÀT÷ r rX c ó e Zd ZeZeZeZy)ÚHealthCheckPoliciesN) r r r r? Ú HEALTHY_ALLrR ÚHEALTHY_MAJORITYrX Ú HEALTHY_ANYr r r r^ r^ £ s Ø"KØ,ÐØ"Kr r^ ÚDEFAULT_HEALTH_CHECK_POLICYc ó e Zd ZdZdefdZy)ÚPingHealthCheckz-
|
Health check based on PING command.
|
r c óê t |j t « r|j j d« S |j j « }|D ] }|j
|
j d« r y y)NÚPINGFT)Ú
|
isinstanceÚclientr Úexecute_commandÚ get_nodesÚredis_connection)r r Ú all_nodesÚnodes r r z PingHealthCheck.check_health± sd Ü hoo¤uÔ -Ø??×2Ñ2°6Ó:Ð :ð !×1Ñ1Ó3IØ!ò !Ø×,Ñ,×<Ñ<¸VÕDÙ ð !ð r N)r r r r. r! r r r r rd rd ¬ s ñð
|
¨ô
|
r rd c ó¦ e Zd ZdZdeeddddddddf dedededee e
|
e
|
f d e d
|
ee
|
d ee
|
d ee e
|
e f d ee
|
dee
|
dee
|
fdZde fdZy)ÚLagAwareHealthCheckz
|
Health check available for Redis Enterprise deployments.
|
Verify via REST API that the database is healthy based on different lags.
|
iã$ NTÚ rest_api_portÚlag_aware_toleranceÚtimeoutÚ
|
auth_basicÚ
|
verify_tlsÚca_fileÚca_pathÚca_dataÚclient_cert_fileÚclient_key_fileÚclient_key_passwordc óz t ||t t « d¬« ||||| |
|
| ¬«
|
| _ || _ || _ y)a£
|
Initialize LagAwareHealthCheck with the specified parameters.
|
|
Args:
|
rest_api_port: Port number for Redis Enterprise REST API (default: 9443)
|
lag_aware_tolerance: Tolerance in lag between databases in MS (default: 100)
|
timeout: Request timeout in seconds (default: DEFAULT_TIMEOUT)
|
auth_basic: Tuple of (username, password) for basic authentication
|
verify_tls: Whether to verify TLS certificates (default: True)
|
ca_file: Path to CA certificate file for TLS verification
|
ca_path: Path to CA certificates directory for TLS verification
|
ca_data: CA certificate data as string or bytes
|
client_cert_file: Path to client certificate file for mutual TLS
|
client_key_file: Path to client private key file for mutual TLS
|
client_key_password: Password for encrypted client private key
|
r )Úretries)
|
rr rs Úretryrt ru rv rw rx ry rz N)r r r Ú _http_clientÚ_rest_api_portÚ_lag_aware_tolerance) r rp rq rr rs rt ru rv rw rx ry rz s r r9 z LagAwareHealthCheck.__init__Ä sK ô@ 'ØØ!Ü ¨QÔ/Ø!ØØØØ -Ø +Ø 3ô
|
Ôð ,ÔØ$7Õ!r r c ó~ |j t d« t |j t « r |j j « d }n#|j j d j }|j d| j }|| j _
|
d }| j j d« D ]+ }|d D ]! }|d |k( r|} |d D ] }||k( s |} ! # - | t j d « t d
|
« d |d d | j }| j j |d¬« y)Nz[Database health check url is not set. Please check DatabaseConfig for the current database.Úhostr ú:z/v1/bdbsÚ endpointsÚdns_nameÚaddrz8LagAwareHealthCheck failed: Couldn't find a matching bdbz Could not find a matching bdbz /v1/bdbs/Úuidz=/availability?extend_check=lag&availability_lag_tolerance_ms=F)Ú expect_jsonT)Úhealth_check_urlr6 rg rh r Úget_connection_kwargsÚ startup_nodesr r r~ Úbase_urlÚgetÚloggerÚwarningr ) r r Údb_hostr Ú matching_bdbÚbdbÚendpointr Úurls r r z LagAwareHealthCheck.check_healthó sl Ø × $Ñ $Ð ,Ü Ømóð ô hoo¤uÔ -Ø oo×;Ñ;Ó=¸fÑEGà oo×3Ñ3°AÑ6×;Ñ;Gà ×/Ñ/Ð0°°$×2EÑ2EÐ1FÐGØ%-×ÑÔ"ð Ø×$Ñ$×(Ñ(¨Ó4ò
|
CØ Ñ ,ò ØJÑ'¨7Ò2Ø#&LÙð % VÑ ,ò DØwØ'* Ù ñ ñ ð
|
ð Ð Ü NNÐUÔ VÜ Ð <Ó=Ð =ð UÑ+Ð,ð -?Ø?C×?XÑ?XÐ>Yð [ð ð ×Ñ× Ñ c¨uÐ Ô5ð r )r r r r. ÚDEFAULT_LAG_AWARE_TOLERANCEr r0 r1 r r Ústrr! r
|
Úbytesr9 r r r r ro ro ¾ s× ñð "Ø#>Ø(Ø04Ø à!%Ø!%Ø/3à*.Ø)-Ø-1ñ -8àð-8ð !ð-8ð ð -8ð
|
U 3¨ 8_Ñ-ð -8ð ð -8ð # ð-8ð # ð-8ð % U
|
Ñ+Ñ,ð-8ð # 3-ð-8ð " # ð-8ð & c]ó -8ð^'¨ô 'r ro )+ÚloggingÚabcr r Úenumr Útimer Útypingr r r r
|
Úredisr Ú redis.backoffr Úredis.http.http_clientr r Úredis.multidb.exceptionr Ú redis.retryr ÚDEFAULT_HEALTH_CHECK_PROBESÚ DEFAULT_HEALTH_CHECK_INTERVALÚDEFAULT_HEALTH_CHECK_DELAYr Ú getLoggerr r r r# r3 r? rR rX r^ r_ rb Ú__annotations__rd ro r r r ú<module>r§ sÙ ðÜ ß #Ý Ý ß /Ó /å Ý #ß >Ý >Ý à Ð Ø !Ð Ø Ð Ø "Ð à × Ñ 8Ó $ô #ô ô ô ô. Ð 1ô ô(Ð0ô ô, Ð 5ô ôB"Ð0ô "ôJ#$ô #ð 4G×3RÑ3RÐ Ð 0Ó Rôkô ô$\+õ \r
|
