Ë
|
|
çúhº! ã óP d dl mZmZ d dlmZmZmZ d dlZd dlm Z d dl
|
m Z m Z m Z d dlmZmZ d dlmZ d dlmZmZ d d lmZmZmZ d d
|
lmZm Z d d l m Z m Z m Z m!Z! d d l"m#Z#m$Z$m%Z%m&Z&m'Z' d d l(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ d dl0m1Z1 dZ2defdZ3e G d d« « Z4e G d d« « Z5y)é )Ú dataclassÚfield)ÚListÚTypeÚUnionN)ÚOptional)ÚConnectionPoolÚRedisÚ RedisCluster)Ú ExponentialWithJitterBackoffÚ NoBackoff)Ú WeightedList)ÚEventDispatcherÚEventDispatcherInterface)ÚDEFAULT_GRACE_PERIODÚCircuitBreakerÚPBCircuitBreakerAdapter)ÚDatabaseÚ Databases)ÚDEFAULT_FAILOVER_ATTEMPTSÚDEFAULT_FAILOVER_DELAYÚFailoverStrategyÚWeightBasedFailoverStrategy)Ú DEFAULT_FAILURE_RATE_THRESHOLDÚ!DEFAULT_FAILURES_DETECTION_WINDOWÚDEFAULT_MIN_NUM_FAILURESÚCommandFailureDetectorÚFailureDetector)ÚDEFAULT_HEALTH_CHECK_DELAYÚ DEFAULT_HEALTH_CHECK_INTERVALÚDEFAULT_HEALTH_CHECK_POLICYÚDEFAULT_HEALTH_CHECK_PROBESÚ HealthCheckÚHealthCheckPoliciesÚPingHealthCheck)ÚRetryéx Úreturnc ó t « S ©N)r © ó õg H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/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 r8 r )ÚselfÚcircuit_breakers r- Údefault_circuit_breakerz&DatabaseConfig.default_circuit_breakerR s# Ü#×2Ñ2À×ARÑARÔSÜ& Ó7Ð7r, )Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r1 ÚfloatÚ__annotations__r Údictr4 r5 r Ústrr6 r r7 r r r8 r9 r? r+ r, r- r0 r0 0 ss
ñð0 FEÓÙ °Ô5M4Ó5Ø "HhsmÓ"Ø*.IxÑ'Ó.Ø(,GXnÑ %Ó,Ø.L%Ó.Ø&*ÐhsmÓ*ð8¨ ô 8r, r0 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
|
) Ú MultiDbConfigaÚ
|
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_probes_delay: Delay between health check attempts.
|
health_check_policy: Policy for determining database health based on health checks.
|
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_probes_delayÚhealth_check_policyÚfailover_strategyÚfailover_attemptsÚfailover_delayÚauto_fallback_intervalr2 Ú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 )rR rQ )Úconnection_pool)Úclientr7 r1 r9 r+ )r rJ r4 Úupdater& r r5 rK r6 Ú set_retryr7 r? Úaddr r1 r9 )r= Ú databasesÚdatabase_configre r7 s r- ri 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 ó\ t | j | j | j ¬« gS )N)rU rV Úfailure_detection_window)r rU rV rW ©r= s r- Údefault_failure_detectorsz'MultiDbConfig.default_failure_detectorsÀ s/ ä "Ø!%×!6Ñ!6Ø'+×'BÑ'BØ)-×)GÑ)Gô ð
|
ð
|
r, c ó t « gS r* )r% rm s r- Údefault_health_checksz#MultiDbConfig.default_health_checksÉ s ä Ó ð
|
ð
|
r, c ó t « S r* )r rm s r- Údefault_failover_strategyz'MultiDbConfig.default_failover_strategyÎ s Ü*Ó,Ð,r, )6r@ rA rB rC r r0 rE r
|
rK r r r r& r rS rT r r r rU Úintr rV rD r rW rX r# r rY r" rZ r r[ r! r\ r$ r] r r r^ r r_ Ú DEFAULT_AUTO_FALLBACK_INTERVALr` r r. ra r r ri rn rp rr r+ r, r- rI rI W sG
ñ&ðP >Ñ*Ó*Ø5:L$uU LÐ 0Ñ1Ñ2Ó:Ù Ù,°!¸Ô<Àaô M5ó ð :>Ðx _Ñ 5Ñ6Ó=Ø 4ÐcÓ4Ø$BÐEÓBØ'HÐ uÓHØ15M8D Ñ -Ñ.Ó5Ø#@Ð5Ó@Ø :ÐÓ:Ø'AÐ uÓAØ/JÐÐ,ÓJØ48ÐxÐ 0Ñ1Ó8Ø 6ÐsÓ6Ø 2NEÓ2Ø$BÐEÓBÙ16Ø0ô2ÐÐ.ó ð'9ó 'ðR
|
¨4°Ñ+@ó
|
ð
|
t¨KÑ'8ó
|
ð
|
-Ð+;ô -r, rI )6Ú dataclassesr r Útypingr r r r< Útyping_extensionsr Úredisr r
|
r Ú redis.backoffr r Úredis.data_structurer Ú redis.eventr r Úredis.multidb.circuitr r r Úredis.multidb.databaser r Úredis.multidb.failoverr r r r Ú redis.multidb.failure_detectorr r r r r Úredis.multidb.healthcheckr r r! r" r# r$ r% Ú redis.retryr& rt r. r0 rI r+ r, r- ú<module>r s£ ðß (ß $Ñ $ã Ý &ç 5Ñ 5ß AÝ -ß A÷ñ ÷
|
7÷ó ÷ õ ÷÷ ñ õ à!$Ð ð Ð":ó ð ÷#8ð #8ó ð#8ðL ÷w-ð w-ó ñw-r,
|
