Ë
|
|
çúhP( ã ó² U d dl Z d dlZd dlmZmZ d dlmZ d dlmZm Z m
|
Z
|
m Z d dl m Z d dlmZmZ d dlmZ d dlmZ d d lmZ d d
|
lmZ d Zd Zd ZdZ ej: 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&jN Z(e&e)d < G d d e « Z* G d d!e « Z+y)"é N)ÚABCÚabstractmethod)ÚEnum)ÚListÚOptionalÚTupleÚUnion)ÚRedis)ÚDEFAULT_TIMEOUTÚAsyncHTTPClientWrapper)Ú NoBackoff)Ú
|
HttpClient)ÚUnhealthyDatabaseException)ÚRetryé é g à?i c ó" e Zd Zedefd« Zy)Ú HealthCheckÚreturnc ó K yw)z(Function to determine the health status.N© )ÚselfÚdatabases õt H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/multidb/healthcheck.pyÚ check_healthzHealthCheck.check_health ó è ø ð ùó N)Ú__name__Ú
|
__module__Ú __qualname__r Úboolr r ó r r r s Øð ¨dò ó ñ 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 ó K yw)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ò ó ó ð ð ð ¨4° Ñ+<ð È4ò ó ñ 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__5 s& Ø Ò "Ü Ð IÓJÐ JØ$7Ô!Ø#5Õ r" r c ó | j S ©N)r8 r& s r r' z-AbstractHealthCheckPolicy.health_check_probes; s à×(Ñ(Ð(r" c ó | j S r< )r9 r& s r r* z,AbstractHealthCheckPolicy.health_check_delay? s à×'Ñ'Ð'r" r+ c ó K y wr< r r- s r r. z!AbstractHealthCheckPolicy.executeC s è ø à ùr N)r r r r1 r2 r: r0 r' r* r r r r! r. r r" r r4 r4 4 sr ð6¨Cð 6ÀUó 6ð ð) Sò )ó ð)ð ð( Eò (ó ð(ð ð ¨4° Ñ+<ð È4ò ó ñ r" r4 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< ©Úsuperr: ©r r' r* Ú __class__s r r: zHealthyAllPolicy.__init__M ó ø Ü ÑÐ,Ð.@ÕAr" r+ r c óB K |D ]t }t | j « D ]Z } |j |« d { s y || j dz
|
k s4t j | j « d { \ v y7 G# t $ r}t d||« d }~ww xY w7 )w)NFúUnhealthy databaser6 T©Úranger' r Ú Exceptionr ÚasyncioÚsleepr9 )r r+ r Ú health_checkÚattemptÚes r r. zHealthyAllPolicy.executeP s· è ø Ø )ò BLÜ ×!9Ñ!9Ó:ò BðXØ!-×!:Ñ!:¸8Ó!D×DÐDÚ $ð Eð
|
T× 5Ñ 5¸Ñ 9Ó9Ü!--¨×(@Ñ(@ÓA×AÑAñ Bð Bð ð Eùä ò XÜ4Ð5IÈ8ÐUVÓWÐWûðXúð BúsI B ¡A?µA=¶A?ºB Á"B Á3B Á4 B Á=A?Á? B BÂBÂB © r r r r/ r1 r2 r: r r r! r. Ú __classcell__©rE s @r r@ r@ H s6 ø ñðB¨Cð BÀUõ Bð ¨4° Ñ+<ð È4÷ 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< rB rD s r r: z HealthyMajorityPolicy.__init__c rF r" r+ r c óÚ K |D ]± }| j dz dk( r| j dz }n| j dz dz }t | j « D ]c } |j |« d { s |dz }|dk r y|| j dz
|
k s=t j | j « d { e ³ y7 P# t $ r!}|dz }|dk r t d||« Y d }~fd }~ww xY w7 8w)Né r r6 FrH T)r' rJ r rK r rL rM r9 )r r+ r rN Úallowed_unsuccessful_probesrO rP s r r. z HealthyMajorityPolicy.executef s è ø Ø )ò BLØ×'Ñ'¨!Ñ+¨qÒ0Ø.2×.FÑ.FÈÑ.JÑ+à/3×/GÑ/GÈ!Ñ/KÈqÑ.PÐ+ä ×!9Ñ!9Ó:ò Bð
|
Ø!-×!:Ñ!:¸8Ó!D×DÐDØ3°qÑ8Ð3Ø6¸!Ò;Ú#(ð T× 5Ñ 5¸Ñ 9Ó9Ü!--¨×(@Ñ(@ÓA×AÑAñ Bð Bð* ð Eùô !ò Ø/°1Ñ4Ð/Ø2°aÒ7Ü 8Ø 0°(¸Aó ð ô 8ûðúð BúsT AC+ÁB<Á)B:Á*B<Á8C+Â"C+Â0C)Â1 C+Â:B<Â< C&ÃC!à C+Ã!C&Ã&C+rQ rS s @r rU rU ^ s6 ø ñðB¨Cð BÀUõ Bð¨4° Ñ+<ð È4÷ r" rU 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< rB rD s r r: zHealthyAnyPolicy.__init__ rF r" r+ r c óz K d}|D ] }d }t | j « D ]] } |j |« d { rd} n?d} || j dz
|
k s7t j | j « d { _ |s|s|c S |r
|s| |S 7 Z# t $ r}t d||« }Y d }~ld }~ww xY w7 >w)NFTrH r6 rI )r r+ r Ú
|
is_healthyrN Ú exceptionrO rP s r r. zHealthyAnyPolicy.execute sÜ è ø Ø
|
à )ò LØ Iä ×!9Ñ!9Ó:ò Bð Ø )× 6Ñ 6°xÓ @×@Ð@Ø%)
|
Ù à%*
|
ð T× 5Ñ 5¸Ñ 9Ó9Ü!--¨×(@Ñ(@ÓA×AÑAð Bñ ¡iØ!Ò!Ú ¢IØ ð+ ð. Ðð% Aùô
|
!ò Ü :Ø,¨h¸ó!Iûðúð Búsh "B;¥B¹BºBÁ B;ÁBÁB;Á"B;Á:B9Á;B; B;ÂB;ÂB B6 B1Â,B;Â1B6Â6B;rQ rS s @r r[ r[ s6 ø ñðB¨Cð BÀUõ Bð¨4° Ñ+<ð È4÷ r" r[ c ó e Zd ZeZeZeZy)ÚHealthCheckPoliciesN) r r r r@ Ú HEALTHY_ALLrU ÚHEALTHY_MAJORITYr[ Ú HEALTHY_ANYr r" r ra ra ¤ s Ø"KØ,ÐØ"Kr" ra ÚDEFAULT_HEALTH_CHECK_POLICYc ó e Zd ZdZdefdZy)ÚPingHealthCheckz-
|
Health check based on PING command.
|
r c ó K t |j t « r#|j j d« d { S |j j « }|D ]' }|j
|
j d« d { r' y y7 K7 w)NÚPINGFT)Ú
|
isinstanceÚclientr
|
Úexecute_commandÚ get_nodesÚredis_connection)r r Ú all_nodesÚnodes r r z PingHealthCheck.check_health² s~ è ø Ü hoo¤uÔ -Ø! ×8Ñ8¸Ó@×@Ð @ð !×1Ñ1Ó3IØ!ò !Ø !× 2Ñ 2× BÑ BÀ6Ó J×JÑJÙ ð !ð ð Aøð
|
Kús( 9B »B¼AB Á=B Á>B ÂB Â B N)r r r r/ r! r r r" r rg rg s ñð
|
¨dô
|
r" rg 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 ó t 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)
|
ru rv Úretryrw rx ry rz r{ r| r} N)r r r r Ú _http_clientÚ_rest_api_portÚ_lag_aware_tolerance) r rs rt ru rv rw rx ry rz r{ r| r} s r r: z LagAwareHealthCheck.__init__Å sS ô@ 3Ü Ø Ø%ÜIK°Ô3Ø%Ø Ø Ø Ø!1Ø /Ø$7ô ó
|
Ôð ,ÔØ$7Õ!r" r c óÂ K |j t d« t |j t « r |j j « d }n#|j j d j }|j d| j }|| j j _
|
d }| j j d« d { D ]+ }|d D ]! }|d |k( r|} |d D ] }||k( s |} ! # - | t j d « t d
|
« d |d d | j }| j j |d¬« d { y7 7 w)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_urlr7 rj rk 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ö s è ø Ø × $Ñ $Ð ,Ü Ømóð ô hoo¤uÔ -Ø oo×;Ñ;Ó=¸fÑEGà oo×3Ñ3°AÑ6×;Ñ;Gà ×/Ñ/Ð0°°$×2EÑ2EÐ1FÐGØ,4×Ñ× Ñ Ô)ð Ø ×*Ñ*×.Ñ.¨zÓ:×:ò
|
CØ Ñ ,ò ØJÑ'¨7Ò2Ø#&LÙð % VÑ ,ò DØwØ'* Ù ñ ñ ð
|
ð Ð Ü NNÐUÔ VÜ Ð <Ó=Ð =ð UÑ+Ð,ð -?Ø?C×?XÑ?XÐ>Yð [ð ð × Ñ ×#Ñ# C°UÐ#Ó;×;Ð;ð ð/ ;øð( <ús+ C E Ã EÃ (E Ã5A E ÅE ÅE Å E )r r r r/ ÚDEFAULT_LAG_AWARE_TOLERANCEr r1 r2 r r Ústrr! r Úbytesr: r r r" r rr rr ¿ s× ñð "Ø#>Ø(Ø04Ø à!%Ø!%Ø/3à*.Ø)-Ø-1ñ /8àð/8ð !ð/8ð ð /8ð
|
U 3¨ 8_Ñ-ð /8ð ð /8ð # ð/8ð # ð/8ð % U
|
Ñ+Ñ,ð/8ð # 3-ð/8ð " # ð/8ð & c]ó /8ðb'¨dô 'r" rr ),rL ÚloggingÚabcr r Úenumr Útypingr r r r Ú redis.asyncior
|
Ú redis.asyncio.http.http_clientr r Ú redis.backoffr Úredis.http.http_clientr Úredis.multidb.exceptionr Ú redis.retryr ÚDEFAULT_HEALTH_CHECK_PROBESÚ DEFAULT_HEALTH_CHECK_INTERVALÚDEFAULT_HEALTH_CHECK_DELAYr Ú getLoggerr r r r$ r4 r@ rU r[ ra rb re Ú__annotations__rg rr r r" r ú<module>rª sÜ ðÜ Û ß #Ý ß /Ó /å ß RÝ #Ý -Ý >Ý à Ð Ø !Ð Ø Ð Ø "Ð à × Ñ 8Ó $ô #ô ô ô ô. Ð 1ô ô(Ð0ô ô, Ð 5ô ôB"Ð0ô "ôJ#$ô #ð 4G×3RÑ3RÐ Ð 0Ó Rôkô ô$^+õ ^r"
|
