Ë
|
|
çúh " ã óT d dl mZmZ d dlmZmZmZmZ d dlZd dl m
|
Z
|
m Z m Z d dl mZmZ d dlmZmZmZmZ d dlmZmZ d dlmZmZmZm Z m Z m Z m Z d d l m!Z! d d
|
l"m#Z#m$Z$ d d l%m&Z& d d l'm(Z(m)Z) d d l*m+Z+m,Z,m-Z- d dl.m/Z/m0Z0m1Z1m2Z2 dZ3de)fdZ4e G d d« « Z5e G d d« « Z6y)é )Ú dataclassÚfield)ÚListÚOptionalÚTypeÚUnionN)ÚConnectionPoolÚRedisÚ RedisCluster)ÚDatabaseÚ Databases)ÚDEFAULT_FAILOVER_ATTEMPTSÚDEFAULT_FAILOVER_DELAYÚAsyncFailoverStrategyÚWeightBasedFailoverStrategy)ÚAsyncFailureDetectorÚFailureDetectorAsyncWrapper)ÚDEFAULT_HEALTH_CHECK_DELAYÚ DEFAULT_HEALTH_CHECK_INTERVALÚDEFAULT_HEALTH_CHECK_POLICYÚDEFAULT_HEALTH_CHECK_PROBESÚ HealthCheckÚHealthCheckPoliciesÚPingHealthCheck)ÚRetry)Ú ExponentialWithJitterBackoffÚ NoBackoff)Ú WeightedList)ÚEventDispatcherÚEventDispatcherInterface)ÚDEFAULT_GRACE_PERIODÚCircuitBreakerÚPBCircuitBreakerAdapter)Ú DEFAULT_FAILURE_RATE_THRESHOLDÚ!DEFAULT_FAILURES_DETECTION_WINDOWÚDEFAULT_MIN_NUM_FAILURESÚCommandFailureDetectoréx Úreturnc ó t « S ©N)r © ó õo H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/multidb/config.pyÚdefault_event_dispatcherr/ . s Ü Ó Ð r- c ó¦ e Zd ZU dZdZeed< ee¬« Z eed< dZ
|
e e ed< dZ e e ed< dZe e ed < eZeed
|
< dZe e ed < d efd Zy)ÚDatabaseConfigaÝ
|
Dataclass representing the configuration for a database connection.
|
|
This class is used to store configuration settings for a database connection,
|
including client options, connection sourcing details, circuit breaker settings,
|
and cluster-specific properties. It provides a structure for defining these
|
attributes and allows for the creation of customized configurations for various
|
database setups.
|
|
Attributes:
|
weight (float): Weight of the database to define the active one.
|
client_kwargs (dict): Additional parameters for the database client connection.
|
from_url (Optional[str]): Redis URL way of connecting to the database.
|
from_pool (Optional[ConnectionPool]): A pre-configured connection pool to use.
|
circuit (Optional[CircuitBreaker]): Custom circuit breaker implementation.
|
grace_period (float): Grace period after which we need to check if the circuit could be closed again.
|
health_check_url (Optional[str]): URL for health checks. Cluster FQDN is typically used
|
on public Redis Enterprise endpoints.
|
|
Methods:
|
default_circuit_breaker:
|
Generates and returns a default CircuitBreaker instance adapted for use.
|
g ð?Úweight©Údefault_factoryÚ client_kwargsNÚfrom_urlÚ from_poolÚcircuitÚ grace_periodÚhealth_check_urlr) c óX t j | j ¬« }t |« S )N)Ú reset_timeout)Ú pybreakerr" r9 r# )ÚselfÚcircuit_breakers r. Údefault_circuit_breakerz&DatabaseConfig.default_circuit_breakerT s# Ü#×2Ñ2À×ARÑARÔSÜ& Ó7Ð7r- )Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r2 ÚfloatÚ__annotations__r Údictr5 r6 r Ústrr7 r r8 r" r! r9 r: r@ r, r- r. r1 r1 2 ss
ñð0 FEÓÙ °Ô5M4Ó5Ø "HhsmÓ"Ø*.IxÑ'Ó.Ø(,GXnÑ %Ó,Ø.L%Ó.Ø&*ÐhsmÓ*ð8¨ ô 8r- r1 c ó e Zd ZU dZee ed< eZe e
|
ee f ed< e e dd¬« d¬« Ze ed < d
|
Zeee ed < eZeed < eZeed < eZeed< d
|
Zeee ed< e Z eed< e Z eed< e Z!eed< e"Z#e$ed< d
|
Z%ee& ed< e'Z(eed< e)Z*eed< e+Z,eed< e-e.¬« Z/e0ed< de1fdZ2dee fd Z3dee fd Z4de&fd Z5y
|
) Ú MultiDbConfigaw
|
Configuration class for managing multiple database connections in a resilient and fail-safe manner.
|
|
Attributes:
|
databases_config: A list of database configurations.
|
client_class: The client class used to manage database connections.
|
command_retry: Retry strategy for executing database commands.
|
failure_detectors: Optional list of additional failure detectors for monitoring database failures.
|
min_num_failures: Minimal count of failures required for failover
|
failure_rate_threshold: Percentage of failures required for failover
|
failures_detection_window: Time interval for tracking database failures.
|
health_checks: Optional list of additional health checks performed on databases.
|
health_check_interval: Time interval for executing health checks.
|
health_check_probes: Number of attempts to evaluate the health of a database.
|
health_check_delay: Delay between health check attempts.
|
failover_strategy: Optional strategy for handling database failover scenarios.
|
failover_attempts: Number of retries allowed for failover operations.
|
failover_delay: Delay between failover attempts.
|
auto_fallback_interval: Time interval to trigger automatic fallback.
|
event_dispatcher: Interface for dispatching events related to database operations.
|
|
Methods:
|
databases:
|
Retrieves a collection of database clients managed by weighted configurations.
|
Initializes database clients based on the provided configuration and removes
|
redundant retry objects for lower-level clients to rely on global retry logic.
|
|
default_failure_detectors:
|
Returns the default list of failure detectors used to monitor database failures.
|
|
default_health_checks:
|
Returns the default list of health checks used to monitor database health
|
with specific retry and backoff strategies.
|
|
default_failover_strategy:
|
Provides the default failover strategy used for handling failover scenarios
|
with defined retry and backoff configurations.
|
Údatabases_configÚ client_classé é
|
)ÚbaseÚcapé )ÚbackoffÚretriesÚ command_retryNÚfailure_detectorsÚmin_num_failuresÚfailure_rate_thresholdÚfailures_detection_windowÚ health_checksÚhealth_check_intervalÚhealth_check_probesÚhealth_check_delayÚhealth_check_policyÚfailover_strategyÚfailover_attemptsÚfailover_delayÚauto_fallback_intervalr3 Úevent_dispatcherr) c óà t « }| j D ]S }|j j dt dt « ¬« i« |j r2 | j j |j fi |j ¤}n}|j rU|j j t dt « ¬« « | j j |j ¬« }n | j di |j ¤}|j |j « n |j }|j t |||j |j ¬« |j « V |S )NÚretryr )rS rR )Úconnection_pool)Úclientr8 r2 r: r, )r rK r5 Úupdater r r6 rL r7 Ú set_retryr8 r@ Úaddr r2 r: )r> Ú databasesÚdatabase_configrf r8 s r. rj zMultiDbConfig.databases sY Ü N à #× 4Ñ 4ó " Oð × )Ñ )× 0Ñ 0Ø%¨´9³;Ô?Ð@ô ð ×'Ò'Ø3×*Ñ*×3Ñ3Ø#×,Ñ,ñØ0?×0MÑ0Mñð !×*Ò*Ø ×)Ñ)×3Ñ3Ü !¬Y«[Ô9ôð ×*Ñ*×4Ñ4Ø$3×$=Ñ$=ð 5ó ð +×*Ñ*ÑK¨_×-JÑ-JÑKð #×*Ñ*Ð2ð ×7Ñ7Ô9à$×,Ñ,ð ð
|
MMÜØ!Ø #Ø*×1Ñ1Ø%4×%EÑ%Eô ð ×&Ñ&ö ð5" ðH Ðr- c ón t t | j | j | j ¬« « gS )N)rV rW Úfailure_detection_window)r r' rV rW rX ©r> s r. Údefault_failure_detectorsz'MultiDbConfig.default_failure_detectorsÁ s7 ä 'Ü&Ø%)×%:Ñ%:Ø+/×+FÑ+FØ-1×-KÑ-Kôó ð
|
ð
|
r- c ó t « gS r+ )r rn s r. Údefault_health_checksz#MultiDbConfig.default_health_checksÌ s ä Ó ð
|
ð
|
r- c ó t « S r+ )r rn s r. Údefault_failover_strategyz'MultiDbConfig.default_failover_strategyÑ s Ü*Ó,Ð,r- )6rA rB rC rD r r1 rF r
|
rL r r r r r rT rU r r r& rV Úintr$ rW rE r% rX rY r r rZ r r[ r r\ r r] r r^ r r r_ r r` Ú DEFAULT_AUTO_FALLBACK_INTERVALra r r/ rb r r rj ro rq rs r, r- r. rJ rJ Y sJ
ñ%ðN >Ñ*Ó*Ø5:L$uU LÐ 0Ñ1Ñ2Ó:Ù Ù,°!¸Ô<Àaô M5ó ð ?CÐx Ð%9Ñ :Ñ;ÓBØ 4ÐcÓ4Ø$BÐEÓBØ'HÐ uÓHØ15M8D Ñ -Ñ.Ó5Ø#@Ð5Ó@Ø :ÐÓ:Ø :ÐÓ:Ø/JÐÐ,ÓJØ9=ÐxÐ 5Ñ6Ó=Ø 6ÐsÓ6Ø 2NEÓ2Ø$BÐEÓBÙ16Ø0ô2ÐÐ.ó ð'9ó 'ðR
|
¨4Ð0DÑ+Eó
|
ð
|
t¨KÑ'8ó
|
ð
|
-Ð+@ô -r- rJ )7Ú dataclassesr r Útypingr r r r r= Ú redis.asyncior r
|
r Ú redis.asyncio.multidb.databaser r Ú redis.asyncio.multidb.failoverr r r r Ú&redis.asyncio.multidb.failure_detectorr r Ú!redis.asyncio.multidb.healthcheckr r r r r r r Úredis.asyncio.retryr Ú redis.backoffr r Úredis.data_structurer Ú redis.eventr r Úredis.multidb.circuitr! r" r# Ú redis.multidb.failure_detectorr$ r% r& r' ru r/ r1 rJ r, r- r. ú<module>r s¥ ðß (ß .Ó .ã ç =Ñ =ß >÷ó ÷ ÷÷ ñ õ &ß AÝ -ß A÷ñ ÷
|
ó ð "%Ð ð Ð":ó ð ÷#8ð #8ó ð#8ðL ÷x-ð x-ó ñx-r-
|
