h UddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZddlmZddlmZmZmZmZmZmZmZddlmZmZmZdd lmZmZmZm Z m!Z!dd l"m#Z#m$Z$m%Z%m&Z&dd l'm(Z(dd l)m*Z*m+Z+dd l,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4ddl5m6Z6ddlm7Z7m8Z8ddl9m:Z:m;Z;mZ>m?Z?e;rddl@Z@dZAdZBdZCdZDdZEeFZGeee%e&e$feHd<e;re$ZIne%ZIGddZJGddZKGddZLGddeLZMGdd eMZNGd!d"eLZOd#ZPd$ZQeReSeSeQeQeTeReReQeSd% ZUd&ZVGd'd(ZWGd)d*eWZXy)+N)abstractmethod)chain)EmptyFull LifoQueue)time)AnyCallableListOptionalSequenceTypeUnion)parse_qsunquoteurlparse)DEFAULT_ALLOW_LISTDEFAULT_DENY_LISTDEFAULT_EVICTION_POLICY AbstractCache _LocalCache)Encoder_HiredisParser _RESP2Parser _RESP3Parser) NoBackoff)CredentialProvider"UsernamePasswordCredentialProvider)AuthenticationError$AuthenticationWrongNumberOfArgsErrorChildDeadlockedErrorConnectionError DataError RedisError ResponseError TimeoutError)Retry)KeysT ResponseT)CRYPTOGRAPHY_AVAILABLEHIREDIS_AVAILABLEHIREDIS_PACK_AVAILABLE SSL_AVAILABLEget_lib_version str_if_bytes*$s  DefaultParserceZdZdefdZy)HiredisRespSerializerargscg}t|dtr1t|djj |ddz}n)d|dvr"t|dj |ddz} |j t j||S#t$r3tj\}}}t|j|wxYw2Pack a series of arguments into the Redis protocolrrN ) isinstancestrtupleencodesplitappendhiredis pack_command TypeErrorsysexc_infor$with_traceback)selfr8output_value tracebacks [/var/www/html/retail-simulation-api/retail/lib/python3.12/site-packages/redis/connection.pypackzHiredisRespSerializer.packBs d1gs #a)//12T!"X=D T!W_a)DH4D = MM'..t4 5   ="%,,. AuiE"11)< < =s 1$Br?r@rA SYM_EMPTYjoinSYM_STARlenSYM_CRLFrXmap memoryview SYM_DOLLARrB)rIr8rJbuffrYarg arg_lengths rNrOzPythonRespSerializer.packXsd d1gs #a)//12T!"X=D T!W_a)DH4D~~xSY)>)>)@(KL++ t{{D)CSJD M) -c:. ~~:s:'='='?J d# c" ~~"J..0   !*4  d r3returnN)rPrQrRrZrOrSr3rNrUrUSs +r3rUc6~eZdZdZdddddedddeddddeddddd dddd deee fd e d e e d e e de e dede de dede de de e de e de e de e deedfde egdfde ede e de egdfdede ed e d!e d"e d#ee d$ee f4d%Zd&Zed'Zd(Zd)Zd*Zd+Zd,Zd-Zed.Zed/Z ed0Z!d1Z"d2Z#d3Z$d4Z%d5Z&dJd7Z'd8Z(dKd9Z) dLd6dd:d;Z*d<Z+d=Z,d>eee e ee fd?dfd@Z-dAe.e fdBZ/dAe.e dCe0dDee1fdEZ2dFZ3dAee e.e ffdGZ4dHe1fdIZ5y)MAbstractConnectionz0Manages communication to and from a Redis serverrNFutf-8strictizredis-pyr4i'dbpasswordsocket_timeoutsocket_connect_timeoutretry_on_timeoutencodingencoding_errorsdecode_responsessocket_read_sizehealth_check_interval client_namelib_name lib_versionusernameretryredis_connect_funccredential_providerprotocolcommand_packer cache_enabled client_cachecache_max_size cache_ttl cache_policycache_deny_listcache_allow_listcr|s|r | tdtj|_||_| |_||_||_||_||_ ||_ ||_ ||}||_ ||_ |turg}|r|jt ||_|s|rR|t%t'd|_nt+j,||_|j(j/|nt%t'd|_| |_d|_||_t7||| |_d|_| |_|j?| g|_ d|_! tE|}|dks|dkDr tMd ||_'|jQ||_)|rtU|||}nd}||n||_+|jV(|jNd vr tYd ||_-||_.yy#tF$r tH}YtJ$r tMdwxYw#dks|dkDr tMd ||_'wxYw) a2 Initialize a new Connection. To specify a retry policy for specific errors, first set `retry_on_error` to a list of the error/s to retry on, then set `retry` to a valid `Retry` object. To retry on TimeoutError, `retry_on_timeout` can also be set to `True`. Nz'username' and 'password' cannot be passed along with 'credential_provider'. Please provide only one of the following arguments: 1. 'password' and (optional) 'username' 2. 'credential_provider'rripzprotocol must be an integerr4zprotocol must be either 2 or 3)r3zBclient caching is only supported with protocol version 3 or higher)/r$osgetpidpidrmrwrxryr}rnrzrorprqSENTINELrBr'retry_on_errorr(rr{copydeepcopyupdate_supported_errorsrvnext_health_checkr|rencoder_sock_socket_read_size set_parser_connect_callbacksrXintrEDEFAULT_RESP_VERSION ValueErrorr#r~_construct_command_packer_command_packerrrr%rr)rIrmrnrorprqrrrrsrt parser_classrurvrwrxryrzr{r|r}r~rrrrrrrrp_caches rNrZzAbstractConnection.__init__sGL &9&E+  99;&  &#6     , ! )%3 "&<# 0 X %N   ! !, /, N}"9;2 "]]51 JJ . .~ >y{A.DJ%:"!""4x:JK  !1  %"$" H A 1uA%&FGGDM#==nM  LIFF,8,DL&    (}}H, X$3D $4D ! ) %$A A!"?@ @ A1uA%&FGGDMs$! G00H?HHHH6c dj|jDcgc] \}}|d|c}}}d|jjd|jjd|dScc}}w)N,=<.()>)r] repr_pieces __class__rQrP)rIkv repr_argss rN__repr__zAbstractConnection.__repr__spHHT5E5E5GH5GTQ1QCj5GHI 4>>,,-Qt~~/F/F.Gq SUVVIsA, cyrWrSrIs rNrzAbstractConnection.repr_pieces r3cD |jy#t$rYywxYwrW) disconnect Exceptionrs rN__del__zAbstractConnection.__del__s#  OO    s  c~||Str tSt|j|jj SrW)r-r7rUrXrr@)rIpackers rNrz,AbstractConnection._construct_command_packers6  M #(* *'(;(;T\\=P=PQ Qr3ctj|}||jvr|jj|yy)a^ Register a callback to be called when the connection is established either initially or reconnected. This allows listeners to issue commands that are ephemeral to the connection, for example pub/sub subscription or key tracking. The callback must be a _method_ and will be kept as a weak reference. N)weakref WeakMethodrrB)rIcallbackwms rNregister_connect_callbackz,AbstractConnection.register_connect_callback s;   ) T,, ,  # # * *2 . -r3c |jjtj|y#t$rYywxYw)z De-register a previously registered callback. It will no-longer receive notifications on connection events. Calling this is not required when the listener goes away, since the callbacks are kept as weak methods. N)rremoverrr)rIrs rNderegister_connect_callbackz.AbstractConnection.deregister_connect_callbacks8    # # * *7+=+=h+G H   s .1 ==c4||j|_y)z Creates a new instance of parser_class with socket size: _socket_read_size and assigns it to the parser for the connection :param parser_class: The required parser class )ruN)r_parser)rIrs rNrzAbstractConnection.set_parser"s $T5K5KL r3c<jry jjfdfd}|_ jjnjjDcgc] }|s |c}_ jD]}|}|s |y#tj$r t dt $r}tj|d}~wwxYw#t$rjwxYwcc}w)z5Connects to the Redis server if not already connectedNc$jSrW)_connectrsrNz,AbstractConnection.connect..0s  r3c&j|SrWr)errorrIs rNrz,AbstractConnection.connect..0stu7Mr3zTimeout connecting to server)rr{call_with_retrysockettimeoutr'OSErrorr#_error_messager| on_connectr%rr)rIsockerefrs` rNconnectzAbstractConnection.connect*s ::  :::--')MD  &&.!''-372I2I"S2I3SU32I"S**CuH+-~~ ?=> > :!$"5"5a"89 9 :  OO   #Ts."B3.C;6 DD3&C8C33C8;DcyrWrSrs rNrzAbstractConnection._connectMrr3cyrWrSrs rN _host_errorzAbstractConnection._host_errorQrr3cyrWrS)rI exceptions rNrz!AbstractConnection._error_messageUrr3c`|jj||j}d}|js|js |jr>|jxs t |j|j}|j }|r|jdvrt|jtrK|jt|j|j_ |jj|t|dk(rd|dg}|jd|jdg||j}n(|r@|jdg|dd i |j}t#|d k7rt%d |jdvrt|jtrK|jt|j|j_ |jj||jd|j|j}|j'd|jk7r)|j'd|jk7r t)d|j*rD|jdd|j*t#|jd k7r t)d |j,r.|jddd|j,|j |j0r.|jddd|j0|j|j2rC|jd|j2t#|jd k7r t)d|j4rI|jddd|j|jj7|j8yy#t $r+|jd|d d |j}YwxYw#t.$rY#wxYw#t.$rYwxYw)z=Initialize the connection, authenticate and select a databaseN)r42rdefaultrHELLOAUTH check_healthFrOKzInvalid Username or PasswordsprotoprotozInvalid RESP versionCLIENTSETNAMEzError setting client nameSETINFOzLIB-NAMEzLIB-VERSELECTzInvalid DatabaseTRACKINGON)rrr}rzrnrget_credentialsr~r=rrrEXCEPTION_CLASSESr_ send_command read_responser!r0r getr#rwrxr&ryrmrset_invalidation_push_handler_cache_invalidation_process)rIparser auth_args cred_providerresponse auth_responses rNrzAbstractConnection.on_connectYs %  # # ((T5dmmT]]S &557I h6$,, 5 -171I1I . ''-9~"& ! 5 D  gt}}f Iy I))+H  D  f Ey Eu E 5 $ 2 2 4 M*d2)*HII]]( *$,, 5 -171I1I . ''-   gt}} 5))+H X&$--7LL)T]]:%&<==      h 43C3C DD..01T9%&ABB }}!!(Iz4==Q""$ !!(Iy$BRBRS""$ 77   h 0D..01T9%&899      h D 9    LL 6 6t7W7W X m8 5 !!&)B-e!L $ 2 2 4  5J      s6 O:P;:P!0P P PP! P-,P-c|jj|j}d|_|ytj|j k(r |j tj |j|jr|jjyy#ttf$rYJwxYw#t$rYHwxYw)z!Disconnects from the Redis serverN)r on_disconnectrrrrshutdownr SHUT_RDWRrrEcloserflush)rIr8 conn_socks rNrzAbstractConnection.disconnects ""$JJ     99;$(( " ""6#3#34  OO        # # % Y'      s$B+3C+B=<B= C  C cx|jddt|jdk7r tdy)z Send PING, expect PONG in returnPINGFrPONGz#Bad response from PING health checkN)rr0rr#rs rN _send_pingzAbstractConnection._send_pings< &u5 **, - 7!"GH H 8r3c$|jy)z Function to call when PING failsNr)rIrs rN _ping_failedzAbstractConnection._ping_failed  r3c|jrIt|jkDr1|jj |j |j yyy)z3Check the health of the connection with a PING/PONGN)rvrrr{rrrrs rNrzAbstractConnection.check_healthsA  % %$&43I3I*I JJ & &t8I8I J+J %r3TcN|js|j|r|j t|tr|g}|D]}|jj |y#t j$r|jtdt$ro}|jt|jdk(rd|jd}}n|jd}|jd}td|d|dd}~wt$r|jwxYw) z2Send an already packed command to the Redis serverzTimeout writing to socketrUNKNOWNrError z while writing to socket. rN)rrrr=r>sendallrrrr'rr_r8r# BaseException)rIcommandritemrerrnoerrmsgs rNsend_packed_commandz&AbstractConnection.send_packed_commandszz LLN      '3'") ""4( ~~ < OO :; ; W OO 166{a )166!9vq !F5'1KF8ST"UV V  OO    s5A&&6D$A*DD$cx|j|jj||jddy)z+Pack and send a command to the Redis serverrTrN)r rrOr)rIr8kwargss rNrzAbstractConnection.send_commands9   %D % %t ,ND9 ! r3c|j}|s|j|j} |jj |S#t $r0}|j td|d|jd}~wwxYw)z8Poll the socket to see if there's data that can be read.Error while reading from z: N) rrrrcan_readrrr#r8)rIrr host_errorrs rNrzAbstractConnection.can_readsyzz LLN%%'  V<<((1 1 V OO !$=j\AFF8"TU U VsA B+A??B)disconnect_on_error push_requestc\|j} |jdvr$ts|jj ||}n|jj |}|jrt|jz|_t!|t"r ||S#t j $r!|r|jtd|t$r2}|r|jtd|d|jd}~wt$r|r|jwxYw#~wxYw)z0Read the response from a previously sent command)rr)disable_decodingr)rzTimeout reading from rz : N)rr~r,rrrrrr'rr#r8rrvrrr=r&)rIrrrrrrs rNrz AbstractConnection.read_responses(%%'  }}(1B<<55%5L6 <<55GW5X&  % %%)Vd.H.H%HD " h . 5~~ E"!!6zlCD D "!!+J<3qvvhG  #!   s$ABD(;D%-D D%(D+c4|jj|S)r;)rrO)rIr8s rNrDzAbstractConnection.pack_commandAs(t##(($//r3cg}g}d}|j}|D]}|jj|D]}t|}||kDs||kDst |t r*|r$|j tj|d}g}||kDst |t r|j |y|j |||z }|r$|j tj||S)z.Pack multiple commands into the Redis protocolr) rXrrOr_r=rbrBr\r]) rIcommandsrJpieces buffer_lengthrYcmdchunkchunklens rN pack_commandsz AbstractConnection.pack_commandsEs ++ C2--22C8u:!M1-/!%4 innV&<=$%MFm+z%/LMM%(MM%(!X-M!9&  MM)..0 1 r3datarhc|d|jjy|dD]&}|jjt|(y)a6 Invalidate (delete) all redis commands associated with a specific key. `data` is a list of strings, where the first string is the invalidation message and the second string is the list of keys to invalidate. (if the list of keys is None, then all keys are invalidated) rN)rrinvalidate_keyr0)rIrkeys rNrz.AbstractConnection._cache_invalidation_processcsF 7?    # # %Aw!!00c1BCr3rc|j"|d|jvs|d|jvry|jr#|j d|jr#|jj |S)zK If the command is in the local cache, return the response NrT)r)rrrrrrrIrs rN_get_from_local_cachez(AbstractConnection._get_from_local_cacherss    %qzT111qz!6!66mmo   D  1mmo  $$W--r3rkeysc|j`|jgk(s|d|jvr?|jgk(s|d|jvr|jj|||yyyy)zp Add the command and response to the local cache if the command is allowed to be cached Nr)rrrset)rIrrr&s rN_add_to_local_cachez&AbstractConnection._add_to_local_cachesw    )%%+wqzAUAU/U&&", d>S>S0S    ! !'8T :1T0V *r3cR|jr|jjyyrW)rrrs rN flush_cachezAbstractConnection.flush_caches"       # # % r3cT|jr|jj|yyrW)rdelete_commandr$s rNdelete_command_from_cachez,AbstractConnection.delete_command_from_caches$       , ,W 5 r3r"cT|jr|jj|yyrW)rr!)rIr"s rNinvalidate_key_from_cachez,AbstractConnection.invalidate_key_from_caches$       , ,S 1 r3T)r)F)6rPrQrR__doc__rr5r/rrrrr r>floatboolrr r rrr rZrrrrrrrrrrrrrrrrrr rrrrDrrr r%r*r)r)r+r.r0rSr3rNrjrjs06"&*.26!&'!&" %%&%)",%4%6"&"&;?<@"#7;#04#3%6&8;j5 j53-j5! j5 !) j5  j5j5j5j5j5 #j5c]j53-j5 c]!j5"3-#j5$S$Y%j5&%Xb$h%78'j5(&&89)j5*3-+j5,!"d(!34-j5./j50}-1j523j545j567j58c9j5:s);j5XW   R / M!F      ^Y@&.I K >  V ,! ,\0< DsHT#Y$7789 D  D .Xc] . ;} ;09 ;AEe ;&6sHSM7I1J62U2r3rjcFeZdZdZ dfd ZdZdZdZdZxZ S) Connectionz4Manages TCP communication to and from a Redis serverc ||_t||_||_|xsi|_||_t |di|yNrS)hostrportsocket_keepalivesocket_keepalive_options socket_typesuperrZ)rIr9r:r;r<r=r rs rNrZzConnection.__init__sD I 0(@(FB%& "6"r3cd|jfd|jfd|jfg}|jr|j d|jf|S)Nr9r:rmrw)r9r:rmrwrBrIrs rNrzConnection.repr_piecessM499% ':T477OL    MM=$*:*:; < r3c@d}tj|j|j|jtj D]}|\}}}}}d} tj|||}|j tjtjd|jrr|j tjtjd|jjD]&\} } |j tj| | (|j|j|j!||j|j"|cS||t%d#t$$r} | }||j'Yd} ~ Qd} ~ wwxYw)zCreate a TCP socket connectionNrz)socket.getaddrinfo returned an empty list)r getaddrinfor9r:r= SOCK_STREAM setsockopt IPPROTO_TCP TCP_NODELAYr; SOL_SOCKET SO_KEEPALIVEr<items settimeoutrprrorr) rIerrresfamilysocktyper canonnamesocket_addressrrrrKs rNrzConnection._connects\ %% IItyy$"2"2F4F4F CBE >FHeYD !}}VXu= 2 2F4F4FJ((OOF$5$5v7J7JAN $ = = C C E1(:(:AqA!F ; ;< ^, 3 34 1 > ?IABB !#JJL !sD E55 F>FFc8|jd|jS)N:)r9r:rs rNrzConnection._host_errors))Adii[))r3cR|j}t|jdk(r d|d|jddS d|jdd|d |jddS#t$rd|jdcYSwxYw#t$rd|jdcYSwxYw) NrzError connecting to z. rrzConnection Error: rz connecting to . )rr_r8AttributeErrorrIrrs rNrzConnection._error_messages%%' y~~ ! # @-j\:"*+1..  @Y^^A./!l"Y^^A%6$7q: " @+INN1,=+>?? @" @+INN1,=+>?? @s#A'%B'BBB&%B&) localhostiFNr rPrQrRr2rZrrrr __classcell__rs@rNr6r6s3: !% #  'CR*@r3r6cJeZdZdZ dfd ZfdZxZS) SSLConnectionzManages SSL connections to and from the Redis server(s). This class extends the Connection class, adding SSL functionality, and making use of ssl.SSLContext (https://docs.python.org/3/library/ssl.html#ssl.SSLContext) c ts td||_||_|tj }nWt |trGtj tjtjd}||vrtd|||}||_ ||_ ||_ ||_ ||_||_| |_| |_| |_| |_| |_||_t-|\di|y)aConstructor Args: ssl_keyfile: Path to an ssl private key. Defaults to None. ssl_certfile: Path to an ssl certificate. Defaults to None. ssl_cert_reqs: The string value for the SSLContext.verify_mode (none, optional, required). Defaults to "required". ssl_ca_certs: The path to a file of concatenated CA certificates in PEM format. Defaults to None. ssl_ca_data: Either an ASCII string of one or more PEM-encoded certificates or a bytes-like object of DER-encoded certificates. ssl_check_hostname: If set, match the hostname during the SSL handshake. Defaults to False. ssl_ca_path: The path to a directory containing several CA certificates in PEM format. Defaults to None. ssl_password: Password for unlocking an encrypted private key. Defaults to None. ssl_validate_ocsp: If set, perform a full ocsp validation (i.e not a stapled verification) ssl_validate_ocsp_stapled: If set, perform a validation on a stapled ocsp response ssl_ocsp_context: A fully initialized OpenSSL.SSL.Context object to be used in verifying the ssl_ocsp_expected_cert ssl_ocsp_expected_cert: A PEM armoured string containing the expected certificate to be returned from the ocsp verification service. ssl_min_version: The lowest supported SSL version. It affects the supported SSL versions of the SSLContext. None leaves the default provided by ssl module. ssl_ciphers: A string listing the ciphers that are allowed to be used. Defaults to None, which means that the default ciphers are used. See https://docs.python.org/3/library/ssl.html#ssl.SSLContext.set_ciphers for more information. Raises: RedisError z$Python wasn't built with SSL supportN)noneoptionalrequiredz+Invalid SSL Certificate Requirements Flag: rS)r.r%keyfilecertfilessl CERT_NONEr=r> CERT_OPTIONAL CERT_REQUIRED cert_reqsca_certsca_dataca_pathcheck_hostnamecertificate_passwordssl_validate_ocspssl_validate_ocsp_stapledssl_ocsp_contextssl_ocsp_expected_certssl_min_version ssl_ciphersr>rZ)rI ssl_keyfile ssl_certfile ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostname ssl_ca_path ssl_passwordrmrnrorprqrrr  CERT_REQSrs rNrZzSSLConnection.__init__sPCD D" $  MMM  s + ----I I- A-Q&m4M&$ " " 0$0!!2)B& 0&<#.& "6"r3cJt |}tj}|j|_|j |_|js |jr2|j|j|j|j|j|j |j2|j|j|j|j|j|j|_|j"r|j%|j"|j'||j(}|j*durt,dur t/d|j0r|j*r t/d|j0r+d dl}d d lm}|j8f|j:j=|j:j>}|jA|j|jC|jn |j8}|jE||jF|j:jI|tKjJ}|jM|jO|j(|jPf|jS|jU|S|j*durRt,rLd d lm+}|||j(|jP|j} | jYr|St[d |S)z Wrap the socket with SSL support)rbrarnN)cafilecapathcadata)server_hostnameTFzcryptography is not installed.zKEither an OCSP staple or pure OCSP connection must be validated - not both.rr)ocsp_staple_verifier) OCSPVerifierzocsp validation error).r>rrccreate_default_contextrkrg verify_moderbraload_cert_chainrlrhrjriload_verify_locationsrqminimum_versionrr set_ciphers wrap_socketr9rmr+r%rnOpenSSLocsprroSSLContext SSLv23_METHODuse_certificate_fileuse_privatekey_fileset_ocsp_client_callbackrpr6r request_ocsprr: do_handshakerris_validr#) rIrcontextsslsockrr staple_ctxconrors rNrzSSLConnection._connectDsw!,,.!%!4!4"nn ==DLL  # # 22 $  MM %||'||'  ) )}}T\\$,, *     +&*&:&:G #       0 0 1%%dDII%F  ! !T ).D.M=> >  ) )d.D.D   ) )  2$$,$[[001J1JK // >..t||<!22  / /$d&A&A  ++((V]]_EC     KKDII. /     LLNN  ! !T ).D *WdiiDMMJAzz|%&=>>r3)NNr`NNFNNFFNNNN)rPrQrRr2rZrrYrZs@rNr\r\sG  "'#F#PEEr3r\c<eZdZdZdfd ZdZdZdZdZxZ S)UnixDomainSocketConnectionz4Manages UDS communication to and from a Redis serverc @||_||_t| di|yr8)pathror>rZ)rIrror rs rNrZz#UnixDomainSocketConnection.__init__s" , "6"r3cd|jfd|jfg}|jr|jd|jf|S)Nrrmrw)rrmrwrBr@s rNrz&UnixDomainSocketConnection.repr_piecessB499%dgg7    MM=$*:*:; < r3c tjtjtj}|j|j|j |j |j|j|S)z&Create a Unix domain socket connection)rAF_UNIXrCrJrprrro)rIrs rNrz#UnixDomainSocketConnection._connectsU}}V^^V-?-?@ 334 TYY ++, r3c|jSrW)rrs rNrz&UnixDomainSocketConnection._host_errors yyr3c|j}t|jdk(rd|d|jddSd|jdd|d|jddS)Nrz!Error connecting to unix socket: rTrrrz connecting to unix socket: )rr_r8rVs rNrz)UnixDomainSocketConnection._error_messages}%%' y~~ ! #3Jupper FALSE_STRINGSr4)rLs rNto_boolrs4 } %%++-="@ ;r3) rmrorpr;rqrmax_connectionsrvrxrcB|jds-|jds|jds tdt|}i}t|jj D]N\}}|s t |dkDst|d}tj|}|r ||||<J|||<P|jrt|j|d<|jrt|j|d <|jd k(r/|jrt|j|d <t|d <|S|j rt|j |d <|j"rt%|j"|d<|jr6d|vr2 t%t|jj'dd|d<|jdk(r t*|d <|S#ttf$rtd|dwxYw#t(tf$rYMwxYw)Nzredis://z rediss://zunix://zRRedis URL must specify one of the following schemes (redis://, rediss://, unix://)rzInvalid value for `z` in connection URL.rzrnunixrconnection_classr9r:rm/rrediss) startswithrrrqueryrIr_rURL_QUERY_ARGUMENT_PARSERSrrErzrnschemerrhostnamer:rreplacerUr\)urlr namerLrs rN parse_urlrs z" >>+ & >>) $ 5  3-C F *002 e SZ!^E!H%E/33D9FW#)%=F4L %t 3 ||$S\\2z ||$S\\2z zzV 88$SXX.F6N%?!"& M! <<$S\\2F6N 88 ]F6N 88F* "7388#4#<# - `rediss://` creates a SSL wrapped TCP socket connection. See more at: - ``unix://``: creates a Unix Domain Socket connection. The username, password, hostname, path and all querystring values are passed through urllib.parse.unquote in order to replace any percent-encoded values with their corresponding characters. There are several ways to specify a database number. The first value found will be used: 1. A ``db`` querystring option, e.g. redis://localhost?db=0 2. If using the redis:// or rediss:// schemes, the path argument of the url, e.g. redis://localhost/0 3. A ``db`` keyword argument to this function. If none of these options are specified, the default db=0 is used. All querystring options are cast to their appropriate Python types. Boolean arguments can be specified with string values "True"/"False" or "Yes"/"No". Values that cannot be properly cast cause a ``ValueError`` to be raised. Once parsed, the querystring arguments and keyword arguments are passed to the ``ConnectionPool``'s class initializer. In the case of conflicting arguments, querystring arguments always win. rrS)rupdate)clsrr  url_optionss rNfrom_urlzConnectionPool.from_urls?R n  '.45G.HK* + k"}V}r3Nrc |xsd}t|tr|dkr td||_||_||_t j|_|jy)Nlrz,"max_connections" must be a positive integer) r=rrrconnection_kwargsr threadingLock _fork_lockreset)rIrrrs rNrZzConnectionPool.__init__Es\ *2U/3/?Q3FKL L 0!2.$..* r3rhc dt|jdt|jdt|jdi|j dS)NrrrrrS)typerQrPreprrrrs rNrzConnectionPool.__repr__^sVT %%&aT (;(;'<*T**DT-C-CDEFb J r3ctj|_d|_g|_t |_tj|_ y)Nr) rr_lock_created_connections_available_connectionsr(_in_use_connectionsrrrrs rNrzConnectionPool.resetds9^^% $%!&(##&5 99;r3cf|jtjk7rq|jj d}|st  |jtjk7r|j |jjyy#|jjwxYw)N)r)rrrracquirer"rrelease)rIacquireds rN _checkpidzConnectionPool._checkpidusF 88ryy{ "..q.9H** *88ryy{*JJL'') #'')s 1BB0 command_namer6cd|j|j5 |jj}|j j|ddd j |jr|j td|S#t$r|j }YywxYw#1swYcxYw#ttf$r?|j|j|jr tdY|SwxYw#t$r|jwxYw)zGet a connection from the poolNConnection has dataConnection not ready)rrrpop IndexErrormake_connectionraddrrrr#rrrrrIrr&options connections rNget_connectionzConnectionPool.get_connections%  ZZ 4!88<<>   $ $ ( ( 4       B&&(Z-D-D-L)*?@@9 4!113  4Z($W- B%%'""$&&()*@AA) B   LL $   sXB6BB6D.'CB30B62B33B66B?A D DDDD/c|j}t|jdd|jdd|jddS)z,Return an encoder based on encoding settingsrrrkrsrlrtF)rrrsrt)rrr)rIr s rN get_encoderzConnectionPool.get_encodersF''ZZ G4"JJ'8(C#ZZ(:EB  r3c|j|jk\r td|xjdz c_|jdi|jS)zCreate a new connectionzToo many connectionsrrS)rrr#rrrs rNrzConnectionPool.make_connectionsO  $ $(<(< <!"89 9 !!Q&!$t$$>t'='=>>r3rcv|j|j5 |jj||j |r|j j|n/|xjdzc_|j dddy dddy#t$rYqwxYw#1swYyxYw)z(Releases the connection back to the poolrN) rrrrKeyErrorowns_connectionrrBrrrIrs rNrzConnectionPool.releases  ZZ ((// ; ##J/++22:> ))Q.)%%'!  ?Z  Zs.B/B AB/ B,)B/+B,,B//B8c4|j|jk(SrW)rrs rNrzConnectionPool.owns_connections~~))r3inuse_connectionsc|j|j5|r!t|j|j}n |j}|D]}|j  dddy#1swYyxYw)z Disconnects connections in the pool If ``inuse_connections`` is True, disconnect connections that are current in use, potentially by other threads. Otherwise only disconnect connections that are idle in the pool. N)rrrrrr)rIr connectionsrs rNrzConnectionPool.disconnects`  ZZ #//1I1I #99 ) %%'*ZZs AA..A7c$|jy)z-Close the pool, disconnecting all connectionsNrrs rNrzConnectionPool.closerr3c|jjd|i|jD] }||_ |jD] }||_ y)Nr{)rrrr{r)rIr{conns rN set_retryzConnectionPool.set_retrysI %%w&67//DDJ0,,DDJ-r3c|j|j5t|j|j}|D]}|j  dddy#1swYyxYwrW)rrrrrr+)rIrrs rNr+zConnectionPool.flush_cachesK  ZZ ; ;T=U=UVK) &&(*ZZs 8AA(rc|j|j5t|j|j}|D]}|j | dddy#1swYyxYwrW)rrrrrr.)rIrrrs rNr.z(ConnectionPool.delete_command_from_cachesM  ZZ ; ;T=U=UVK) 44W=*ZZ 9A  A)r"c|j|j5t|j|j}|D]}|j | dddy#1swYyxYwrW)rrrrrr0)rIr"rrs rNr0z(ConnectionPool.invalidate_key_from_cachesM  ZZ ; ;T=U=UVK) 44S9*ZZrrg)rhr6)rr6rhNr1)r{r(rhN)rPrQrRr2 classmethodrr6r rrZr>rrrrrrrrrr4rrrr+r.r0rSr3rNrrs ..d$)-"#2 3* "-*^"3"\"H W ?**,*3*(D(D(()>>:S:r3rcJeZdZdZddeeffd ZdZdZdZ dZ d Z xZ S) BlockingConnectionPoola Thread-safe blocking connection pool:: >>> from redis.client import Redis >>> client = Redis(connection_pool=BlockingConnectionPool()) It performs the same function as the default :py:class:`~redis.ConnectionPool` implementation, in that, it maintains a pool of reusable connections that can be shared by multiple redis clients (safely across threads if required). The difference is that, in the event that a client tries to get a connection from the pool when all of connections are in use, rather than raising a :py:class:`~redis.ConnectionError` (as the default :py:class:`~redis.ConnectionPool` implementation does), it makes the client wait ("blocks") for a specified number of seconds until a connection becomes available. Use ``max_connections`` to increase / decrease the pool size:: >>> pool = BlockingConnectionPool(max_connections=10) Use ``timeout`` to tell it either how many seconds to wait for a connection to become available, or to block forever: >>> # Block forever. >>> pool = BlockingConnectionPool(timeout=None) >>> # Raise a ``ConnectionError`` after five seconds if a connection is >>> # not available. >>> pool = BlockingConnectionPool(timeout=5) 2c F||_||_t| d||d|y)N)rrrS) queue_classrr>rZ)rIrrrrrrs rNrZzBlockingConnectionPool.__init__Gs6'   -+   r3c|j|j|_ |jjd#t$rYnwxYwg|_t j|_yrW) rrpool put_nowaitr _connectionsrrrrs rNrzBlockingConnectionPool.resetWsf$$T%9%9:   $$T*   99;s? A  A ct|jdi|j}|jj||S)zMake a fresh connection.rS)rrrrBrs rNrz&BlockingConnectionPool.make_connectionos7*T**DT-C-CD    ,r3c |jd} |jjd|j}||j } |j |jr t d |S#t$r t dwxYw#t tf$r?|j|j|jr t dY|SwxYw#t$r|j|wxYw)a7 Get a connection, blocking for ``self.timeout`` until a connection is available from the pool. If the connection returned is ``None`` then creates a new connection. Because we use a last-in first-out queue, the existing connections (having been returned to the pool after the initial ``None`` values were added) will be returned before ``None`` values. This means we only create new connections when we need to, i.e.: the actual number of connections will only increase in response to demand. NT)blockrzNo connection available.rr) rrrrrr#rrrrrrrrs rNrz%BlockingConnectionPool.get_connectionus   >T4<<HJ  --/J      B&&()*?@@)= >""<= = >($W- B%%'""$&&()*@AA) B   LL $  s6'A=C&B=BA C#C&"C##C&&Dc|j|j|s,|j|jj dy |jj |y#t $rYywxYw)z)Releases the connection back to the pool.N)rrrrrrrs rNrzBlockingConnectionPool.releasesj ##J/  ! ! # II  &   II  ,   sA++ A76A7cf|j|jD]}|jy)z(Disconnects all connections in the pool.N)rrrrs rNrz!BlockingConnectionPool.disconnects( ++J  ! ! #,r3) rPrQrRr2r6rrZrrrrrrYrZs@rNrr%s6F#  0 2h*$r3r)YrrrrcrFrrabcr itertoolsrqueuerrrrtypingr r r r r rr urllib.parserrrrrrrrr_parsersrrrrbackoffr credentialsrr exceptionsr r!r"r#r$r%r&r'r{r(r)r*utilsr+r,r-r.r/r0rCr^rcr`r\robjectr__annotations__r5r7rUrjr6r\rrrrr3listrrrrrSr3rNrse ((GGG44JIO   $      8E, nDEFF"M M$00fR2R2jX@#X@vSJSl%!3%P/  # ! 6r\:\:~]$^]$r3