Ë
|
|
çúh¿h ã ó´ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl
|
m
|
Z
|
d dl m Z d dl mZmZmZmZmZmZmZmZmZmZmZmZmZmZ d dl m Z m Z d dl m Z m!Z!m"Z" d dl#m$Z$ d d l%m&Z&m'Z'm(Z( d d
|
l)m*Z* d d l+m,Z, d d l-m.Z. d d l/m0Z0m1Z1 d dl2m3Z3m4Z4m5Z5 d dl6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ d dlAmBZBmCZC d dlDmEZEmFZF d dlGmHZH d dlImJZJmKZK d dlLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^ d dl_m`Z`maZambZb d dlcmdZdmeZemfZfmgZgmhZhmiZimjZj edr d dlkmlZlmmZmmnZn ndZldZndZm edeoded eedf « Zp G d de5e;eC« Zq G d d« Zr G d d « Zs G d d e5e;eC« Zte7D ]8 Zueují d!d"« jï « Zueud#k( r) exeteu e>eu« « : G d$ d%« Zy G d& d'e« Zz G d( d)ez« Z{ G d* d+e{« Z| G d, d-e{« Z}y).é N)ÚABCÚabstractmethod)Úcopy)Úchain)ÚAnyÚCallableÚ CoroutineÚDequeÚDictÚ GeneratorÚListÚMappingÚOptionalÚSetÚTupleÚTypeÚTypeVarÚUnion)ÚAsyncCommandsParserÚEncoder)Ú_RedisCallbacksÚ_RedisCallbacksRESP2Ú_RedisCallbacksRESP3)ÚResponseCallbackT)Ú
|
ConnectionÚ SSLConnectionÚ parse_url©ÚLock)ÚRetry)ÚTokenInterface)Ú ExponentialWithJitterBackoffÚ NoBackoff)ÚEMPTY_RESPONSEÚ NEVER_DECODEÚ AbstractRedis)
|
ÚPIPELINE_BLOCKED_COMMANDSÚPRIMARYÚREPLICAÚSLOT_IDÚAbstractRedisClusterÚ LoadBalancerÚLoadBalancingStrategyÚblock_pipeline_commandÚ get_node_nameÚparse_cluster_slots)Ú READ_COMMANDSÚAsyncRedisClusterCommands)ÚREDIS_CLUSTER_HASH_SLOTSÚkey_slot)ÚCredentialProvider)Ú#AfterAsyncClusterInstantiationEventÚEventDispatcher)ÚAskErrorÚBusyLoadingErrorÚClusterDownErrorÚ ClusterErrorÚConnectionErrorÚCrossSlotTransactionErrorÚ DataErrorÚExecAbortErrorÚInvalidPipelineStackÚMaxConnectionsErrorÚ
|
MovedErrorÚRedisClusterExceptionÚ
|
RedisErrorÚ ResponseErrorÚSlotNotCoveredErrorÚ TimeoutErrorÚ TryAgainErrorÚ
|
WatchError)ÚAnyKeyTÚ
|
EncodableTÚKeyT)Ú SSL_AVAILABLEÚdeprecated_argsÚdeprecated_functionÚget_lib_versionÚsafe_strÚ str_if_bytesÚ truncate_text)Ú
|
TLSVersionÚ VerifyFlagsÚ
|
VerifyModeÚ TargetNodesTÚ ClusterNodec Z ó e Zd ZdZedededd fd« ZdZ e dgdd ¬
|
« e d gd d ¬
|
« ddddddddddddddddddd e
|
« ddddddddddddddddddddddf*de e d e ee f d e ed d eded e e d!ed"e d e d#e d$e d% d&e eee d'e ee f d(e e d)e e d*e e d+e e d,e e d-e e d.e e d/ed0ed1ed2ed3e e d4ed5e ee e e ef f d6e e d7ed8e e d9e e d:e eef d;e ee d<e ee d=e e d>ed?e e d@e e dAe e dBe e dCe eeee f geee f f dDe e ddfVdE« « Z ddFZ d
dGZ e dHdIdJ¬K« d
dL« Z!ddMZ"de fdNZ#de fdOZ$dP Z%de&edd f fdQZ'dRZ(e)jT e+jX fdSedTeddfdUZ-dVe.ddfdWZ/ded fdXZ0ded fdYZ1ded fdZZ2dd[Z3dd\Z4dd]Z5 dde e d e e d^e e de d fd_Z6 dd`edaede d fdbZ7d`e8de fdcZ9de:fddZ;de<ee e f fdeZ=d$e>ddfdfZ?dgedhe@ddfdiZAddjdgedkedle e ded fdmZBdgedkede fdnZCdoedefdpZDdoeded fdqZEdke8dedefdrZFdsd dke eGe8f dedefdtZH ddue e dve e ddwfdxZI ddyeGdze e d{ed|ed}e e d~e eeJ dededeJfdZKdeLddwef fdZMy)Ú RedisClustera·
|
Create a new RedisCluster client.
|
|
Pass one of parameters:
|
|
- `host` & `port`
|
- `startup_nodes`
|
|
| Use ``await`` :meth:`initialize` to find cluster nodes & create connections.
|
| Use ``await`` :meth:`close` to disconnect connections & close client.
|
|
Many commands support the target_nodes kwarg. It can be one of the
|
:attr:`NODE_FLAGS`:
|
|
- :attr:`PRIMARIES`
|
- :attr:`REPLICAS`
|
- :attr:`ALL_NODES`
|
- :attr:`RANDOM`
|
- :attr:`DEFAULT_NODE`
|
|
Note: This client is not thread/process/fork safe.
|
|
:param host:
|
| Can be used to point to a startup node
|
:param port:
|
| Port used if **host** is provided
|
:param startup_nodes:
|
| :class:`~.ClusterNode` to used as a startup node
|
:param require_full_coverage:
|
| When set to ``False``: the client will not require a full coverage of
|
the slots. However, if not all slots are covered, and at least one node
|
has ``cluster-require-full-coverage`` set to ``yes``, the server will throw
|
a :class:`~.ClusterDownError` for some key-based commands.
|
| When set to ``True``: all slots must be covered to construct the cluster
|
client. If not all slots are covered, :class:`~.RedisClusterException` will be
|
thrown.
|
| See:
|
https://redis.io/docs/manual/scaling/#redis-cluster-configuration-parameters
|
:param read_from_replicas:
|
| @deprecated - please use load_balancing_strategy instead
|
| Enable read from replicas in READONLY mode.
|
When set to true, read commands will be assigned between the primary and
|
its replications in a Round-Robin manner.
|
The data read from replicas is eventually consistent with the data in primary nodes.
|
:param load_balancing_strategy:
|
| Enable read from replicas in READONLY mode and defines the load balancing
|
strategy that will be used for cluster node selection.
|
The data read from replicas is eventually consistent with the data in primary nodes.
|
:param dynamic_startup_nodes:
|
| Set the RedisCluster's startup nodes to all the discovered nodes.
|
If true (default value), the cluster's discovered nodes will be used to
|
determine the cluster nodes-slots mapping in the next topology refresh.
|
It will remove the initial passed startup nodes if their endpoints aren't
|
listed in the CLUSTER SLOTS output.
|
If you use dynamic DNS endpoints for startup nodes but CLUSTER SLOTS lists
|
specific IP addresses, it is best to set it to false.
|
:param reinitialize_steps:
|
| Specifies the number of MOVED errors that need to occur before reinitializing
|
the whole cluster topology. If a MOVED error occurs and the cluster does not
|
need to be reinitialized on this current error handling, only the MOVED slot
|
will be patched with the redirected node.
|
To reinitialize the cluster on every MOVED error, set reinitialize_steps to 1.
|
To avoid reinitializing the cluster on moved errors, set reinitialize_steps to
|
0.
|
:param cluster_error_retry_attempts:
|
| @deprecated - Please configure the 'retry' object instead
|
In case 'retry' object is set - this argument is ignored!
|
|
Number of times to retry before raising an error when :class:`~.TimeoutError`,
|
:class:`~.ConnectionError`, :class:`~.SlotNotCoveredError`
|
or :class:`~.ClusterDownError` are encountered
|
:param retry:
|
| A retry object that defines the retry strategy and the number of
|
retries for the cluster client.
|
In current implementation for the cluster client (starting form redis-py version 6.0.0)
|
the retry object is not yet fully utilized, instead it is used just to determine
|
the number of retries for the cluster client.
|
In the future releases the retry object will be used to handle the cluster client retries!
|
:param max_connections:
|
| Maximum number of connections per node. If there are no free connections & the
|
maximum number of connections are already created, a
|
:class:`~.MaxConnectionsError` is raised.
|
:param address_remap:
|
| An optional callable which, when provided with an internal network
|
address of a node, e.g. a `(host, port)` tuple, will return the address
|
where the node is reachable. This can be used to map the addresses at
|
which the nodes _think_ they are, to addresses at which a client may
|
reach them, such as when they sit behind a proxy.
|
|
| Rest of the arguments will be passed to the
|
:class:`~redis.asyncio.connection.Connection` instances when created
|
|
:raises RedisClusterException:
|
if any arguments are invalid or unknown. Eg:
|
|
- `db` != 0 or None
|
- `path` argument for unix socket connection
|
- none of the `host`/`port` & `startup_nodes` were provided
|
|
ÚurlÚkwargsÚreturnc ó |j t |« « |j dd« t u rd|d< | di |¤S )aá
|
Return a Redis client object configured from the given URL.
|
|
For example::
|
|
redis://[[username]:[password]]@localhost:6379/0
|
rediss://[[username]:[password]]@localhost:6379/0
|
|
Three URL schemes are supported:
|
|
- `redis://` creates a TCP socket connection. See more at:
|
<https://www.iana.org/assignments/uri-schemes/prov/redis>
|
- `rediss://` creates a SSL wrapped TCP socket connection. See more at:
|
<https://www.iana.org/assignments/uri-schemes/prov/rediss>
|
|
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.
|
|
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
|
:class:`~redis.asyncio.connection.Connection` when created.
|
In the case of conflicting arguments, querystring arguments are used.
|
Úconnection_classNTÚssl© )Úupdater Úpopr )Úclsr[ r\ s õh H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/cluster.pyÚfrom_urlzRedisCluster.from_urlÊ s= ð8 i nÔ%Ø ::Ð(¨$Ó /´=Ñ @Ø F5MÙ}V}Ð ó )Ú _initializeÚ_lockÚretryÚ command_flagsÚcommands_parserÚconnection_kwargsÚencoderÚ
|
node_flagsÚ nodes_managerÚread_from_replicasÚreinitialize_counterÚreinitialize_stepsÚresponse_callbacksÚresult_callbacksrq z6Please configure the 'load_balancing_strategy' insteadz5.3.0)Ú args_to_warnÚreasonÚversionÚ cluster_error_retry_attemptsz+Please configure the 'retry' object insteadz6.0.0Nië TFé é ì r zredis-pyzutf-8ÚstrictÚrequiredé ÚhostÚportÚ startup_nodesrX Úrequire_full_coverageÚload_balancing_strategyÚdynamic_startup_nodesrs Úmax_connectionsrj r Úretry_on_errorÚdbÚpathÚcredential_providerÚusernameÚpasswordÚ client_nameÚlib_nameÚ lib_versionÚencodingÚencoding_errorsÚdecode_responsesÚhealth_check_intervalÚsocket_connect_timeoutÚsocket_keepaliveÚsocket_keepalive_optionsÚsocket_timeoutr` Ú ssl_ca_certsÚ ssl_ca_dataÚ ssl_cert_reqsÚssl_include_verify_flagsÚssl_exclude_verify_flagsÚ ssl_certfileÚssl_check_hostnameÚ ssl_keyfileÚssl_min_versionÚ ssl_ciphersÚprotocolÚ address_remapÚevent_dispatcherc+ óì | r t d« |r t d« |r|s |s t d« i d|
|
dt d|d|d|d |d
|
|d |d |d |d|d|d|d|d|d| d|(}+| r!|+j t | | | |!|"|#|$|%|&|'d « |s|r| j |+d< | r| | _ n t t dd¬« | ¬« | _ | r| j
|
j | « t j « |+d< |+j d« d v r|+d j t « n|+d j t « |+| _ |rFg },|D ]< }-|,j t! |-j" |-j$ fi | j ¤« > |,}ng }|r(|r&|j t! ||fi | j ¤« |*t' « | _ n|*| _ || _ t- |||+||)| j( ¬ « | _ t1 |||« | _ || _ || _ || _ d | _ t= « | _ | j@ jB j « | _" | j@ jF j « | _$ |+d | _% | j@ jL j « | _' d | jN d < d!| _( d | _) d | _* tW jX « | _- y )"Nz/Argument 'db' must be 0 or None in cluster modez3Unix domain socket is not supported in cluster modea1 RedisCluster requires at least one node to discover the cluster.
|
Please provide one of the following or use RedisCluster.from_url:
|
- host and port: RedisCluster(host="localhost", port=6379)
|
- startup_nodes: RedisCluster(startup_nodes=[ClusterNode("localhost", 6379), ClusterNode("localhost", 6380)])r r_ r r r r r r r r r r r r r r r¢ ) r_ r r r r r r r r r r¡ Úredis_connect_funcé é
|
)ÚbaseÚcap)ÚbackoffÚretriesrt )Ú3r{ )r
r£ r¤ r c óN t t |j « « d fi |¤S ©Nr )r0 ÚlistÚvalues)ÚcmdÚresr\ s re ú<lambda>z'RedisCluster.__init__.<locals>.<lambda>° s' Ô':ÜSZZ\Ó" 1Ñ%ñ(Ø)/ñ( rg ú CLUSTER SLOTST).rC r rb r Ú
|
on_connectrj r r" Úupdate_supported_errorsr r Úgetr r rm ÚappendrX r r r7 Ú_event_dispatcherr Ú NodesManagerrp r rn rq r rs rr r rl Ú __class__Ú
|
NODE_FLAGSro Ú COMMAND_FLAGSrk rt ÚRESULT_CALLBACKSru rh ri Ú_usage_counterÚasyncior Ú _usage_lock).Úselfr r r r rq r r
rs ry r rj r r r r r r r r r r r r r r r r r r` r r r r r r r r r r¡ r¢ r£ r¤ r\ Ú passed_nodesÚnodes. re Ú__init__zRedisCluster.__init__ü s ñ| Ü'ØAóð ñ Ü'ØEóð ñ D©-Ü'ðSóð ð"
|
Ø ð"
|
à ¤
|
ð"
|
ð "Ð#6ð "
|
ð
|
ð "
|
ð ð "
|
ð ;ð"
|
ð ð"
|
ð ;ð"
|
ð ð"
|
ð ð"
|
ð Ð 0ð"
|
ð $Ð%:ð "
|
ð %Ð&<ð!"
|
ð" Ð 0ð#"
|
ð$ 'Ð(@ð%"
|
ð& nð'"
|
ð( ð)"
|
ñ. à MMä(5Ø$0Ø#.Ø%2Ø0HØ0HØ$0Ø*<Ø#.Ø'6Ø#.ñ ô ñ Ñ!8à+/¯?©?FÐ'Ñ (á Ø DJä Ü4¸!ÀÔDØ4ôDJñ Ø JJ× .Ñ .¨~Ô >ä'6×';Ñ';Ó'=Ð#Ñ$Ø ::jÓ ! XÑ -Ø Ð'Ñ (× /Ñ /Ô0DÕ Eà Ð'Ñ (× /Ñ /Ô0DÔ EØ!'Ô á Ø LØ%ò Ø ×#Ñ#Ü § ¡ ¨4¯9©9ÑO¸×8NÑ8NÑOõð ð )Mà MÙ DØ × Ñ ¤¨T°4Ñ!R¸4×;QÑ;QÑ!RÔ Sà Ð #Ü%4Ó%6DÕ "à%5DÔ "à *ÔÜ )Ø Ø !Ø Ø"7Ø'Ø !× 3Ñ 3ô
|
Ôô x¨ Ð:JÓK Ø"4Ô Ø'>Ô$Ø"4Ô Ø$%Ô!Ü 2Ó 4Ô Ø ..×3Ñ3×8Ñ8Ó:Ø !^^× 9Ñ 9× >Ñ >Ó @ÔØ"(Ð)=Ñ">Ô Ø $§¡× ?Ñ ?× DÑ DÓ FÔ ñ ð × Ñ oÑ.ð ÔØ-1
|
ð
|
ÔÜ"<<>Õrg c ó~ K | j r¹| j st j « | _ | j 4 d{ | j ra | j j « d{ | j j | j j « d{ d| _ ddd« d{ | S | S 7
7 X7 ## t $ rI | j j « d{ 7 | j j d« d{ 7 w xY w7 c# 1 d{ 7 sw Y | S xY ww)zJGet all nodes from startup nodes & creates connections if not initialized.NFr )
|
rh ri rÁ r rp Ú
|
initializerl Ú default_nodeÚ BaseExceptionÚaclose©rà s re rÈ zRedisCluster.initialize¾ s è ø à × Ò Ø::Ü $\\^
|
Øzz÷ ñ Ø×#Ò#ð Ø "× 0Ñ 0× ;Ñ ;Ó =×=Ð=Ø "× 2Ñ 2× =Ñ =Ø × .Ñ .× ;Ñ ;ó ÷ ð ð ,1Ô(÷ ÷ ð t ð øð >øðùô )ò Ø "× 0Ñ 0× 7Ñ 7Ó 9×9Ñ9Ø "× 0Ñ 0× 7Ñ 7¸Ó H×HÑHØ ð úð ø÷ ÷ ð ð üs AD=ÁC
|
ÁD=Á D'Á CÁ3C Á46CÂ*CÂ+ CÂ6 D=ÃD%Ã D=Ã CÃCÃ&D"Ã6C9Ã7#D"ÄD ÄD"Ä"D'Ä%D=Ä'D:Ä-D0 Ä.D:Ä5D=c ó¤ K | j s£| j st j « | _ | j 4 d{ | j sLd| _ | j j « d{ | j j d« d{ ddd« d{ yy7 n7 ;7 7 # 1 d{ 7 sw Y yxY ww)z.Close all connections & client if initialized.NTr )rh ri rÁ r rp rË rÌ s re rË zRedisCluster.acloseÑ sº è ø à× Ò Ø::Ü $\\^
|
Øzz÷ Eñ EØ×'Ò'Ø'+DÔ$Ø ×,Ñ,×3Ñ3Ó5×5Ð5Ø ×,Ñ,×3Ñ3°OÓD×DÐD÷ E÷ Eð Eð ð Eøð 6øØDøð Eø÷ E÷ Eñ Eüsl ACÁB3ÁCÁ1B;Á9B5Á:"B; B7 B;Â! CÂ,B9Â-CÂ5B;Â7B;Â9CÂ;C ÃC ÃC à Cz5.0.0zUse aclose() insteadÚclose)rx rw Únamec ó@ K | j « d{ y7 w)z.alias for aclose() for backwards compatibilityN)rË rÌ s re rÎ zRedisCluster.closeÜ s è ø ð kkm×Òúó c ó K | j « d{ | j « d{ S 7 7 # t $ r | j « d{ 7 w xY ww)z¸
|
Async context manager entry. Increments a usage counter so that the
|
connection pool is only closed (via aclose()) when no context is using
|
the client.
|
N)Ú_increment_usagerÈ Ú ExceptionÚ_decrement_usagerÌ s re Ú
|
__aenter__zRedisCluster.__aenter__á s] è ø ð ×#Ñ#Ó%×%Ð%ð à Ó*×*Ð *ð &øð +ùÜò à×'Ñ'Ó)× )Ñ )Ø ð üs: A 4A 8 ¯6°8 ³A ¶8 ¸ A ÁAÁA Á A c óÊ K | j 4 d{ | xj dz c_ | j cddd« d{ S 7 67 # 1 d{ 7 sw Y yxY ww)z
|
Helper coroutine to increment the usage counter while holding the lock.
|
Returns the new value of the usage counter.
|
Nr§ ©r rÀ rÌ s re rÓ z RedisCluster._increment_usageð óZ è ø ð
|
×#Ñ#÷ 'ñ 'Ø × Ò 1Ñ $Õ Ø×&Ñ&÷ '÷ 'ò 'øð 'ø÷ '÷ 'ñ 'üóC A#A
|
A#!A¸ A#ÁA ÁA#Á A#ÁA ÁA ÁA Á A#c óÊ K | j 4 d{ | xj dz c_ | j cddd« d{ S 7 67 # 1 d{ 7 sw Y yxY ww)z
|
Helper coroutine to decrement the usage counter while holding the lock.
|
Returns the new value of the usage counter.
|
Nr§ rØ rÌ s re rÕ z RedisCluster._decrement_usageù rÙ rÚ c óÌ K t j | j « « d{ }|dk( r,t j | j « « d{ yy7 67 w)z©
|
Async context manager exit. Decrements a usage counter. If this is the
|
last exit (counter becomes zero), the client closes its connection pool.
|
Nr )rÁ ÚshieldrÕ rË )rà Úexc_typeÚ exc_valueÚ tracebackÚ current_usages re Ú __aexit__zRedisCluster.__aexit__ sS è ø ô
|
&nn¨T×-BÑ-BÓ-DÓ E×E Ø AÒ ä.. §¡£ Ó/× /Ñ /ð ð Føð 0ús! 'A$©A ª/A$ÁA"ÁA$Á"A$c ó> | j « j « S ©N©rÈ Ú __await__rÌ s re ræ zRedisCluster.__await__ ó ØÓ ×*Ñ*Ó,Ð,rg z Unclosed RedisCluster clientÚ_warnÚ_grlc óÞ t | d« rR| j sE || j d| t | ¬« | | j d} |« j |« y y y # t
|
$ r Y y w xY w)Nrh ú ©Úsource©ÚclientÚmessage)Úhasattrrh Ú _DEL_MESSAGEÚResourceWarningÚcall_exception_handlerÚ RuntimeError)rà rè ré Úcontexts re Ú__del__zRedisCluster.__del__ sv ô
|
4 Ô '°×0@Ò0@Ù T×&Ñ&Ð' q¨¨Ð1´?È4Õ Pð Ø%)°d×6GÑ6GÑHÙ×-Ñ-¨gÕ6ð 1AÐ 'øô
|
ò Ùð ús ¸%A Á A,Á+A,Ú
|
connectionc óØ K |j « d { |j d« d { t |j « d { « dk7 r t d« y 7 M7 67 w)NÚREADONLYÚOKzREADONLY command failed)r¶ Ú send_commandrR Ú read_responser< ©rà rø s re r¶ zRedisCluster.on_connect sh è ø Ø×#Ñ#Ó%×%Ð%ð ×%Ñ% jÓ1×1Ð1Ü j× 6Ñ 6Ó 8×8Ó 9¸TÒ AÜ!Ð";Ó<Ð <ð Bð &øð 2øØ8ús1 A*A$A*¯A&° A*Á A(Á A*Á&A*Á(A*c ó\ t | j j j « « S )z Get all nodes of the cluster.)r° rp Ú nodes_cacher± rÌ s re Ú get_nodeszRedisCluster.get_nodes* s" äD×&Ñ&×2Ñ2×9Ñ9Ó;Ó<Ð<rg c ó@ | j j t « S )z%Get the primary nodes of the cluster.)rp Úget_nodes_by_server_typer( rÌ s re Ú get_primarieszRedisCluster.get_primaries. ó à×!Ñ!×:Ñ:¼7ÓCÐCrg c ó@ | j j t « S )z%Get the replica nodes of the cluster.)rp r r) rÌ s re Ú get_replicaszRedisCluster.get_replicas2 r rg c ó t j t | j j j « « « S )z!Get a random node of the cluster.)ÚrandomÚchoicer° rp r r± rÌ s re Úget_random_nodez RedisCluster.get_random_node6 s+ ä}}T $×"4Ñ"4×"@Ñ"@×"GÑ"GÓ"IÓ JÓKÐKrg c ó. | j j S )z#Get the default node of the client.)rp rÉ rÌ s re Úget_default_nodez RedisCluster.get_default_node: s à×!Ñ!×.Ñ.Ð.rg c óx |r | j |j ¬« s t d« || j _ y)z
|
Set the default node of the client.
|
|
:raises DataError: if None is passed or node does not exist in cluster.
|
©Ú node_namez1The requested node does not exist in the cluster.N)Úget_noderÏ r> rp rÉ )rà rÅ s re Úset_default_nodez RedisCluster.set_default_node> s2 ñ 4==°4·9±9=Ô=ÜÐ OÓPÐ Pà*.×ÑÕ'rg r c ó< | j j |||« S )z&Get node by (host, port) or node_name.)rp r ©rà r r r s re r zRedisCluster.get_nodeI s ð ×!Ñ!×*Ñ*¨4°°yÓAÐArg ÚkeyÚreplicac óü | j |« }| j j j |« }|st d| d« |r-t | j j | « dk ryd}|| S d}|| S )aG
|
Get the cluster node corresponding to the provided key.
|
|
:param key:
|
:param replica:
|
| Indicates if a replica should be returned
|
|
|
None will returned if no replica holds this key
|
|
:raises SlotNotCoveredError: if the key is not covered by any slot.
|
úSlot "z " is not covered by the cluster.r Nr§ r )Úkeyslotrp Ú slots_cacher¸ rF Úlen)rà r r ÚslotÚ
|
slot_cacheÚnode_idxs re Úget_node_from_keyz RedisCluster.get_node_from_keyR s ð ||CÓ Ø×'Ñ'×3Ñ3×7Ñ7¸Ó=
|
ÙÜ%¨¨t¨fÐ4TÐ&UÓVÐ Vá Ü4×%Ñ%×1Ñ1°$Ñ7Ó8¸1Ò<ØØHð (Ñ#Ð#ð Hà(Ñ#Ð#rg c óJ t | j j |« « S )z
|
Find the keyslot for a given key.
|
|
See: https://redis.io/docs/manual/scaling/#redis-cluster-data-sharding
|
)r4 rn Úencode)rà r s re r zRedisCluster.keyslotn s ô ×+Ñ+¨CÓ0Ó1Ð1rg c ó | j S )z%Get the encoder object of the client.)rn rÌ s re Ú get_encoderzRedisCluster.get_encoderv s à||Ðrg c ó | j S )zGGet the kwargs passed to :class:`~redis.asyncio.connection.Connection`.)rm rÌ s re Úget_connection_kwargsz"RedisCluster.get_connection_kwargsz s à×%Ñ%Ð%rg c ó || _ y rä )rj )rà rj s re Ú set_retryzRedisCluster.set_retry~ s Ø
|
rg ÚcommandÚcallbackc ó" || j |< y)z Set a custom response callback.N)rt )rà r( r) s re Úset_response_callbackz"RedisCluster.set_response_callback s à+3× Ñ Ò(rg )Ú node_flagÚargsr, c ó® K |s| j j |« }|| j v r@|| j j k( r| j
|
j gS || j j k( r | j
|
j t « S || j j k( r | j
|
j t « S || j j k( r-t | j
|
j j « « S || j j k( rAt# j$ t | j
|
j j « « « gS | j
|
j' | j( |g|¢ d { | j* xr |t, v |t, v r| j. « gS d « gS 7 8wrä )rk r¸ ro r¼ Ú DEFAULT_NODErp rÉ Ú PRIMARIESr r( ÚREPLICASr) Ú ALL_NODESr° r r± ÚRANDOMr r
|
Úget_node_from_slotÚ_determine_slotrq r1 r )rà r( r, r- s re Ú_determine_nodesz RedisCluster._determine_nodes
s è ø ñ
|
à ×*Ñ*×.Ñ.¨wÓ7Ià Ò 'ØDNN× 7Ñ 7Ò7à ×*Ñ*×7Ñ7Ð8Ð8ØDNN× 4Ñ 4Ò4à×)Ñ)×BÑBÄ7ÓKÐKØDNN× 3Ñ 3Ò3à×)Ñ)×BÑBÄ7ÓKÐKØDNN× 4Ñ 4Ò4äD× .Ñ .× :Ñ :× AÑ AÓ CÓDÐDØDNN× 1Ñ 1Ò1ä ¤d¨4×+=Ñ+=×+IÑ+I×+PÑ+PÓ+RÓ&SÓTÐUÐUð × Ñ × 1Ñ 1Ø*d×*Ñ*¨7Ð:°TÒ:×:Ø×'Ñ'ÒD¨G´}Ð,DØ07¼=Ñ0H×,Ñ,ó ð
|
ð
|
ð OSó ð
|
ð
|
à:ús FGÆGÆ9Gc óÖ K | j j |« t k( rt |d « S |j « dv rPt |« dk rt d|g|¢ « |ddt |d « z }|s{t j dt « S | j j |g|¢ d { }|s:|j « dv rt j dt « S t d| « t |« dk( r| j |d « S |D ch c] }| j |« }}t |« dk7 rt | d« |j « S 7 ¬c c}w w) Nr )ÚEVALÚEVALSHAr zInvalid args in command: r§ )ÚFCALLÚFCALL_ROzNo way to dispatch this command to Redis Cluster. Missing key.
|
You can execute the command by specifying target nodes.
|
Command: z) - all keys must map to the same key slot)rk r¸ r* ÚintÚupperr rC r Ú randranger3 rl Úget_keysr rc )rà r( r- Úkeysr Úslotss re r5 z RedisCluster._determine_slot¨ sy è ø Ø × Ñ × !Ñ ! 'Ó *¬gÒ 5ätAw<Ð ð ==?Ð 1Ñ 1ä4y1}Ü+Ø/°°¸$±Ð/?Ð@óð ð A¤ D¨¡G£ Ñ ,Ð-Dñ Ü ×'Ñ'¨Ô+CÓDÐDà6×-Ñ-×6Ñ6°wÐFÀÒF×FDÙð ==?Ð&;Ñ;Ü!×+Ñ+¨AÔ/GÓHÐHÜ+ð/à/3¨fð6óð ô t9>Ø<< Q¡Ó(Ð (ð /3Ö3 s cÕ"Ð3Ð3Ü u:?Ü'Ø)ÐDÐEóð ð yy{Ðð1 Gúò$ 4ùs% B3E)Â5E"Â6A&E)Ä E$Ä4/E)Å$E)Ú target_nodesc óB t |t « xr || j v S rä )Ú
|
isinstanceÚstrro )rà rB s re Ú _is_node_flagzRedisCluster._is_node_flagÛ s Ü,¬Ó,ÒP° ÀÇ Á Ð1PÐPrg c óØ t |t « r|}|S t |t « r|g}|S t |t « rt |j « « }|S t dt |« « )Nz°target_nodes type can be one of the following: node_flag (PRIMARIES, REPLICAS, RANDOM, ALL_NODES),ClusterNode, list<ClusterNode>, or dict<any, ClusterNode>. The passed type is )rD r° rX Údictr± Ú TypeErrorÚtype)rà rB Únodess re Ú_parse_target_nodesz RedisCluster._parse_target_nodesÞ s Ü l¤DÔ )Ø Eð ô ¤kÔ 2à!NEð ô ¤dÔ +ô ×,Ñ,Ó.Ó/Eð ô ð&ô '+¨<Ó&8Ð%9ð;óð rg c
|
ó K d }g }d} j j « }j dd« }|r& j |« s j |« }d}d}d|z }t |« D ] } j rL j « d{ t |« dk( r&|d j « k( r j « |s+ j d|i d{ }|st d d « t |« dk( r[ j |d g¢i ¤ d{ }
|
| j v r( j | ||d j |
|
ifi ¤c S |
|
c S |D cg c] } | j } } t! j" fd
|
|D « d{ } | j v r, j | |t% t' | | « « fi ¤c S t% t' | | « « c S y7 a7 7 Õc c} w 7 d# t( $ r8}|dkD r,t+ |« j, j. v r |dz }Y d}~Í|d}~ww xY ww) a
|
Execute a raw command on the appropriate cluster node or target_nodes.
|
|
It will retry the command as specified by the retries property of
|
the :attr:`retry` & then raise an exception.
|
|
:param args:
|
| Raw command args
|
:param kwargs:
|
|
- target_nodes: :attr:`NODE_FLAGS` or :class:`~.ClusterNode`
|
or List[:class:`~.ClusterNode`] or Dict[Any, :class:`~.ClusterNode`]
|
- Rest of the kwargs are passed to the Redis connection
|
|
:raises RedisClusterException: if target_nodes is not provided & the command
|
can't be mapped to a slot
|
r FrB NTr§ r, ú!No targets were found to execute ú command onc 3 óp K | ]- }t j j |g¢i ¤« / y wrä )rÁ Ú create_taskÚ_execute_command)Ú.0rÅ r- r\ rà s re ú <genexpr>z/RedisCluster.execute_command.<locals>.<genexpr>0 s@ øè ø ò ð !%ô $× /Ñ /Ø 5 × 5Ñ 5°dÐ L¸TÒ LÀVÑ L÷ ñùs 36)rj Ú get_retriesrc rF rL Úrangerh rÈ r r Úreplace_default_noder6 rC rR ru rÏ rÁ ÚgatherrH ÚziprÔ rJ r¼ ÚERRORS_ALLOW_RETRY)rà r- r\ r( rB Útarget_nodes_specifiedÚretry_attemptsÚpassed_targetsÚexecute_attemptsÚ_ÚretrÅ r@ r± Úes ``` re Úexecute_commandz RedisCluster.execute_commandò s úè ø ð$ q'Ø Ø!&Ð Ø ×/Ñ/Ó1à N°DÓ9Ù $×"4Ñ"4°^Ô"DØ ×3Ñ3°NÓCLØ%)Ð "Ø Nð ~Ñ-ÐÜÐ'Ó(ó 3 AØ× Ò ØooÓ'×'Ð'ä Ó%¨Ò*Ø$ Q¨4×+@Ñ+@Ó+BÒBð ×-Ñ-Ô/ð* Ù-à)>¨×)>Ñ)>Ø ð*Ø)7ñ*÷ $Lñ (Ü 3Ø ?À¸vÀ[Ð Qó ð ô |Ó$¨Ò)à 5 × 5Ñ 5°lÀ1±oÐ WÈÒ WÐPVÑ W×WCØ $×"7Ñ"7Ñ7Ø =t× 4Ñ 4°WÑ =Ø # l°1¡o×&:Ñ&:¸CÐ%@ñ ØDJñ ò ð Jà2>Ö?¨$DIIÐ?DÐ?Ü#*§>¡>õð )5ô ð$÷ Fð $×"7Ñ"7Ñ7Ø =t× 4Ñ 4°WÑ =Ø #¤T¬#¨d°FÓ*;Ó%<ñ Ø@Fñ ò ô ¤ D¨&Ó 1Ó2Ò2ñU3 à'ùð$ùð Xúò @ð ùô ò Ø! AÒ%¬$¨q«'°T·^±^×5VÑ5VÑ*Vð # aÑ'NÝ ð Gûð üs¨
BI
|
ÂG7Â8I
|
ÃHÃ'G:Ã(?HÄ'G=Ä(7HÅ I
|
Å"HÅ#I
|
Å&HÅ*G?Å="HÆ HÆ ;HÇI
|
Ç HÇ2I
|
Ç:HÇ=HÇ?HÈ IÈ+IÈ:I
|
É IÉIÉI
|
Ú target_nodec ó" K dx}}d }| j }|dkD r¶|dz } |r.| j |¬« }|j d« d { d}nf|rd | j | d { }| j j || j xr |d t v |d t v r | j nd « }d} |j |i |¤ d { S t= d « 7 7 x7 # t $ r t $ r t t f$ rK | j j j |j d « | j! « d { 7 t" t$ f$ r9 | j! « d { 7 t' j( d« d { 7 t* $ r{} | xj, dz c_ | j. r=| j, | j. z dk( r!| j! « d { 7 d| _ n| | j _ d}Y d } ~ nvd } ~ wt2 $ r-} t5 | j6 | j8 ¬« }d}Y d } ~ nBd } ~ wt: $ r3 || j d z k r t' j( d
|
« d { 7 Y nw xY w|dkD rs¿w) NFr r§ r ÚASKINGç Ð?T©r r r g©?zTTL exhausted.) ÚRedisClusterRequestTTLr rb r5 rp r4 rq r1 r r9 rA r< rG r rc rÏ rË r: rF rÁ ÚsleeprB rr rs Ú_moved_exceptionr8 r/ r r rH r; )
|
rà rc r- r\ ÚaskingÚmovedÚ redirect_addrÚttlr ra s
|
re rR z RedisCluster._execute_commandF sg è ø ð Ð Ø Ø×)Ñ)àAgØ 1HCðK .ÙØ"&§-¡-¸- -Ó"HKØ%×5Ñ5°hÓ?×?Ð?Ø "FÙð "6 ×!5Ñ!5°tÐ!<×<DØ"&×"4Ñ"4×"GÑ"GØ Ø ×/Ñ/ÒL°D¸±G¼}Ð4Là 7¤mÑ3ð ×4Ò4à !ó #Kð "Eà 8[× 8Ñ 8¸$Ð IÀ&Ñ I×IÐIôv Ð+Ó,Ð,ðU @øð
|
=øð JùÜ#ò ØÜ&ò ð
|
Ü#¤\Ð2ò ð
|
×"Ñ"×0Ñ0×4Ñ4°[×5EÑ5EÀtÔLð kkm×#Ñ#ØÜ$Ô&9Ð:ò ð kkm×#Ñ#Ü mm DÓ)×)Ñ)ØÜ ò ð ×)Ò)¨QÑ.Õ)à×+Ò+Ø ×1Ñ1°D×4KÑ4KÑKÈqÒPà ++-×'Ñ'à01DÕ-à:;D×&Ñ&Ô7Ø ûÜò Ü -°1·6±6ÀÇÁÔ G Ø ûÜ ò .Ø×4Ñ4°qÑ8Ò8Ü!--¨Ó-×-Ñ-ùð .úðW AgûsÁ J (C! ÁCÁ C! Á$C Á%A&C! à C à C! à JÃC! à C! à C! Ã!A$JÅEÅ'JÅ-E0Å. JÆ FÆ JÆAHÇ*G-Ç+ HÈ JÈ JÈ #IÈ?JÉ6JÉ:I=É;JÊ JÊJÊJÚ transactionÚ
|
shard_hintÚClusterPipelinec ó4 |r t d« t | |« S )zù
|
Create & return a new :class:`~.ClusterPipeline` object.
|
|
Cluster implementation of pipeline does not support transaction or shard_hint.
|
|
:raises RedisClusterException: if transaction or shard_hint are truthy values
|
z(shard_hint is deprecated in cluster mode)rC rq )rà ro rp s re ÚpipelinezRedisCluster.pipeline s ñ Ü'Ð(RÓSÐ Sä t [Ó1Ð1rg rÏ Útimeoutri ÚblockingÚblocking_timeoutÚ
|
lock_classÚ thread_localÚraise_on_release_errorc
|
ó2 |t } || |||||||¬« S )a}
|
Return a new Lock object using key ``name`` that mimics
|
the behavior of threading.Lock.
|
|
If specified, ``timeout`` indicates a maximum life for the lock.
|
By default, it will remain locked until release() is called.
|
|
``sleep`` indicates the amount of time to sleep per loop iteration
|
when the lock is in blocking mode and another client is currently
|
holding the lock.
|
|
``blocking`` indicates whether calling ``acquire`` should block until
|
the lock has been acquired or to fail immediately, causing ``acquire``
|
to return False and the lock not being acquired. Defaults to True.
|
Note this value can be overridden by passing a ``blocking``
|
argument to ``acquire``.
|
|
``blocking_timeout`` indicates the maximum amount of time in seconds to
|
spend trying to acquire the lock. A value of ``None`` indicates
|
continue trying forever. ``blocking_timeout`` can be specified as a
|
float or integer, both representing the number of seconds to wait.
|
|
``lock_class`` forces the specified lock implementation. Note that as
|
of redis-py 3.0, the only lock class we implement is ``Lock`` (which is
|
a Lua-based lock). So, it's unlikely you'll need this parameter, unless
|
you have created your own custom lock class.
|
|
``thread_local`` indicates whether the lock token is placed in
|
thread-local storage. By default, the token is placed in thread local
|
storage so that a thread only sees its token, not a token set by
|
another thread. Consider the following timeline:
|
|
time: 0, thread-1 acquires `my-lock`, with a timeout of 5 seconds.
|
thread-1 sets the token to "abc"
|
time: 1, thread-2 blocks trying to acquire `my-lock` using the
|
Lock instance.
|
time: 5, thread-1 has not yet completed. redis expires the lock
|
key.
|
time: 5, thread-2 acquired `my-lock` now that it's available.
|
thread-2 sets the token to "xyz"
|
time: 6, thread-1 finishes its work and calls release(). if the
|
token is *not* stored in thread local storage, then
|
thread-1 would see the token value as "xyz" and would be
|
able to successfully release the thread-2's lock.
|
|
``raise_on_release_error`` indicates whether to raise an exception when
|
the lock is no longer owned when exiting the context manager. By default,
|
this is True, meaning an exception will be raised. If False, the warning
|
will be logged and the exception will be suppressed.
|
|
In some use cases it's necessary to disable thread local storage. For
|
example, if you have code where one thread acquires a lock and passes
|
that lock instance to a worker thread to release later. If thread
|
local storage isn't disabled in this case, the worker thread won't see
|
the token set by the thread that acquired the lock. Our assumption
|
is that these cases aren't common and as such default to using
|
thread local storage.)rt ri ru rv rx ry r ) rà rÏ rt ri ru rv rw rx ry s re ÚlockzRedisCluster.lock s5 ðH Ð Ü JÙØ Ø ØØØ Ø -Ø%Ø#9ô
|
ð
|
rg Úfuncc óö K |j dd« }|j dd« }|j dd« }| j d|« 4 d{ } |r |j | d{ ||« d{ }|j « d{ } |r|n| cddd« d{ S 7 _7 F7 87 "7 # t $ r ||dkD rt j |« Y w xY w# 1 d{ 7 sw Y yxY ww)zç
|
Convenience method for executing the callable `func` as a transaction
|
while watching all keys specified in `watches`. The 'func' callable
|
should expect a single argument which is a Pipeline object.
|
rp NÚvalue_from_callableFÚ watch_delayTr )rc rs ÚwatchÚexecuterI Útimeri )
|
rà r| Úwatchesr\ rp r~ r ÚpipeÚ
|
func_valueÚ
|
exec_values
|
re ro zRedisCluster.transactionþ sõ è ø ð ZZ ¨dÓ3
|
Ø $jjÐ)>ÀÓ FÐØ jj °Ó5 Ø== zÓ2÷ ð °dØð Ù Ø (djj¨'Ð 2×2Ð2Ù'+¨D£z×!1JØ'+§|¡|£~×!5JÙ)<:À*ÐL÷ ÷ ò øð 3øØ!1øØ!5øð ùô "ò Ø"Ð.°;À²?Ü
|
|
;Ô/Ù ð ú÷ ÷ ñ üs A C9ÁB/ÁC9ÁC$ÁB9Á*B1Á+B9Á:B3Á;B9ÂB5Â B9Â C9Â)B7Â*C9Â1B9Â3B9Â5B9Â7C9Â9%C!Ã C$Ã C!Ã!C$Ã$C6Ã*C- Ã+C6Ã2C9)r] rZ ©r] N)r] rX )rÅ rX r] N©NNN©F)NN)Ng¹?TNNTT)NÚ__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú classmethodrE r rf Ú __slots__rN rP r r r< r Úboolr- r rÔ r5 Úfloatr ÚbytesrV rU rT r r r7 rÆ rÈ rË rO rÎ rÖ rÓ rÕ râ r ræ rò ÚwarningsÚwarnrÁ Úget_running_loopr÷ r r¶ r r r r r r r r rK r r r# r r% r r' r r+ r6 r5 rF rL rb rL rR rs r r{ r ro ra rg re rZ rZ d sP ñcðJ ð 3ð ¨#ð °.ò ó ð ð@Iñ" Ø*Ð+ØGØôñ
|
à *ð
|
ð =Øô ð #Ø $à7;Ø&*Ø#(ØCGØ&*Ø"#Ø,-Ø $Ø#'Ø:>à Ø "Ø<@Ø"&Ø"&Ø%)Ø",Ù%4Ó%6à Ø 'Ø!&à'(Ø26Ø!&ØNRØ*.àØ&*Ø%)Ø0:Ø@DØ@DØ&*Ø#'Ø%)Ø04Ø%)Ø"#ØPTØ6:ñat*àsmðt*ð CHoðt*ð
|
]Ñ 3Ñ4ð t*ð $ð t*ð !ðt*ð "*Ð*?Ñ!@ðt*ð $ðt*ð ðt*ð '*ðt*ð ðt*ð Ñ ðt*ð ! d¨9¡oÑ!6Ñ7ð t*ð #s(Oð!t*ð" smð#t*ð$ &Ð&8Ñ 9ð%t*ð& 3-ð't*ð( 3-ð)t*ð* c]ð+t*ð, 3-ð-t*ð. c]ð/t*ð2 ð3t*ð4 ð5t*ð6 ð7t*ð: %ð;t*ð< !)¨¡ð=t*ð> ð?t*ð@ #+¨7°3¸¸cÀ5¸jÑ8IÐ3IÑ+JÑ"KðAt*ðB ! ðCt*ðF ðGt*ðH smðIt*ðJ c]ðKt*ðL S *_Ñ-ðMt*ðN #+¨4° Ñ+<Ñ"=ðOt*ðP #+¨4° Ñ+<Ñ"=ðQt*ðR smðSt*ðT !ðUt*ðV c]ðWt*ðX " *Ñ-ðYt*ðZ c]ð[t*ð\ 3-ð]t*ð^ ¨%°°S°©/Ð):¸EÀ#ÀsÀ(¹OÐ)KÑ LÑMð_t*ð` # ?Ñ3ðat*ðb
|
òct*óó ðt*óló& Eñ Ð1GÈgÔVò ó Wð ó ð '¨ó 'ð'¨ó 'ò0ð-9 S¨$°Ð%>Ñ?ó -ð 2Lð ]]Ø×,Ñ,ñ àð ð ð ð
|
ó ð
|
=¨:ð
|
=¸$ó
|
=ð=4 Ñ.ó =ðDt MÑ 2ó DðDd =Ñ 1ó DóLó/ó /ð #Ø "Ø#'ñ BàsmðBð smðBð C=ð Bð
|
|
-Ñ ó Bð ).ñ$Øð$Ø!%ð$à -Ñ ó$ð82:ð 2¨#ó 2ð Wó ð& t¨C°¸#± Ð,>Ñ'?ó &ðuð ¨ó ð4¨Sð 4Ð<Mð 4ÐRVó 4ð
|
DHò!
|
Øð!
|
Ø#&ð!
|
Ø3;¸C±=ð!
|
à mÑ ó!
|
ðF1¨Sð 1¸ð 1Àó 1ðfQ¨#ð Q°$ó Qð°ð ¸¸]Ñ8Kó ð(R ¨:ð R Àð R Èó R ðhV-Ø(ðV-Ø16°t¸ZÐ7GÑ1HðV-ØTWðV-à óV-ðr NRñ 2Ø# C=ð 2Ø=EÀc¹]ð 2à ó 2ð$ $(ØØ Ø,0Ø+/Ø !Ø'+ñO
|
àðO
|
ð % ðO
|
ð ð O
|
ð
|
ð O
|
ð # 5/ð O
|
ð T $ZÑ(ðO
|
ð ðO
|
ð !%ðO
|
ð
|
óO
|
ðb Ø dÐ$5°sÐ :Ñ;ô rg rZ c ó: e Zd ZdZdZ d%deddedeeef de e d ed
|
e
|
e d e d dfd Z d efdZ de d efdZdZej$ ej( fde de d dfdZd&dZd efdZded dfdZdedede d e fdZd e de d e fd Zd ed d efd Z d!e fd"Z d#e fd$Z y)'rX z
|
Create a new ClusterNode.
|
|
Each ClusterNode manages multiple :class:`~redis.asyncio.connection.Connection`
|
objects for the (host, port).
|
) Ú _connectionsÚ_freeri rº r_ rm r r rÏ r rt Ú server_typeNr| )r r_ r r r r r_ rm r] c ó |dk( rt j |« }||d< ||d< || _ || _ t ||« | _ || _ || _ || _ || _ |j di « | _ g | _ t j | j ¬« | _ | j j! dd « | _ | j" t% « | _ y y )NÚ localhostr r rt )Úmaxlenr¤ )ÚsocketÚ gethostbynamer r r/ rÏ r r r_ rm rc rt r Ú collectionsÚdequer r¸ rº r7 )rà r r r r r_ rm s re rÆ zClusterNode.__init__. sÝ ð ;Ò Ü×'Ñ'¨Ó-Dà$(Ð&Ñ!Ø$(Ð&Ñ!Ø Ø Ü! $¨Ó- Ø&Ôà .Ô Ø 0Ô Ø!2Ô Ø"3×"7Ñ"7Ð8LÈbÓ"QÔ à.0ÔÜ(3×(9Ñ(9À×AUÑAUÔ(V
|
Ø!%×!7Ñ!7×!;Ñ!;Ð<NÐPTÓ!UÔ Ø × !Ñ !Ð )Ü%4Ó%6DÕ "ð *rg c óp d| j d| j d| j d| j d S )Nz[host=z, port=z, name=z, server_type=ú])r r rÏ r rÌ s re Ú__repr__zClusterNode.__repr__M s? àTYYKw t§y¡y kð 2ØII;n¨T×-=Ñ-=Ð,>¸að Að
|
rg Úobjc óX t |t « xr |j | j k( S rä )rD rX rÏ )rà r¤ s re Ú__eq__zClusterNode.__eq__S s! Ü#{Ó+ÒE°·±¸D¿I¹IÑ0EÐErg zUnclosed ClusterNode objectrè ré c óê | j D ]T }|j s || j d| t | ¬« | | j d} |« j |« y y # t
|
$ r Y y w xY w)Nrë rì rî )r Ú is_connectedrò ró rô rõ )rà rè ré rø rö s re r÷ zClusterNode.__del__X s ð
|
×+Ñ+ò JØ×&Ó&Ù×*Ñ*Ð+¨1¨T¨HÐ5´ÈtÕTðØ)-¸$×:KÑ:KÑ LGÙF×1Ñ1°'Ô:ñ ñ øô $ò ØÙðús ¼%A%Á% A2Á1A2c ó K t j d | j D « ddi d { }t d |D « d « }|r|y 7 w)Nc 3 ób K | ]' }t j |j « « ) y wrä ©rÁ rQ Ú
|
disconnect)rS rø s re rT z)ClusterNode.disconnect.<locals>.<genexpr>j s, è ø ò à ô ×#Ñ# J×$9Ñ$9Ó$;×<ñùó -/Úreturn_exceptionsTc 3 óB K | ] }t |t « s| y wrä )rD rÔ )rS r³ s re rT z)ClusterNode.disconnect.<locals>.<genexpr>p s è ø ÒEC¬*°S¼)Õ*DCÑEùs )rÁ rX r Únext)rà r` Úexcs re r¬ zClusterNode.disconnecth s\ è ø ÜNNñà"&×"3Ñ"3ôð
|
ð
|
#ñ
|
÷
|
ô ÑE 3ÔEÀtÓLÙ ØIð ð
|
ús *A ¬A A c ó | j j « S # t $ r t | j « | j
|
k rkt t « dt f¬« }| j j « }||d< | j di |¤}| j j |« |cY S t « w xY w)Nr )r« r¬ Úsupported_errorsrj ra )r ÚpopleftÚ
|
IndexErrorr r r r r# r< rm r r_ r¹ rA )rà rj rm rø s re Úacquire_connectionz ClusterNode.acquire_connectiont s· ð (Ø::×%Ñ%Ó'Ð 'øÜò (Ü4×$Ñ$Ó%¨×(<Ñ(<Ò<ô Ü %KØ Ü&5Ð%7ôð
|
%)×$:Ñ$:×$?Ñ$?Ó$AÐ!Ø-2Ð! 'Ñ*Ø 2T× 2Ñ 2Ñ GÐ5FÑ G
|
Ø×!Ñ!×(Ñ(¨Ô4Ø!Ò!ä%Ó'Ð 'ð- (ús BB=Â2 B=rø c ó: | j j |« y)z8
|
Release connection back to free queue.
|
N)r r¹ rþ s re ÚreleasezClusterNode.release s ð
|
|
×Ñ*Õ%rg r( r\ c ó K t |v r0|j d¬« d { }|j t « n|j « d { }t |v r|j t « |j dd « || j
|
v r | j
|
| |fi |¤S |S 7 7 [# t $ r t |v r |t cY S w xY ww)NT)Údisable_decodingr@ )r% rý rc rE r$ rt )rà rø r( r\ Úresponses re Úparse_responsezClusterNode.parse_response sÎ è ø ð ÜvÑ%Ø!+×!9Ñ!9È4Ð!9Ó!P×PØ
|
|
<Õ(à!+×!9Ñ!9Ó!;×;ô VÑ #Ø JJ~Ô &ð
|
|
64Ô ð d×-Ñ-Ñ -Ø34×*Ñ*¨7Ñ3°HÑGÀÑGÐ Gàð' Qøð <ùÜ ò Ü Ñ'Ø nÑ-Ò-Ø ð üsK C B- ¡B)¢-B- ÁB+ÁB- ÁACÂ)B- Â+B- Â-C ÃCà C à Cr- c ó6 K | j « }|j |j | d« d { | j ||d fi |¤ d { | j j |« S 7 ?7 !# | j j |« w xY ww)NFr )r¶ Úsend_packed_commandÚ pack_commandr¼ r r¹ )rà r- r\ rø s re rb zClusterNode.execute_command¯ s è ø à×,Ñ,Ó.
|
ð ×,Ñ,Ð-D¨Z×-DÑ-DÀdÐ-KÈUÓS×SÐSð *Ø,×,Ñ,¨Z¸¸a¹ÑKÀFÑK×Kð JJ× Ñ jÕ )ð Tøð Lùð JJ× Ñ jÕ )üs8 3BµA5¶B»A9 ÁA7ÁA9 Á BÁ7A9 Á9 BÂBÚcommandsÚPipelineCommandc ó K | j « }|j |j d |D « « d« d { d}|D ]; } | j ||j d fi |j
|
¤ d { |_ = | j j |« |S 7 c7 *# t $ r}||_ d}Y d }~vd }~ww xY ww)Nc 3 ó4 K | ] }|j y wrä )r- )rS r² s re rT z/ClusterNode.execute_pipeline.<locals>.<genexpr>Ã s è ø Ò$B°# S§X¥XÑ$Bùs Fr T)
|
r¶ r¾ Ú pack_commandsr¼ r- r\ ÚresultrÔ r r¹ )rà rÀ rø r` r² ra s re Úexecute_pipelinez ClusterNode.execute_pipeline½ sÒ è ø à×,Ñ,Ó.
|
ð ×,Ñ,Ø × $Ñ $Ñ$B¸Ô$BÓ BÀEó
|
÷
|
ð
|
ð
|
Øò Cð Ø#6 4×#6Ñ#6Ø §¡¨¡ ñ$Ø/2¯z©zñ$÷
|
ð ð
|
|
×Ñ*Ô%à
|
ð%
|
øð ùô ò Ø
|
Øûð üsK <C¾B"¿ CÁ .B&Á9B$Á: B& CÂ$B&Â& CÂ/ B=Â8CÂ=CÃCÚtokenc óÖ K t j « } j r j j « j j fd fd« d { j j fd fd« d { |j « j r|r/|j « j j « |r.y y 7 ~7 Vw)Nc ód j dj d« j « « S )NÚAUTHÚoid)rü Útry_getÚ get_value)ÚconnrÇ s re r´ z.ClusterNode.re_auth_callback.<locals>.<lambda>Û s) ø ×)Ñ)ØEMM¨%Ó 0°%·/±/Ó2Có rg c ó& j | « S rä ©Ú_mock©Úerrorrà s re r´ z.ClusterNode.re_auth_callback.<locals>.<lambda>Þ s ø djj¨Ó / rg c ó$ j « S rä )rý )rÎ s re r´ z.ClusterNode.re_auth_callback.<locals>.<lambda>á s ø ×*Ñ*Ó, rg c ó& j | « S rä rÐ rÒ s re r´ z.ClusterNode.re_auth_callback.<locals>.<lambda>á s ø ¸D¿J¹JÀuÓ<M rg )r r r r´ rj Úcall_with_retryr¹ )rà rÇ Ú tmp_queuerÎ s `` @re Úre_auth_callbackz ClusterNode.re_auth_callbackÖ sÆ úè ø Ü ×%Ñ%Ó' ØjjØ::×%Ñ%Ó'DØ**×,Ñ,ôó 0ó ÷ ð ð **×,Ñ,Û,Ó.Mó÷ ð ð × Ñ TÔ "ð jjñ Ø ×$Ñ$Ó&DØ JJ× Ñ dÔ #ô ð øð ús0
A!C)Á&C%Á')C)ÂC'Â!C)Â3/C)Ã#C)Ã'C)rÓ c ó K yw)z
|
Dummy functions, needs to be passed as error callback to retry object.
|
:param error:
|
:return:
|
Nra ©rà rÓ s re rÑ zClusterNode._mocké s è ø ð ùó rä r )!r r r r r r rE r r< r r r rÆ r£ r r¦ rò r r rÁ r r÷ r¬ r¶ r¸ r¼ rb r rÆ r! rØ rD rÑ ra rg re rX rX sj ñð Ið& &*ð 7ð %Ø-7ò 7àð 7ð CHoð 7ð c]ð 7ð ð 7ð zÑ*ð 7ð !ð 7ð
|
ó 7ð>
|
#ó
|
ð F#ð F $ó Fð 1Lð ]]Ø×,Ñ,ñàðð ðð
|
ó ó
|
ð( Jó (ð6& *ð &°ó &ð Ø$ðØ/2ðØ>Aðà óð4 *¨3ð *¸#ð *À#ó *ð ¨tÐ4EÑ/Fð È4ó ð2$¨Nó $ð& ô rg c óV e Zd ZdZ d ded dedeeef dede e
|
e ee f ge ee f f d e e d
|
dfd Z d d e e d e e de e d
|
e d fdZ d!deedf deedf ded
|
dfdZd Zd"dZ d#de ded
|
dfdZded
|
ed fdZd"dZd$d ed
|
dfd Zd ed e d
|
e ee f fd Zy)%r» ) Ú_dynamic_startup_nodesrj rº rm rÉ r Úread_load_balancerr r r r£ Nr rX r rm r
r£ r¤ r] c ó |D ci c] }|j | c}| _ || _ || _ || _ d | _ i | _ i | _ t « | _ || _
|
d | _ |t « | _ y || _ y c c}w rä )rÏ r r rm r£ rÉ r r r, rÞ rÝ rj r7 rº )rà r r rm r
r£ r¤ rÅ s re rÆ zNodesManager.__init__ s ð ;HÖ H°$dii¨oÒ HÔØ%:Ô"Ø!2Ô Ø *Ôà+/ÔØ57ÔØ;=ÔÜ".£.Ô à,AÔ#Ø,0Ô Ø Ð #Ü%4Ó%6DÕ "à%5DÕ "ùò Is
Br r r c óÚ |rB|r@|dk( rt j |« }| j j t ||¬« « S |r| j j |« S t d« )Nr rg zEget_node requires one of the following: 1. node name 2. host and port)r r r r¸ r/ r> r s re r zNodesManager.get_node si ñ Dà{Ò"Ü ×+Ñ+¨DÓ1Ø×#Ñ#×'Ñ'¬ ¸4ÀdÔ(KÓLÐ LÙ Ø×#Ñ#×'Ñ'¨ Ó2Ð 2äØWóð rg ÚoldÚnewÚ
|
remove_oldc óP |rUt |j « « D ]9 }||vst j |j |« j « « }; |j « D ]< \ }}||v r.|| |u rt j || j « « }|||< > y rä )r° r@ rÁ rQ rc r¬ Úitems)rà rá râ rã rÏ ÚtaskrÅ s re Ú set_nodeszNodesManager.set_nodes- s¢ ñ Ü SXXZÓ(ò KØs?Ü"×.Ñ.¨s¯w©w°t«}×/GÑ/GÓ/IÓJDð Kð ))+ò JD$Øs{Øt9 Ñ$Ø Ü ×*Ñ*¨3¨t©9×+?Ñ+?Ó+AÓBØ CIñ rg c ó || _ y rä )rj )rÃ Ú exceptions re Úupdate_moved_exceptionz#NodesManager.update_moved_exception? s
|
Ø )Õ rg c ó6 | j }| j |j |j ¬« }|r |j t
|
k7 rdt
|
|_ nXt |j |j t
|
fi | j ¤}| j | j |j |i« || j |j v r±| j |j d }t |_ | j |j j |« | j |j j |« || j |j d< | j |k( r)|| _ d | _ y |g| j |j < d | _ y )Nrg r )rj r r r r r( rX rm rç r rÏ r Úslot_idr) r¹ ÚremoverÉ )rà ra Úredirected_nodeÚ old_primarys re Ú_update_moved_slotsz NodesManager._update_moved_slotsB s\ Ø × !Ñ !Ø --¨Q¯V©V¸!¿&¹&-ÓAÙ à ×*Ñ*¬gÒ5ä.5Õ+ô *ؤñ Ø+/×+AÑ+Añ Oð NN4×+Ñ+¨o×.BÑ.BÀOÐ-TÔ UØ d× .Ñ .¨q¯y©yÑ 9Ñ 9ð ×*Ñ*¨1¯9©9Ñ5°aÑ8Kô '.KÔ #Ø × Ñ QYYÑ '× .Ñ .¨{Ô ;ð × Ñ QYYÑ '× .Ñ .¨Ô ?à-<D× Ñ QYYÑ '¨Ñ *Ø× Ñ KÒ/à$3Ô!ð !%Õ ð ,;Ð*;D× Ñ QYYÑ 'à $Õ rg r rq c óæ | j r| j « |du r|t j } t | j
|
| « dkD rc|ra| j
|
| d j }| j j |t | j
|
| « |« }| j
|
| | S | j
|
| d S # t t f$ r t d| d| j d« w xY w)NTr§ r r z5" not covered by the cluster. "require_full_coverage=ú") rj rð r- Ú ROUND_ROBINr r rÏ rÞ Úget_server_indexrµ rI rF r )rà r rq r Ú primary_namer s re r4 z NodesManager.get_node_from_sloth s ð × Ò Ø × $Ñ $Ô &à Ñ %Ð*AÐ*IÜ&;×&GÑ&GÐ #ð Ü4×#Ñ# DÑ)Ó*¨QÒ.Ñ3Jà #× /Ñ /°Ñ 5°aÑ 8× =Ñ = Ø ×2Ñ2×CÑCØ ¤# d×&6Ñ&6°tÑ&<Ó"=Ð?Vó ð ×'Ñ'¨Ñ-¨hÑ7Ð7Ø×#Ñ# DÑ)¨!Ñ,Ð ,øÜIÐ&ò Ü%Øð *Ø*.×*DÑ*DÐ)EÀQðHóð ð ús ´A=C Â2C Ã,C0r c óz | j j « D cg c] }|j |k( r| c}S c c}w rä )r r± r )rà r rÅ s re r z%NodesManager.get_nodes_by_server_type sA ð ×(Ñ(×/Ñ/Ó1ö
|
àØ× Ñ ;Ò.ò ò
|
ð
|
ùò
|
s 8c
|
ó` K | j j « i }i }g }d}d}d }t | j j « « D ]à } | j
|
j t | j | j j dd « « « |j d« d { }d}t |« dk( r8|d d d s-t | j « dk( r|j |d d d< |D ] }
|
t# dt |
|
« « D ]! } |
|
| D cg c] } t% | « c} |
|
| < # |
|
d } | d }|d k( r |j }t' | d « }| j) ||« \ }}g }|j t+ ||« « }|s t- ||t. fi | j ¤}|||j0 < |j3 |« |
|
d
|
d }|D ]z }|d }|d }| j) ||« \ }}|j t+ ||« « }|s t- ||t4 fi | j ¤}|||j0 < |j3 |« | t# t' |
|
d « t' |
|
d « dz « D ] } | |vr||| < || d }|j0 |j0 k7 s/|j3 |j0 d |j0 d | « t |« d kD skt ddj7 |« « d}t# t8 « D ]
|
} | |vsd} n |sá n |st dt; |« « ||s+| j< r t dt |« dt8 d« || _ | jA | j |d¬« | jB r(| jA | j | j d¬« | jE t. « d | _# d | _$ y 7 F# t $ r t d« w xY w# t $ r } | }Y d } ~ Õd } ~ ww xY wc c} w w)NFr rµ z(Cluster mode is not enabled on this nodeTr§ r r Ú r{ z vs z
|
on slot: rz z6startup_nodes could not agree on a valid slots cache: z, zORedis Cluster cannot be connected. Please provide at least one reachable node: z9All slots are not covered after query all startup_nodes. z of z covered...)rã )%rÞ ÚresetÚtupler r± rº Údispatchr6 r rm r¸ rb rE rC rÔ r r rV rR r< Úremap_host_portr/ rX r( rÏ r¹ r) Újoinr3 rE r r rç rÝ r rÉ rj )rà Útmp_nodes_cacheÚ tmp_slotsÚ disagreementsÚstartup_nodes_reachableÚ fully_coveredré Ú startup_nodeÚ cluster_slotsra r ÚiÚvalÚ primary_noder r Únodes_for_slotrc Ú replica_nodesÚ replica_nodeÚtarget_replica_nodeÚtmp_slots re rÈ zNodesManager.initialize s´ è ø Ø × Ñ ×%Ñ%Ô'Ø46Ø46 Ø Ø"'Ð Ø Ø ô " $×"4Ñ"4×";Ñ";Ó"=Ó >ó a Lð ð Ø×*Ñ*×3Ñ3Ü;Ø × ,Ñ ,Ø × 2Ñ 2× 6Ñ 6Ð7LÈdÓ Sóôð +7×*FÑ*FÀÓ*W×$WMð
|
+/Ð'ô MÓ" aÒ'Ø% aÑ(¨Ñ+¨AÒ.Ü×*Ñ*Ó+¨qÒ0à)5×):Ñ): aÑ Ñ# AÑ&à%ó 4 "Ü q¤# d£)Ó,ò EAØ<@À¹GÖ D°S|¨CÕ 0Ò DDGðEà # Aw Ø# AØ2:Ø'×,Ñ,DÜ<¨?Ó+Ø !× 1Ñ 1°$¸Ó =
|
dà!#à -× 1Ñ 1´-ÀÀdÓ2KÓ L Ù"Ü"-Ø d¤Gñ#Ø/3×/EÑ/Eñ#Kð 5@ × 0Ñ 0Ñ1Ø ×%Ñ% kÔ2à $ Q R Ø$1ò ?LØ'¨?DØ'¨?DØ!%×!5Ñ!5°d¸DÓ!AJD$à*9×*=Ñ*=¼mÈDÐRVÓ>WÓ*XÐ'Ù.Ü.9Ø $¬ñ/Ø37×3IÑ3Iñ/Ð+ð ATOÐ$7×$<Ñ$<Ñ=Ø"×)Ñ)Ð*=Õ>ð ?ô s 4¨¡7|¬S°°a±«\¸AÑ-=Ó>ò "AØ Ñ)Ø'5 ! ð $-¨Q¡<°¡?Ø#==¨K×,<Ñ,<Ó<Ø )× 0Ñ 0Ø#+§=¡= /°°k×6FÑ6FÐ5GÀzÐRSÐQTÐ Uô ô # =Ó 1°AÓ 5Ü&;ð'4Ø48·I±I¸mÓ4LÐ3Mð%Oó'"ð !"ò"ðI4 "ðn !MÜÔ3Ó4ò ØIÒ%Ø$)MÙð ó ÙðCa ñF 'Ü'ð'Ü'*¨9£~Ð&6ð8óð ð ñ ×!;Ò!;ô (ØKÜy>Ð" $Ô'?Ð&@ð A ð óð ð %ÔØ t×'Ñ'¨ ÀTÔJà × &Ò &à NN4×-Ñ-¨t×/?Ñ/?ÈDNÔ Qð !× 9Ñ 9¼'Ó BÀ1Ñ EÔà $Õ ði %XúÜ$ò Ü/ØBóð ðûô
|
ò ð Ýûð üò, Eùs| AP.ÁA O8Â/O5Â0O8Â4PÂ6A+P.Ä!P)
|
Ä3E:P.Ê.;P.Ë*9P.Ì$P.Ì-CP.Ï5O8Ï8P Ð PÐ P&ÐP!ÐP.Ð!P&Ð&P.Úattrc ó K d | _ t j d t | |« j « D « d { y 7 w)Nc 3 ób K | ]' }t j |j « « ) y wrä r« ©rS rÅ s re rT z&NodesManager.aclose.<locals>.<genexpr> s* è ø ò àô ×#Ñ# D§O¡OÓ$5×6ñùr )rÉ rÁ rX Úgetattrr± )rà r s re rË zNodesManager.aclose sA è ø Ø ÔÜnnñä # D¨$Ó /× 6Ñ 6Ó 8ôð
|
÷
|
ò
|
ús <A¾A¿Ac óH | j r| j ||f« S ||fS )z³
|
Remap the host and port returned from the cluster to a different
|
internal value. Useful if the client is not connecting directly
|
to the cluster.
|
)r£ )rà r r s re rü z NodesManager.remap_host_port s, ð × Ò Ø×%Ñ% t¨T lÓ3Ð 3ØTzÐrg )TNNr r r )FN)r )r r r r r r r rE r r r r r< r7 rÆ r rç rê rð r4 r rÈ rË rü ra rg re r» r» ò s¤ ð Ið& '+ØPTØ6:ñ6àMÑ*ð6ð $ð6ð S >ð 6ð
|
$ð 6ð ¨%°°S°©/Ð):¸EÀ#ÀsÀ(¹OÐ)KÑ LÑMð 6ð # ?Ñ3ð6ð
|
ó6ð8 #Ø "Ø#'ñ àsmðð smðð C=ð ð
|
|
-Ñ ó ð, !ñ à #}Ð$Ñ %ð ð #}Ð$Ñ %ð ð ð ð
|
|
ó ò$*ó$%ðR $)Ø $ñ àðð !ðð
|
|
ó ð6
|
°Cð
|
¸DÀ Ñ<Oó
|
óH%ñT
|
ð
|
¸ó
|
ð Cð ¨sð °u¸SÀ#¸X±ô rg r» c ó e Zd ZdZdZ d dedee ddfdZd dZ d d Z
|
d!d
|
Z de e dd f fd Zdefd Zdefd Zdeeef de dd fdZ d"dededee fdZdededd fdZd Zd Zd Z d Z d Z d Z d e e!ef dd fd Z"y)#rq a·
|
Create a new ClusterPipeline object.
|
|
Usage::
|
|
result = await (
|
rc.pipeline()
|
.set("A", 1)
|
.get("A")
|
.hset("K", "F", "V")
|
.hgetall("K")
|
.mset_nonatomic({"A": 2, "B": 3})
|
.get("A")
|
.get("B")
|
.delete("A", "B", "K")
|
.execute()
|
)
|
# result = [True, "1", 1, {"F": "V"}, True, True, "2", "3", 1, 1, 1]
|
|
Note: For commands `DELETE`, `EXISTS`, `TOUCH`, `UNLINK`, `mset_nonatomic`, which
|
are split across multiple nodes, you'll get multiple results for them in the array.
|
|
Retryable errors:
|
- :class:`~.ClusterDownError`
|
- :class:`~.ConnectionError`
|
- :class:`~.TimeoutError`
|
|
Redirection errors:
|
- :class:`~.TryAgainError`
|
- :class:`~.MovedError`
|
- :class:`~.AskError`
|
|
:param client:
|
| Existing :class:`~.RedisCluster` client
|
)Úcluster_clientÚ _transactionÚ_execution_strategyNrï ro r] c óz || _ || _ | j st | « | _ y t | « | _ y rä )r r ÚPipelineStrategyÚTransactionStrategyr )rà rï ro s re rÆ zClusterPipeline.__init__O sC ð %ÔØ 'Ôð ×$Ò$ô TÓ "ð Õ ô % TÓ*ð Õ rg c óV K | j j « d { | S 7 wrä )r rÈ rÌ s re rÈ zClusterPipeline.initializeZ s( è ø Ø×&Ñ&×1Ñ1Ó3×3Ð3Ø ð 4ús ) '¡)c ó> K | j « d { S 7 wrä )rÈ rÌ s re rÖ zClusterPipeline.__aenter__^ s è ø Ø__Ó&×&Ð&Ð&ús c ó@ K | j « d { y 7 wrä ©rù )rà rÞ rß rà s re râ zClusterPipeline.__aexit__a ó è ø Øjjl×ÒúrÑ c ó> | j « j « S rä rå rÌ s re ræ zClusterPipeline.__await__d rç rg c ó y)z?Pipeline instances should always evaluate to True on Python 3+Tra rÌ s re Ú__bool__zClusterPipeline.__bool__g s àrg c ó, t | j « S rä )r r rÌ s re Ú__len__zClusterPipeline.__len__k s Ü4×+Ñ+Ó,Ð,rg r- r\ c ó: | j j |i |¤S )ad
|
Append a raw command to the pipeline.
|
|
:param args:
|
| Raw command args
|
:param kwargs:
|
|
- target_nodes: :attr:`NODE_FLAGS` or :class:`~.ClusterNode`
|
or List[:class:`~.ClusterNode`] or Dict[Any, :class:`~.ClusterNode`]
|
- Rest of the kwargs are passed to the Redis connection
|
)r rb ©rà r- r\ s re rb z ClusterPipeline.execute_commandn s" ð 8t×'Ñ'×7Ñ7¸ÐHÀÑHÐHrg Úraise_on_errorÚallow_redirectionsc óÈ K | j j ||« d{ | j « d{ S 7 7 # | j « d{ 7 w xY ww)a
|
Execute the pipeline.
|
|
It will retry the commands as specified by retries specified in :attr:`retry`
|
& then raise an exception.
|
|
:param raise_on_error:
|
| Raise the first error if there are any errors
|
:param allow_redirections:
|
| Whether to retry each failed command individually in case of redirection
|
errors
|
|
:raises RedisClusterException: if target_nodes is not provided & the command
|
can't be mapped to a slot
|
N)r r rù ©rà r& r' s re r zClusterPipeline.execute~ sU è ø ð$ Ø ×1Ñ1×9Ñ9Ø Ð 2ó÷ ð **,× Ñ ð øð ù$**,× Ò üsG A" A £A ¤A §A"ºA»A"Á A ÁA"ÁA ÁAÁA Á A"r( r@ c ó | j j |« j « D ] } | j |g|¢ | S rä )r Ú_partition_keys_by_slotr± rb )rà r( r@ Ú slot_keyss re Ú_split_command_across_slotsz+ClusterPipeline._split_command_across_slots sI ð ×,Ñ,×DÑDÀTÓJ×QÑQÓSò 6IØ D× Ñ Ð 5¨9Ô 5ð 6ð rg c óT K | j j « d{ y7 w©z/
|
Reset back to empty pipeline.
|
N)r rù rÌ s re rù zClusterPipeline.reset s è ø ð ×&Ñ&×,Ñ,Ó.×.Ò.úó ( &¡(c ó8 | j j « y)z
|
Start a transactional block of the pipeline after WATCH commands
|
are issued. End the transactional block with `execute`.
|
N)r ÚmultirÌ s re r2 zClusterPipeline.multi¥ s ð
|
× Ñ ×&Ñ&Õ(rg c óT K | j j « d{ y7 w)rë N)r ÚdiscardrÌ s re r4 zClusterPipeline.discard¬ ó è ø à×&Ñ&×.Ñ.Ó0×0Ò0úr0 c óR K | j j | d{ y7 w)z$Watches the values at keys ``names``N)r r ©rà Únamess re r zClusterPipeline.watch° s" è ø à,d×&Ñ&×,Ñ,¨eÐ4×4Ò4úó '% 'c óT K | j j « d{ y7 w)z'Unwatches all previously specified keysN)r ÚunwatchrÌ s re r; zClusterPipeline.unwatch´ r5 r0 c óR K | j j | d { y 7 wrä )r Úunlinkr7 s re r= zClusterPipeline.unlink¸ s" è ø Ø-d×&Ñ&×-Ñ-¨uÐ5×5Ò5úr9 Úmappingc ó8 | j j |« S rä )r Úmset_nonatomic©rà r> s re r@ z ClusterPipeline.mset_nonatomic» s ð ×'Ñ'×6Ñ6°wÓ?Ð?rg rä ©r] rq )rÞ Nrß Nrà Nr] N©TT)#r r r r r rZ r r rÆ rÈ rÖ râ r r ræ r! r< r# r rL rK rb r r rE r- rù r2 r4 r r; r= r rJ r@ ra rg re rq rq ( s( ñ"ðH JIð CGñ
|
Ø"ð
|
Ø19¸$± ð
|
à ó
|
óó'óð-9 S¨$Ð0AÐ%AÑBó -ð$ó ð-ó -ðIØ4 Ð+Ñ,ðIØ8;ðIà óIð" GKñ Ø "ð Ø?Cð à có ð2ØðØ#'ðà óò/ò )ò1ò5ò1ò6ð@Ø w¨
|
Ð 2Ñ3ð@à ô@rg rq rë r_ r@ c ó0 e Zd ZdedededdfdZdefdZy)rÁ Úpositionr- r\ r] Nc ó< || _ || _ || _ d | _ y rä )r- r\ rE rÅ )rà rE r- r\ s re rÆ zPipelineCommand.__init__Ê s Ø Ø Ø Ø-1 rg c óV d| j d| j d| j dS )Nú[z] ú (ú))rE r- r\ rÌ s re r£ zPipelineCommand.__repr__Ð s) Ø4==/ D§I¡I ;¨b°·±° ¸QÐ?Ð?rg )r r r r< r rÆ rE r£ ra rg re rÁ rÁ É s1 ð2 ð 2¨Sð 2¸Cð 2ÀDó 2ð @#ô @rg rÁ c ó e Zd Zedd« Zedeeef deddfd« Z e dde
|
de
|
de e fd « Z ed
|
e eef ddfd « Zed « Zed « Zed « Zed « Zed « Zed « Zedefd« Zy)ÚExecutionStrategyr] rq c ó K yw)z^
|
Initialize the execution strategy.
|
|
See ClusterPipeline.initialize()
|
Nra rÌ s re rÈ z ExecutionStrategy.initializeÕ ó è ø ð ùrÛ r- r\ c ó y)zf
|
Append a raw command to the pipeline.
|
|
See ClusterPipeline.execute_command()
|
Nra r% s re rb z!ExecutionStrategy.execute_commandÞ ó ð rg r& r' c ó K yw)zÈ
|
Execute the pipeline.
|
|
It will retry the commands as specified by retries specified in :attr:`retry`
|
& then raise an exception.
|
|
See ClusterPipeline.execute()
|
Nra r) s re r zExecutionStrategy.executeé s è ø ð ùrÛ r> c ó y)z
|
Executes multiple MSET commands according to the provided slot/pairs mapping.
|
|
See ClusterPipeline.mset_nonatomic()
|
Nra rA s re r@ z ExecutionStrategy.mset_nonatomic÷ rP rg c ó K yw)zZ
|
Resets current execution strategy.
|
|
See: ClusterPipeline.reset()
|
Nra rÌ s re rù zExecutionStrategy.reset rN rÛ c ó y)zU
|
Starts transactional context.
|
|
See: ClusterPipeline.multi()
|
Nra rÌ s re r2 zExecutionStrategy.multi s ð rg c ó K yw)zI
|
Watch given keys.
|
|
See: ClusterPipeline.watch()
|
Nra r7 s re r zExecutionStrategy.watch rN rÛ c ó K yw)za
|
Unwatches all previously specified keys
|
|
See: ClusterPipeline.unwatch()
|
Nra rÌ s re r; zExecutionStrategy.unwatch rN rÛ c ó K y wrä ra rÌ s re r4 zExecutionStrategy.discard& ó è ø à ùrÛ c ó K yw)z^
|
"Unlink a key specified by ``names``"
|
|
See: ClusterPipeline.unlink()
|
Nra r7 s re r= zExecutionStrategy.unlink* rN rÛ c ó y rä ra rÌ s re r# zExecutionStrategy.__len__3 ó à rg NrB rC )r r r r rÈ r rL rK r rb r r r r rJ r@ rù r2 r r; r4 r= r< r# ra rg re rL rL Ô s> Øò ó ð ð ð Ø4 Ð+Ñ,ð Ø8;ð à ò ó ð ð àFJñ Ø "ð Ø?Cð à cò ó ð ð ð Ø w¨
|
Ð 2Ñ3ð à ò ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ð ò ó ñ rg rL c ó e Zd ZdeddfdZddZdeeef de ddfd Z
|
d
|
Z e d e eef ddfd « Ze dd ededee fd« Ze d « Ze d « Ze d « Ze d « Ze d « Ze d « ZdefdZy)ÚAbstractStrategyr r] Nc ó || _ g | _ y rä )Ú_pipeÚ_command_queue)rà r s re rÆ zAbstractStrategy.__init__9 s Ø&*
|
Ø79Õrg rq c óÌ K | j j j r,| j j j « d { g | _ | j S 7 wrä )r_ r rh rÈ r` rÌ s re rÈ zAbstractStrategy.initialize= sL è ø Ø ::× $Ñ $× 0Ò 0Ø**×+Ñ+×6Ñ6Ó8× 8Ð 8Ø ÔØzzÐð 9ús AA$Á
|
A"Á A$r- r\ c ó | j j t t | j « g|¢i |¤« | j S rä )r` r¹ rÁ r r_ r% s re rb z AbstractStrategy.execute_commandC sA ð ×Ñ×"Ñ"Ü C × 3Ñ 3Ó 4Ð F°tÒ F¸vÑ Fô
|
ð zzÐrg c ó´ dj t t |« « }d| dt |« d|j d }|f|j dd z |_ y)zS
|
Provides extra context to the exception prior to it being handled
|
rë ú
|
Command # rI ú ) of pipeline caused error: r r§ N)rý ÚmaprQ rS r- )rà ré Únumberr( r² Úmsgs re Ú_annotate_exceptionz$AbstractStrategy._annotate_exceptionK se ð hhs8 WÓ-Ó.à ¤=°Ó#5Ð"6ð 7 Ø &^^¨AÑ .Ð /ð 1ð ð )§.¡.°°Ð"4Ñ4 rg r> c ó y rä ra rA s re r@ z AbstractStrategy.mset_nonatomicV s ð rg r& r' c ó K y wrä ra r) s re r zAbstractStrategy.execute\ s è ø ð ùrÛ c ó K y wrä ra rÌ s re rù zAbstractStrategy.resetb rX rÛ c ó y rä ra rÌ s re r2 zAbstractStrategy.multif r[ rg c ó K y wrä ra r7 s re r zAbstractStrategy.watchj rX rÛ c ó K y wrä ra rÌ s re r; zAbstractStrategy.unwatchn rX rÛ c ó K y wrä ra rÌ s re r4 zAbstractStrategy.discardr rX rÛ c ó K y wrä ra r7 s re r= zAbstractStrategy.unlinkv rX rÛ c ó, t | j « S rä )r r` rÌ s re r# zAbstractStrategy.__len__z s Ü4×&Ñ&Ó'Ð'rg rB rC )r r r rq rÆ rÈ r rL rK r rb ri r r rJ r@ r r r rù r2 r r; r4 r= r< r# ra rg re r] r] 8 s+ ð:_ð :°ó :óð Ø4 Ð+Ñ,ðØ8;ðà óò 5ð ð Ø w¨
|
Ð 2Ñ3ð à ò ó ð ð
|
àFJñ Ø "ð Ø?Cð à cò ó ð ð
|
ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð ñ ó ð ð(ô (rg r] c ó² e Zd Zdeddf fd Zdeeef ddfdZ dde d e de
|
e fd
|
Z dd d d e
|
d de d e de
|
e f
|
dZ d Zd Zd Zd Zd Zd Z xZS )r r r] Nc ó$ t | |« y rä )ÚsuperrÆ ©rà r r¼ s re rÆ zPipelineStrategy.__init__ s ø Ü ÑÕ rg r> rq c óT | j j j }i }|j « D ]@ }t |j |d « « }|j |g « j |« B |j « D ] } | j dg|¢ | j S )Nr ÚMSET)
|
r_ r rn rå r4 r! Ú
|
setdefaultÚextendr± rb )rà r> rn Ú slots_pairsÚpairr Úpairss re r@ z PipelineStrategy.mset_nonatomic s ð **×+Ñ+×3Ñ3à ØMMOò :DÜGNN¨4°©7Ó 3Ó4DØ × "Ñ " 4¨Ó ,× 3Ñ 3°DÕ 9ð :ð !×'Ñ'Ó)ò 1EØ D× Ñ Ð 0¨%Ô 0ð 1ð zzÐrg r& r' c ó K | j sg S | j j j j « } | j j j
|
r,| j j j « d { | j | j j | j ||¬« d { | j « d { S 7 W7 7 # t j $ rb}|dkD rQ|dz }| j j j « d { 7 t j d« d { 7 n|Y d }~nd }~ww xY w # | j « d { 7 w xY ww)N)r& r' r r§ rf )r` r_ r rj rU rh rÈ Ú_executerù rZ rZ rË rÁ ri )rà r& r' r\ ra s re r zPipelineStrategy.execute sB è ø ð ×"Ò"ØIð Ø !ZZ× 6Ñ 6× <Ñ <× HÑ HÓ JNØð Øzz×0Ñ0×<Ò<Ø "jj× 7Ñ 7× BÑ BÓ D×DÐDØ!%§ ¡ Ø
|
|
×1Ñ1Ø ×+Ñ+Ø'5Ø+=ð "/ó "÷ ð$ **,× Ñ ð' Eøð øð$ ùô $×6Ñ6ò Ø%¨Ò)ð '¨!Ñ+Ø "jj× 7Ñ 7× >Ñ >Ó @×@Ñ@Ü %mm¨DÓ 1×1Ò1ð ô 2ûð úñ øð, **,× Ò üs E?/E! ÁAC' Â C!Â
|
:C' ÃC#ÃC' ÃE?ÃC%Ã E?Ã!C' Ã#C' Ã%E?Ã'E Ã:1EÄ+D.Ä, EÅ E Å
|
EÅE! ÅE Å E! Å!E<Å5E8Å6E<Å<E?rï rZ ÚstackrÁ c ó6 K |D cg c]+ }|j rt |j t « s*|- }}i }|D ]í }|j j dd « }|r#|j |« s|j |« } n? |j |j d|i d { } | st d|j d« t | « dkD rt d|j « | d }
|
|
|
j |vr|
|
g f||
|
j < ||
|
j d j |« ï t j d |j « D « d { } t! | « rf|ra|D ]\ }t |j t" t$ t& f« s) |j( |j i |j ¤ d { |_ ^ |r|D ] }|j } t | t « s d j+ t- t. |j « « }d
|
|j0 dz d t3 |« d | j }|f| j dd z | _ | |j5 « }|^|j7 |j « }|A|d D ]9 }t9 |j « t: j< v s)|j? « n |D cg c] }|j c}S c c}w 7 M7 7 4# t $ r} | |_ Y d } ~ d } ~ ww xY wc c}w w) NrB r, rN rO r§ z Too many targets for command r c 3 óp K | ]. }t j |d j |d « « 0 yw)r r§ N)rÁ rQ rÆ r s re rT z,PipelineStrategy._execute.<locals>.<genexpr>Ñ s6 è ø ò àô ×#Ñ# D¨¡G×$<Ñ$<¸TÀ!¹WÓ$E×Fñùs 46rë rd rI re ) rÅ rD rÔ r\ rc rF rL r6 r- rC r rÏ r¹ rÁ rX r± ÚanyrH rB r8 rb rý rf rQ rE rS r r¸ rJ rZ rZ rW )rà rï r r& r' r² ÚtodorK r] rB rÅ Úerrorsra rÅ r( rh Údefault_cluster_noderÉ s re r zPipelineStrategy._execute± s è ø ð !ö
|
ب¯
|
ª
|
´jÀÇÁÌYÕ6WCð
|
ð
|
ð Øò ,CØ ZZ^^¨N¸DÓ ANÙ f×&:Ñ&:¸>Ô&JØ %× 9Ñ 9¸.Ó I à%< V×%<Ñ%<ØXXð&Ø)7ñ&÷ ñ $Ü/Ø;¸C¿H¹H¸:À[ÐQóð ô <Ó 1Ò$Ü+Ð.KÈCÏHÉHÈ:Ð,VÓWÐWØ ?DØyy Ñ%Ø$(¨" :diiÑ Ø $))Ñ QÑ × &Ñ & sÕ +ð# ,ô& ~~ñà !LLNôð
|
÷
|
ô v;Ù!à ò +CÜ! #§*¡*¬}¼jÌ(Ð.SÕTð+Ø/E¨v×/EÑ/EØ!$§¡ð0 Ø-0¯Z©Zñ0 ÷ * CJð+ñ Ø ò
|
%CØ ZZFÜ! &¬)Õ4Ø"%§(¡(¬3¬x¸¿¹Ó+BÓ"Cà (¨¯ © ¸Ñ)9Ð(:ð ; Ü -¨gÓ 6Ð 7ð 89Ø9?¿¹¸ ð Gð ð
|
(+ f¨v¯{©{¸1¸2¨Ñ&> Ø $ ð
|
%ð $*×#:Ñ#:Ó#<Ð ð
|
$Ð/Ø $yyÐ)=×)BÑ)BÓ C Ø Ð+ð
|
,¨Aò "ô §
|
¡
|
Ó+¬|×/NÑ/NÒNØ "× 7Ñ 7Ô 9Ù !ð "ð ',Ö,s
|
|
Ò,Ð,ùòW
|
ð ùð
|
ùð* úô )ò +Ø)*CJJûð+üòF -ùs L+K(³K(·A)LÂ K-Â!B6LÅK0Å<LÆ)K6Æ?K3Ç K6Ç %LÇ/C LÊ;LËLË% LË0LË3K6Ë6 LË?L ÌLÌ LÌLc ó K g | _ ywr/ )r` rÌ s re rù zPipelineStrategy.reset s è ø ð !Õùs c ó t d« )Nz@method multi() is not supported outside of transactional context©rC rÌ s re r2 zPipelineStrategy.multi s Ü#Ø Nó
|
ð
|
rg c ó K t d« w)Nz@method watch() is not supported outside of transactional contextr r7 s re r zPipelineStrategy.watch s è ø Ü#Ø Nó
|
ð
|
ùó c ó K t d« w)NzBmethod unwatch() is not supported outside of transactional contextr rÌ s re r; zPipelineStrategy.unwatch ó è ø Ü#Ø Pó
|
ð
|
ùr c ó K t d« w)NzBmethod discard() is not supported outside of transactional contextr rÌ s re r4 zPipelineStrategy.discard r r c óf K t |« dk7 r t d« | j d|d « S w)Nr§ z>unlinking multiple keys is not implemented in pipeline commandÚUNLINKr )r rC rb r7 s re r= zPipelineStrategy.unlink s: è ø Ü u:?Ü'ØPóð ð ×#Ñ# H¨e°A©hÓ7Ð7ùs /1rC )r r r rq rÆ r rJ rK r@ r r r r r rù r2 r r; r4 r= Ú __classcell__©r¼ s @re r r ~ sÊ ø ð _ð °õ ð Ø w¨
|
Ð 2Ñ3ð à ó ð GKñ Ø "ð Ø?Cð à có ðH $Ø#'ñ R-à ðR-ð Ð%Ñ&ðR-ð ð R-ð
|
!ð R-ð
|
có R-òh!ò
|
ò
|
|
ò
|
|
ò
|
|
ö
|
8rg r c ó^ e Zd ZdhZddhZh d£ZeefZe e
|
e e fZ deddf fd Zdeeef fdZd eeef d
|
edd fd Zd eeef d
|
edef fd Zd Zd Zd Z dedefdZ d Z d Z de e!ef ddfdZ" d&de#de#de$e fdZ%d e$d de#fd Z&d e$d de#fd Z'd Z(d! Z)d" Z*d# Z+d$ Z,d% Z- xZ.S )'r ÚUNWATCHÚWATCH> ÚEXECÚDISCARDr r r] Nc óP t | |« d| _ d| _ t « | _ d | _ d | _ d| _ t | j j j « | _ | j j t j | j" z « y )NF)ru rÆ Ú_explicit_transactionÚ _watchingÚsetÚ_pipeline_slotsÚ_transaction_nodeÚ_transaction_connectionÚ
|
_executingr r_ r rj Ú_retryr· rZ rZ ÚSLOT_REDIRECT_ERRORSrv s re rÆ z TransactionStrategy.__init__4 s ø Ü ÑÔ Ø%*Ô"Ø Ü),«Ô Ø8<Ô Ø=AÔ$Ø Ü4::×4Ñ4×:Ñ:Ó; Ø ×+Ñ+Ü × +Ñ +¨d×.GÑ.GÑ Gõ
|
rg c óT | j s t d« | j j j j t | j « d d« }|| _ | j s!| j j « }|| _ | j | j fS )ao
|
Find a connection for a pipeline transaction.
|
|
For running an atomic transaction, watch keys ensure that contents have not been
|
altered as long as the watch commands for those keys were sent over the same
|
connection. So once we start watching a key, we fetch a connection to the
|
node that owns that slot and reuse it.
|
z:At least a command with a key is needed to identify a noder F)
|
r rC r_ r rp r4 r° r r r¶ )rà rÅ rø s re Ú*_get_client_and_connection_for_transactionz>TransactionStrategy._get_client_and_connection_for_transactionA s ð ×#Ò#Ü'ØLóð ð !JJ× 5Ñ 5× CÑ C× VÑ VÜ ×%Ñ%Ó & qÑ )¨5ó
|
ð "&Ô à×+Ò+Ø%)×%;Ñ%;×%NÑ%NÓ%PJØ+5DÔ (à×%Ñ% t×'CÑ'CÐCÐCrg r- r\ r c ó d d fd}t j |¬« }|j « |j « rS )Nc ó t j j i ¤« y # t $ r } | Y d } ~ y d } ~ ww xY wrä )rÁ ÚrunrR rÔ )ra r- rÓ r\ r» rà s re Úrunnerz3TransactionStrategy.execute_command.<locals>.runnera s> ø ð Ü";;Ð'< t×'<Ñ'<¸dÐ'MÀfÑ'MÓNøÜ ò Øûð ús %) © >²9¹>)Útarget)Ú threadingÚThreadÚstartrý )rà r- r\ r§ ÚthreadrÓ r» s ``` @@re rb z#TransactionStrategy.execute_command\ sH ü àØ÷ ð ô ×!Ñ!¨Ô0Ø Ø á ØKàrg c óô K | j j j r,| j j j « d { d }|d | j vr+ | j j j
|
| d { }| j s|d | j v r| j s|d dk( r| j « |A| j r|| j vr t d« | j j |« n#|d | j vrt d|d d« | j |i |¤S || j j |« t | @ |i |¤S 7 (7 ìw)Nr r z0Cannot watch or send commands on different slotsz)Cannot identify slot number for command: z(,it cannot be triggered in a transaction)r_ r rh rÈ ÚNO_SLOTS_COMMANDSr5 r ÚIMMEDIATE_EXECUTE_COMMANDSr Ú_validate_watchr r= ÚaddrC Ú_immediate_execute_commandru rb )rà r- r\ Ú slot_numberr¼ s re rR z$TransactionStrategy._execute_commandr su øè ø ð ::× $Ñ $× 0Ò 0Ø**×+Ñ+×6Ñ6Ó8× 8Ð 8à%) Ø 7$×0Ñ0Ñ 0Ø I §
|
¡
|
× 9Ñ 9× IÑ IÈ4Ð P×PKð NNd 1g¨×)HÑ)HÑ HØ×,Ò,ØAw'Ò!Ø×$Ñ$Ô&àÐ&Ø×'Ò'¨K¸t×?SÑ?SÑ,SÜ3ØJóð ð ×$Ñ$×(Ñ(¨Õ5Øa × 6Ñ 6Ñ6Ü+Ø?ÀÀQÁ¸yð I>ð >óð ð
|
34×2Ñ2°DÐC¸FÑCÐ CàÐ&Ø×$Ñ$×(Ñ(¨Ô5ä7Ñ*¨DÐ;°FÑ;Ð ;ð= 9ùð Qús% AE8Á E3Á =E8 E6Â
|
C*E8Å6E8c ó@ | j r t d« d| _ y )Nú"Cannot issue a WATCH after a MULTIT)r rD r rÌ s re r° z#TransactionStrategy._validate_watch s Ø × %Ò %Ü Ð AÓBÐ Bà rg c óz K j j fd j « d { S 7 w)Nc ó( j i ¤S rä )Ú _get_connection_and_send_command)r- Úoptionsrà s re r´ z@TransactionStrategy._immediate_execute_command.<locals>.<lambda> s ø Ð9D×9Ñ9¸4ÐKÀ7ÑK rg ©r rÖ Ú_reinitialize_on_error)rà r- r¹ s ```re r² z.TransactionStrategy._immediate_execute_command s4 úè ø Ø[[×0Ñ0Ý KØ × 'Ñ 'ó
|
÷
|
ð
|
ð
|
úó
/;´9µ;c óz K | j « \ }} | j |||d g|¢i |¤ d { S 7 wr¯ )r£ Ú _send_command_parse_response)rà r- r¹ Ú
|
redis_noderø s re r¸ z4TransactionStrategy._get_connection_and_send_command¢ sS è ø Ø!%×!PÑ!PÓ!RÑ
|
JØ6T×6Ñ6Ø
|
D¨¡Gð
|
Ø.2ò
|
Ø6=ñ
|
÷
|
ð
|
ð
|
ús 2;´9µ;rø r¿ c ó¦ K |j | d{ |j ||fi |¤ d{ }|| j v rd| _ |S 7 77 w)z7
|
Send a command and parse the response
|
NF)rü r¼ ÚUNWATCH_COMMANDSr )rà rø r¿ Ú command_namer- r¹ Úoutputs re r¾ z0TransactionStrategy._send_command_parse_response¨ s] è ø ð &j×%Ñ% tÐ,×,Ð,Ø0z×0Ñ0°¸\ÑUÈWÑU×Uà 4×0Ñ0Ñ 0Ø "DNØ ð -øØUús AA A±A² AÁAc ó8 K | j r.t |« | j v r| j r t d« t |« | j v st |« | j
|
v r$| j rd | _ | j j xj dz c_ | j j j r| j j j | j j j z dk( rE| j j j j « d { d| _ d| _ y t |t « r/| j j j j |« d| _ y 7 Zw)Nz-Slot rebalancing occurred while watching keysr§ r F)r rJ r¡ r rI ÚCONNECTION_ERRORSr r_ r rr rs rp rÈ rD r8 rê rÚ s re r» z*TransactionStrategy._reinitialize_on_error» s: è ø Ø >>ÜE{d× 7Ñ 7Ñ7¸D¿OºOÜ Ð!PÓQÐQô K4×4Ñ4Ñ 4ÜE{d× 4Ñ 4Ò4à×+Ò+Ø/3Ô,à JJ× %Ñ %× :Ò :¸aÑ ?Õ :à
|
|
×)Ñ)×<Ò<ØJJ×-Ñ-×BÑBØ**×+Ñ+×>Ñ>ñ?àòð jj×/Ñ/×=Ñ=×HÑHÓJ×JÐJØ,-Ô)ð ô e¤XÔ.ØJJ×-Ñ-×;Ñ;×RÑRØ ôð ð Kús D;FÄ=FÄ>AFc ó¤ t ||« D ]A \ }}t |t « s| j ||j dz |j
|
« | y)z8
|
Raise the first exception on the stack
|
r§ N)rY rD rÔ ri rE r- )rÃ Ú responsesr Úrr² s re Ú_raise_first_errorz&TransactionStrategy._raise_first_errorØ sL ô ) UÓ+ò FAsÜ!YÕ'Ø×(Ñ(¨¨C¯L©L¸1Ñ,<¸c¿h¹hÔGØñ rg r> rq c ó t d« )Nz1Method is not supported in transactional context.)ÚNotImplementedErrorrA s re r@ z"TransactionStrategy.mset_nonatomicá s ô "Ð"UÓVÐVrg r& r' c ó K | j }|s| j r | j sg S | j ||« d { S 7 wrä )r` r r Ú!_execute_transaction_with_retries)rà r& r' r s re r zTransactionStrategy.executeæ sB è ø ð ×#Ñ#Ùdnn°D×4HÒ4HØIà×;Ñ;¸EÀ>ÓR×RÐRÐRús >AÁ AÁAr rÁ c óz K j j fd j « d { S 7 w)Nc ó( j « S rä )Ú_execute_transaction)r& rà r s re r´ zGTransactionStrategy._execute_transaction_with_retries.<locals>.<lambda>ó s ø D×-Ñ-¨e°^ÓD rg rº )rà r r& s ```re rÍ z5TransactionStrategy._execute_transaction_with_retriesï s6 úè ø ð [[×0Ñ0Ý DØ × 'Ñ 'ó
|
÷
|
ð
|
ð
|
úr¼ c óR K t | j « dkD r t d« d| _ | j « \ }}t t dd« g|t dd« g« }|D cg c]! }t |j vs|j # }}|j |« }|j |« d { g } |j |d« d { t# | j$ « D ]W \ } } t | j v r%|j | | j t f« = |j |d« d { } Y d } |j |d« d { }d| _ d| _ | t- d « |D ] \ } } |j/ | | « t |« t | j$ « k7 rIt1 d
|
j3 | j$ D cg c] }|j d c}t |« « « |st |« dkD r | j5 || j$ « g }t7 || j$ « D ] \ }}t9 |t: « se|j d }|| j< j> j@ v r4 | j< j> j@ | |fi |j ¤}|j |« |S c c}w 7 (7 # t $ r/} | j | dd« |j | « Y d } ~ ?d } ~ w| j $ r}
|
| j |
|
dd« d }
|
~
|
ww xY w7 # | j& $ r<}| j || dz | j « |j |« Y d }~¡d }~w| j $ r&}
|
| j |
|
| dz | j « d }
|
~
|
wt $ r<} | j | | dz | j « |j | « Y d } ~ d } ~ ww xY w7 # t( $ r |r|d w xY wc c}w w) Nr§ zDAll keys involved in a cluster transaction must map to the same slotTr ÚMULTIr r_ FzWatched variable changed.zeUnexpected response length for cluster pipeline EXEC. Command stack was {} but response had length {})!r r r= r r£ r rÁ r$ r\ r- rÄ r¾ r¼ rE ri r¹ rÅ Ú enumerater` r¡ r? r rI Úinsertr@ ÚformatrÉ rY rD rÔ r_ r rt )rà r r& r¿ rø ÚcrÀ Úpacked_commandsr
ra Ú cluster_errorr r( r_ Ú
|
slot_errorr» ÚdatarÈ r² r s re rÐ z(TransactionStrategy._execute_transaction÷ së è ø ô t×#Ñ#Ó $ qÒ (Ü+ØVóð ð à!%×!PÑ!PÓ!RÑ
|
JäÜ Q Ó (Ð )Ø Ü Q Ó 'Ð (ó
|
ð
|
%*ÖLq¬^À1Ç8Á8Ò-KAFFÐLÐLØ$×2Ñ2°8Ó<Ø×,Ñ,¨_Ó=×=Ð=Øð Ø ×+Ñ+¨J¸Ó@× @Ð @ô $ D×$7Ñ$7Ó8ò %JAwÜ § ¡ Ñ/Ø q '§.¡.´ Ñ"@Ð AÕBð
|
%Ø (× 7Ñ 7¸
|
ÀCÓ H×HAð %ð ð Ø '× 6Ñ 6°zÀ6Ó J×JHð ð à Ð Ü Ð 8Ó9Ð 9ð ò "DAqØ OOAqÕ !ð "ô x=C × 3Ñ 3Ó 4Ò 4Ü&ðCßCIÁ6Ø(,×(;Ñ(;Ö< 1QVVAYÒ<¼cÀ(»móDóð ñ S [¨1_Ø × #Ñ #ØØ×#Ñ#ô ð Ü( D×$7Ñ$7Ó8ò FAsÜ a¤Ô+Ø "xx¨{ Ø 4§:¡:×#<Ñ#<×#OÑ#OÑOØR
|
|
×1Ñ1×DÑDÀ\ÑRØñØ ZZñAð KKNð ð ùòc Mà=ùð AúÜ ò Ø × $Ñ $ Q¨¨7Ô 3Ø MM!× Ò ûØ×%Ñ%ò Ø × $Ñ $ ]°A°wÔ ?Ø ûð úð IúØ×0Ñ0ò .Ø×,Ñ,¨Z¸¸Q¹ÀÇ Á ÔMØMM *×-Ò-ûØ×-Ñ-ò Ø×,Ñ,¨]¸AÀ¹EÀ7Ç<Á<ÔPØûÜ$ò %Ø×,Ñ,¨Q°°A±°w·|±|ÔDØMM !×$Ò$ûð%úð KúÜ ò ÙØ QiØ ð üò* =ùsÿ A%P'Á'KÁ?K 'P'Â4K Â5P'Â<K" ÃK ÃK" ÃAP'Ä)MÄ>MÄ?MÅP'ÅP Å P
|
Å P Å"A6P'ÇP" Ç.C/P'Ë K" Ë" M Ë+$LÌP'ÌM Ì'L;Ì;M Í P'ÍMÍPÍ1N ÎP'Î PÎ !N?Î? PÏ 1PÏ<P'ÐPÐP'Ð
|
P Ð P Ð P'c ó K g | _ | j r~ | j rE| j j d« d { | j j « d { | j
|
j | j « d | _ d | _ d| _ d| _ t « | _ d| _ y 7 ~7 ^# | j $ r2 | j r#| j j « d { 7 Y pw xY ww)Nr F) r` r r rü rý r r¸ rÅ r¬ r r r r rÌ s re rù zTransactionStrategy.reset[ sì è ø Ø Ôð × 'Ò 'ð DØ>>ð ×6Ñ6×CÑCÀIÓN×NÐNØ ×6Ñ6×DÑDÓF×FÐFð ×&Ñ&×.Ñ.¨t×/KÑ/KÔLØ/3Ô,ð "&Ô Ø Ø%*Ô"Ü "uÔ Ø ð! OøØFùð
|
×)Ñ)ò Dà×/Ò/Ø ×6Ñ6×AÑAÓC×CÑCùð DüsX D*C ÁC Á!C Á#CÁ$0C Â,Dà C ÃC Ã8DÃ<C?Ã=DÄDÄDÄDc ón | j r t d« | j r t d« d| _ y )Nz"Cannot issue nested calls to MULTIz:Commands without an initial WATCH have already been issuedT)r rD r` rÌ s re r2 zTransactionStrategy.multiw s: Ø × %Ò %Ü Ð AÓBÐ BØ × Ò Ü ØLóð ð &*Õ"rg c ór K | j r t d« | j dg|¢ d { S 7 w)Nrµ r )r rD rb r7 s re r zTransactionStrategy.watch s9 è ø Ø × %Ò %Ü Ð AÓBÐ Bà)T×)Ñ)¨'Ð:°EÒ:×:Ð:Ð:ús .7°5±7c óZ K | j r| j d« d { S y7 w)Nr T)r rb rÌ s re r; zTransactionStrategy.unwatch s) è ø Ø >>Ø ×-Ñ-¨iÓ8×8Ð 8àð 9ús !+£)¤+c ó@ K | j « d { y 7 wrä r rÌ s re r4 zTransactionStrategy.discard r rÑ c ó0 K | j dg|¢ S w)Nr )rb r7 s re r= zTransactionStrategy.unlink s è ø Ø#t×#Ñ# HÐ5¨uÒ5Ð5ùs rC )/r r r r® r¯ rÁ r8 rB r¡ r< ÚOSErrorr: rF rÅ rq rÆ r rX r r£ r rL rK r rb rR r° r² r¸ r¾ r» rÉ r rJ r@ r r r rÍ rÐ rù r2 r r; r4 r= r r s @re r r ( s ø Ø" ÐØ")¨9Ð!5Ð Ú5ÐØ $ jÐ1ÐàØØØð Ðð
|
_ð
|
°õ
|
ðDà {JÐ&Ñ 'óDð6 U¨4°Ð+;Ñ%<ð Èð ÐPUó ð,"<Ø4 Ð+Ñ,ð"<Ø8;ð"<à õ"<òH ò
|
ò
|
ð à ðð óò& ò:ðWØ w¨
|
Ð 2Ñ3ðWà óWð GKñSØ "ðSØ?CðSà cóSð
|
ØÐ+Ñ,ð
|
Ø>Bó
|
ðbØÐ+Ñ,ðbØ>BóbòH ò8*ò;ò ò ö6rg r )~rÁ r r r r© r r Úabcr r r Ú itertoolsr Útypingr r r r
|
r r r r r r r r r r Úredis._parsersr r Úredis._parsers.helpersr r r Úredis.asyncio.clientr Úredis.asyncio.connectionr r r Úredis.asyncio.lockr Úredis.asyncio.retryr Úredis.auth.tokenr! Ú redis.backoffr" r# Ú redis.clientr$ r% r& Ú redis.clusterr' r( r) r* r+ r, r- r. r/ r0 Úredis.commandsr1 r2 Ú redis.crcr3 r4 Úredis.credentialsr5 Ú redis.eventr6 r7 Úredis.exceptionsr8 r9 r: r; r< r= r> r? r@ rA rB rC rD rE rF rG rH rI Ú redis.typingrJ rK rL Ú redis.utilsrM rN rO rP rQ rR rS r` rT rU rV rE rW rZ rX r» rq r( ÚreplaceÚlowerÚsetattrrÁ rL r] r r ra rg re ú<module>rù sÉ ðÛ Û Û Û Û Û Û ß #Ý Ý ÷÷ ÷ ÷ ÷" 8÷ñ õ
|
3ß IÑ IÝ #Ý %Ý +ß Aß DÑ D÷ ÷ ÷ ÷ Dß 8Ý 0ß L÷÷ ÷ ÷ ÷ ÷( 3Ñ 2÷÷ ñ ñ ß7Ò7àJØJØKáØC ¨¨]Ñ(;¸TÀ#À}ÐBTÑ=Uó ô
|
p =Ð"6Ð8Qô p ÷f X ñ X ÷vsñ sôl V@mÐ%9Ð;Tô V@ðr )ò GGØooc 3Ó'×-Ñ-Ó/GØÐ"Ò"Øá OWÑ&<¸WÓ&EÕFð G÷@ñ @ôa ô a ôHC(Ð(ô C(ôLg8Ð'ô g8ôTh6Ð*õ h6rg
|
