Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/redis/__pycache__/connection.cpython-39.pyc
Ðазад
a a�h�� � @ s� d dl mZ d dlmZ d dlmZ d dlmZ d dlZd dlZd dl Z d dl Z d dl Z d dl Z d dl mZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m Z m Z m Z m Z d dl!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ d dl0m1Z1 zd dl2Z2d Z3W n e4�y( d Z3Y n0 e ej5iZ6e3�rfe7e2d ��r\d e6e2j8< d e6e2j9< n d e6e2j:< e j;e6v�r|d e6e j;< e<e6�=� �Z>e1�r�d dl?Z?ee?j@�ZAeAed�kZBeAed�kZCeAed�kZDeC�s�de?j@ ZEe �FeE� d ZGeC�s�d ZGdZHdZIdZJdZKdZLeM� ZNG dd� deM�ZOG dd� deM�ZPG dd � d eM�ZQG d d � d eP�ZRG d d � d eP�ZSe1�rbeSZTneRZTG d!d"� d"eM�ZUG d#d$� d$eU�ZVG d%d&� d&eU�ZWd'ZXd(d)� ZYeZeZeYeYe[e[eYd*�Z\G d+d,� d,eM�Z]G d-d.� d.e]�Z^dS )/� )�unicode_literals)� StrictVersion)�chain)�timeN)�xrange�imap�unicode�long� nativestr� basestring� iteritems� LifoQueue�Empty�Full�urlparse�parse_qs�recv� recv_into�unquote�BlockingIOError�sendall�shutdown�ssl_wrap_socket)�AuthenticationError�$AuthenticationWrongNumberOfArgsError�BusyLoadingError�ChildDeadlockedError�ConnectionError� DataError�ExecAbortError�InvalidResponse�NoPermissionError� NoScriptError� ReadOnlyError� RedisError� ResponseError� TimeoutError)�HIREDIS_AVAILABLETF�SSLWantReadError� i���z0.1.3z0.1.4z1.0.0z`redis-py works best with hiredis >= 0.1.4. You're running hiredis %s. Please consider upgrading.� *� $s � z Connection closed by server.c @ s* e Zd ZdZdd� Zdd� Zd dd�Zd S ) �Encoderz=Encode strings to bytes-like and decode bytes-like to stringsc C s || _ || _|| _d S �N��encoding�encoding_errors�decode_responses)�selfr0 r1 r2 � r4 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/redis/connection.py�__init__b s zEncoder.__init__c C s� t |ttf�r|S t |t�r&td��nTt |t�r>t|��� }n<t |tt f�rZt |��� }n t |t �szt |�j }td| ��t |t�r�|�| j| j�}|S )z=Return a bytestring or bytes-like representation of the valuezNInvalid input of type: 'bool'. Convert to a bytes, string, int or float first.zLInvalid input of type: '%s'. Convert to a bytes, string, int or float first.)� isinstance�bytes� memoryview�boolr �float�repr�encode�intr �strr �type�__name__r r0 r1 )r3 �value�typenamer4 r4 r5 r= g s � zEncoder.encodeFc C s: | j s |r6t|t�r |�� }t|t�r6|�| j| j�}|S )z:Return a unicode string from the bytes-like representation)r2 r7 r9 �tobytesr8 �decoder0 r1 )r3 rB �forcer4 r4 r5 rE } s zEncoder.decodeN)F)rA � __module__� __qualname__�__doc__r6 r= rE r4 r4 r4 r5 r- _ s r- c @ s4 e Zd Zeeeeed�eeee ee d�Z dd� Z dS )� BaseParser)z max number of clients reachedz(Client sent AUTH, but no password is setzinvalid passwordz,wrong number of arguments for 'auth' commandz,wrong number of arguments for 'AUTH' command)ZERRZ EXECABORTZLOADINGZNOSCRIPTZREADONLYZNOAUTHZNOPERMc C s\ |� d�d }|| jv rT|t|�d d� }| j| }t|t�rL|�|t�}||�S t|�S )zParse an error response� r � N)�split�EXCEPTION_CLASSES�lenr7 �dict�getr% )r3 �responseZ error_codeZexception_classr4 r4 r5 � parse_error� s zBaseParser.parse_errorN) rA rG rH r r r r r r" r# r! rN rS r4 r4 r4 r5 rJ � s � �rJ c @ sX e Zd Zdd� Zedd� �Zdedfdd�Zd d � Zd d � Z d d� Z dd� Z dd� Z dS )� SocketBufferc C s, || _ || _|| _t�� | _d| _d| _d S �Nr )�_sock�socket_read_size�socket_timeout�io�BytesIO�_buffer� bytes_written� bytes_read)r3 �socketrW rX r4 r4 r5 r6 � s zSocketBuffer.__init__c C s | j | j S r. )r\ r] �r3 r4 r4 r5 �length� s zSocketBuffer.lengthNTc C s� | j }| j}| j}|�| j� d}|tu}�zLz�|r>|�|� t| j |�} t| t �rht | �dkrht t ��|� | � t | �} | j| 7 _|| 7 }|d ur�||kr�q>W W |r�|�| j� dS tjy� |r�td��Y W |r�|�| j� dS t�yb } z^t�| jd�} |�s>| j| k�r>W Y d } ~ W |�r:|�| j� dS t d| jf ��W Y d } ~ n d } ~ 0 0 W |�r�|�| j� n|�r�|�| j� 0 d S �Nr TzTimeout reading from socketF���z#Error while reading from socket: %s)rV rW r[ �seekr\ �SENTINEL� settimeoutr r7 r8 rO r � SERVER_CLOSED_CONNECTION_ERROR�writerX r^ �timeoutr& �NONBLOCKING_EXCEPTIONS�#NONBLOCKING_EXCEPTION_ERROR_NUMBERSrQ � __class__�errno�args) r3 r` rh �raise_on_timeout�sockrW �buf�marker�custom_timeout�dataZ data_length�ex�allowedr4 r4 r5 �_read_from_socket� sV � � �� �z SocketBuffer._read_from_socketc C s t | j�p| j|dd�S )NF�rh rn )r: r` rv �r3 rh r4 r4 r5 �can_read� s ��zSocketBuffer.can_readc C sn |d }|| j kr"| �|| j � | j�| j� | j�|�}| jt|�7 _| j| jkrb| �� |d d� S )Nr) ���) r` rv r[ rc r] �readrO r\ �purge)r3 r` rs r4 r4 r5 r{ � s zSocketBuffer.readc C st | j }|�| j� |�� }|�t�sB| �� |�| j� |�� }q| jt|�7 _| j| jkrh| � � |d d� S )Nrz ) r[ rc r] �readline�endswith�SYM_CRLFrv rO r\ r| )r3 rp rs r4 r4 r5 r} � s zSocketBuffer.readlinec C s& | j �d� | j �� d| _d| _d S rU )r[ rc �truncater\ r] r_ r4 r4 r5 r| s zSocketBuffer.purgec C s: z| � � | j�� W n ty( Y n0 d | _d | _d S r. )r| r[ �close� ExceptionrV r_ r4 r4 r5 r� s zSocketBuffer.close) rA rG rH r6 �propertyr` rd rv ry r{ r} r| r� r4 r4 r4 r5 rT � s � +rT c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )� PythonParserzPlain Python parsing classc C s || _ d | _d | _d | _d S r. )rW �encoderrV r[ �r3 rW r4 r4 r5 r6 $ s zPythonParser.__init__c C s$ z | � � W n ty Y n0 d S r. �� on_disconnectr� r_ r4 r4 r5 �__del__* s zPythonParser.__del__c C s( |j | _ t| j | j|j�| _|j| _dS )z Called when the socket connectsN)rV rT rW rX r[ r� �r3 � connectionr4 r4 r5 � on_connect0 s �zPythonParser.on_connectc C s* d| _ | jdur | j�� d| _d| _dS )z"Called when the socket disconnectsN)rV r[ r� r� r_ r4 r4 r5 r� 8 s zPythonParser.on_disconnectc C s | j o| j �|�S r. )r[ ry rx r4 r4 r5 ry @ s zPythonParser.can_readc s � j �� }|stt��|d d� |dd � }}|dvrDtd| ��|dkrpt|�}� �|�}t|t�rl|�|S |dkrznn|dkr�t|�}n\|dkr�t |�}|dkr�d S � j � |�}n2|d kr�t |�}|dkr�d S � fd d �t |�D �}t|t ��r � j �|�}|S ) NrL )� -� +� :r+ r* zProtocol Error: %rr� r� r� r+ rb r* c s g | ] }� � � �qS r4 )� read_response)�.0�ir_ r4 r5 � <listcomp>k r, z.PythonParser.read_response.<locals>.<listcomp>)r[ r} r rf r r rS r7 r r> r{ r r8 r� rE )r3 �raw�byterR �errorr` r4 r_ r5 r� C s: zPythonParser.read_responseN) rA rG rH rI r6 r� r� r� ry r� r4 r4 r4 r5 r� " s r� c @ sN e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Ze d fd d�Z dd� Z dS )� HiredisParserz*Parser class for connections using Hiredisc C s$ t s td��|| _tr t|�| _d S )NzHiredis is not installed)r' r$ rW �HIREDIS_USE_BYTE_BUFFER� bytearrayr[ r� r4 r4 r5 r6 s s zHiredisParser.__init__c C s$ z | � � W n ty Y n0 d S r. r� r_ r4 r4 r5 r� { s zHiredisParser.__del__c C sh |j | _ |j| _t| jd�}ts(t|d< |jjr<|jj |d< t rL|jj |d< t j f i |��| _d| _d S )N)Z protocolError� replyErrorr� r0 �errorsF)rV rX �_socket_timeoutr rS � HIREDIS_SUPPORTS_CALLABLE_ERRORSr% r� r2 r0 � HIREDIS_SUPPORTS_ENCODING_ERRORSr1 �hiredis�Reader�_reader�_next_response)r3 r� �kwargsr4 r4 r5 r� � s � zHiredisParser.on_connectc C s d | _ d | _d| _d S )NF)rV r� r� r_ r4 r4 r5 r� � s zHiredisParser.on_disconnectc C s@ | j stt��| jdu r<| j �� | _| jdu r<| j|dd�S dS )NFrw T)r� r rf r� �gets�read_from_socketrx r4 r4 r5 ry � s �zHiredisParser.can_readTc C s� | j }|tu}�zVz�|r"|�|� trXt| j | j�}|dkrDtt��| j� | jd|� n8t | j | j �}t |t �r|t|�dkr�tt��| j� |� W W |r�|�| j� dS tjy� |r�td��Y W |r�|�| j� dS t�yP } z^t�|jd�}|�s,|j|k�r,W Y d }~W |�r(|�| j� dS td|jf ��W Y d }~n d }~0 0 W |�r||�| j� n|�rz|�| j� 0 d S ra )rV rd re r� r r[ r rf r� �feedr rW r7 r8 rO r� r^ rh r& ri rj rQ rk rl rm ) r3 rh rn ro rr Zbufflen�bufferrt ru r4 r4 r5 r� � sN � � �� �z HiredisParser.read_from_socketc C s� | j stt��| jdur(| j}d| _|S | j �� }|du rN| �� | j �� }q2ts�t|t�rn| � |j d �}n4t|t �r�|r�t|d t�r�| � |d j d �|d< t|t�r�|�n$t|t �r�|r�t|d t�r�|d �|S )NFr ) r� r rf r� r� r� r� r7 r% rS rm �list)r3 rR r4 r4 r5 r� � s0 � �zHiredisParser.read_responseN) rA rG rH rI r6 r� r� r� ry rd r� r� r4 r4 r4 r5 r� q s &r� c @ s� e Zd ZdZddddddddddddded dddfd d �Zd d � Zdd� Zdd� Zdd� Z dd� Z dd� Z dd� Z dd� Z d d � Zd d � Zd d!� Zd/d#d$�Zd%d&� Zd0d'd(�Zd)d*� Zd+d,� Zd-d.� ZdS )1� Connectionz4Manages TCP communication to and from a Redis server� localhost�� r NF�utf-8�strict� c C s� t �� | _|| _t|�| _|| _|| _|| _|| _ || _ |p>|| _ || _ |pNi | _ | | _| | _|| _d| _t| | | �| _d | _||d�| _g | _d| _d S �Nr )rW ip )�os�getpid�pid�hostr> �port�db�username� client_name�passwordrX �socket_connect_timeout�socket_keepalive�socket_keepalive_options� socket_type�retry_on_timeout�health_check_interval�next_health_checkr- r� rV �_parser�_connect_callbacks�_buffer_cutoff)r3 r� r� r� r� rX r� r� r� r� r� r0 r1 r2 � parser_classrW r� r� r� r4 r4 r5 r6 � s( zConnection.__init__c C s( d� dd� | �� D ��}d| jj|f S )N�,c S s g | ]\}}d ||f �qS )z%s=%sr4 )r� �k�vr4 r4 r5 r� r, z'Connection.__repr__.<locals>.<listcomp>�%s<%s>)�join� repr_piecesrk rA )r3 Z repr_argsr4 r4 r5 �__repr__ s zConnection.__repr__c C s6 d| j fd| jfd| jfg}| jr2|�d| jf� |S )Nr� r� r� r� )r� r� r� r� �append�r3 �piecesr4 r4 r5 r� s �zConnection.repr_piecesc C s$ z | � � W n ty Y n0 d S r. )� disconnectr� r_ r4 r4 r5 r� s zConnection.__del__c C s | j �|� d S r. )r� r� )r3 �callbackr4 r4 r5 �register_connect_callback$ s z$Connection.register_connect_callbackc C s g | _ d S r. )r� r_ r4 r4 r5 �clear_connect_callbacks' s z"Connection.clear_connect_callbacksc C s� | j r dS z | �� }W nN tjy2 td��Y n4 tjyd } zt| �|���W Y d}~n d}~0 0 || _ z | �� W n t y� | � � � Y n0 | j D ] }|| � q�dS )z5Connects to the Redis server if not already connectedNz Timeout connecting to server) rV �_connectr^ rh r& r� r �_error_messager� r$ r� r� )r3 ro �er� r4 r4 r5 �connect* s $ zConnection.connectc C s d}t �| j| j| jt j�D ]�}|\}}}}}d}z�t � |||�}|�t jt jd� | j r�|�t j t j d� t | j �D ]\} } |�t j| | � qv|�| j� |�|� |�| j� |W S t jy� } z | }|dur�|�� W Y d} ~ q d} ~ 0 0 q |du�r|�t �d��dS )z Create a TCP socket connectionNrL z)socket.getaddrinfo returned an empty list)r^ � getaddrinfor� r� r� � SOCK_STREAM� setsockopt� IPPROTO_TCP� TCP_NODELAYr� � SOL_SOCKET� SO_KEEPALIVEr r� re r� r� rX r� r� ) r3 �err�res�family�socktype�proto� canonnameZsocket_addressro r� r� �_r4 r4 r5 r� B s0 � zConnection._connectc C sJ t |j�dkr&d| j| j|jd f S d|jd | j| j|jd f S d S )NrL z Error connecting to %s:%s. %s.r z!Error %s connecting to %s:%s. %s.)rO rm r� r� �r3 � exceptionr4 r4 r5 r� j s ��zConnection._error_messagec C s� | j �| � | js| jr�| jr0| j| jp*df}n| jf}| jdg|�R ddi� z | �� }W n, ty� | jd| jdd� | �� }Y n0 t|�dkr�td��| j r�| �dd | j � t| �� �dkr�t d ��| j r�| �d | j � t| �� �dkr�t d ��d S )z=Initialize the connection, authenticate and select a database� ZAUTH� check_healthF�r� �OKz Invalid Username or PasswordZCLIENTZSETNAMEzError setting client nameZSELECTzInvalid DatabaseN) r� r� r� r� � send_commandr� r r r r� r r� )r3 Z auth_argsZ auth_responser4 r4 r5 r� t s* zConnection.on_connectc C sb | j �� | jdu rdS z*t�� | jkr6t| jtj� | j� � W n tj yV Y n0 d| _dS )z!Disconnects from the Redis serverN) r� r� rV r� r� r� r r^ � SHUT_RDWRr� r� r_ r4 r4 r5 r� � s zConnection.disconnectc C s� | j r�t� | jkr�z*| jddd� t| �� �dkr:td��W nD ttfy� | �� | jddd� t| �� �dkr|td��Y n0 dS )z3Check the health of the connection with a PING/PONGZPINGFr� ZPONGz#Bad response from PING health checkN) r� r r� r� r r� r r& r� r_ r4 r4 r5 r� � s ��zConnection.check_healthTc C s� | j s| �� |r| �� z*t|t�r,|g}|D ]}t| j |� q0W n� tjyh | �� t d��Y n� tj y� } zX| �� t |j �dkr�d|j d }}n|j d }|j d }t d||f ��W Y d}~n$d}~0 ty� | �� � Y n0 dS )z2Send an already packed command to the Redis serverzTimeout writing to socketrL �UNKNOWNr z%Error %s while writing to socket. %s.N)rV r� r� r7 r? r r^ rh r� r& r� rO rm r � BaseException)r3 �commandr� �itemr� rl �errmsgr4 r4 r5 �send_packed_command� s0 � z Connection.send_packed_commandc O s | j | j|� |�dd�d� dS )z+Pack and send a command to the Redis serverr� Tr� N)r� � pack_commandrQ )r3 rm r� r4 r4 r5 r� � s �zConnection.send_commandc C s$ | j }|s| �� | j }| j�|�S )z8Poll the socket to see if there's data that can be read.)rV r� r� ry )r3 rh ro r4 r4 r5 ry � s zConnection.can_readc C s� z| j �� }W n� tjy> | �� td| j| jf ��Y n` tjy� } z,| �� t d| j| j|j f ��W Y d}~n$d}~0 t y� | �� � Y n0 | j r�t � | j | _t|t�r�|�|S )z0Read the response from a previously sent commandzTimeout reading from %s:%sz#Error while reading from %s:%s : %sN)r� r� r^ rh r� r& r� r� r� r rm r� r� r r� r7 r% )r3 rR r� r4 r4 r5 r� � s( � � zConnection.read_responsec G s g }t |d t�r4t|d �� �� �|dd� }n(d|d v r\t|d �� �|dd� }t�ttt |���� t f�}| j }t | j j|�D ]|}t |�}t |�|ks�||ks�t |t�r�t�|tt|��� t f�}|�|� |�|� t }q�t�|tt|��� t |t f�}q�|�|� |S )z2Pack a series of arguments into the Redis protocolr rL N� )r7 r �tupler= rM � SYM_EMPTYr� �SYM_STARr? rO r r� r r� r9 � SYM_DOLLARr� )r3 rm �outputZbuff� buffer_cutoff�argZ arg_lengthr4 r4 r5 r� � s2 " �� �� zConnection.pack_commandc C s� g }g }d}| j }|D ]~}| j|� D ]n}t|�}||ksJ||ksJt|t�rb|�t�|�� d}g }||kstt|t�r�|�|� q$|�|� ||7 }q$q|r�|�t�|�� |S )z.Pack multiple commands into the Redis protocolr )r� r� rO r7 r9 r� r� r� ) r3 �commandsr� r� Z buffer_lengthr� �cmd�chunkZchunklenr4 r4 r5 � pack_commands s( � zConnection.pack_commands)T)r )rA rG rH rI � DefaultParserr6 r� r� r� r� r� r� r� r� r� r� r� r� r� ry r� r� r� r4 r4 r4 r5 r� � s4 � ( ' "r� c s* e Zd Zd� fdd� Z� fdd�Z� ZS ) � SSLConnectionN�requiredFc s� t s td��tt| �jf i |�� || _|| _|d u r>tj}n8t |t �rvtjtj tj d�}||vrntd| ��|| }|| _ || _|| _d S )Nz$Python wasn't built with SSL support)�none�optionalr z-Invalid SSL Certificate Requirements Flag: %s)� ssl_availabler$ �superr r6 �keyfile�certfile�ssl� CERT_NONEr7 r � CERT_OPTIONAL� CERT_REQUIRED� cert_reqs�ca_certs�check_hostname)r3 Z ssl_keyfileZ ssl_certfileZ ssl_cert_reqsZ ssl_ca_certs�ssl_check_hostnamer� Z CERT_REQS�rk r4 r5 r6 6 s, ���zSSLConnection.__init__c s� t t| ��� }ttd�rrt�� }| j|_| j|_| j rN| j rN|j | j | j d� | j r`|� | j � t||| jd�}n tt|| j| j | j | j d�}|S )z Wrap the socket with SSL support�create_default_context)r r )�server_hostname)r r r r )r r r� �hasattrr r r r � verify_moder r �load_cert_chainr �load_verify_locationsr r� )r3 ro �contextr r4 r5 r� Q s( � �zSSLConnection._connect)NNr NF)rA rG rH r6 r� � __classcell__r4 r4 r r5 r 4 s �r c @ sH e Zd Zdddddddddedddf dd �Zd d � Zd d � Zdd� ZdS )�UnixDomainSocketConnectionr� r Nr� r� Fr� c C sp t �� | _|| _|| _|| _| | _|| _|| _| | _ | | _ d| _ t |||�| _ d | _| | d�| _g | _d| _d S r� )r� r� r� �pathr� r� r� r� rX r� r� r� r- r� rV r� r� r� )r3 r r� r� r� rX r0 r1 r2 r� r� rW r� r� r4 r4 r5 r6 l s z#UnixDomainSocketConnection.__init__c C s. d| j fd| jfg}| jr*|�d| jf� |S )Nr r� r� )r r� r� r� r� r4 r4 r5 r� � s �z&UnixDomainSocketConnection.repr_piecesc C s, t � t jt j�}|�| j� |�| j� |S )z&Create a Unix domain socket connection)r^ �AF_UNIXr� re rX r� r )r3 ro r4 r4 r5 r� � s z#UnixDomainSocketConnection._connectc C sB t |j�dkr"d| j|jd f S d|jd | j|jd f S d S )NrL z(Error connecting to unix socket: %s. %s.r z+Error %s connecting to unix socket: %s. %s.)rO rm r r� r4 r4 r5 r� � s ��z)UnixDomainSocketConnection._error_message)rA rG rH r� r6 r� r� r� r4 r4 r4 r5 r j s � r )�0�F�FALSE�N�NOc C s6 | d u s| dkrd S t | t�r.| �� tv r.dS t| �S )Nr� F)r7 r �upper� FALSE_STRINGSr: )rB r4 r4 r5 �to_bool� s r# )rX r� r� r� �max_connectionsr� r c @ sv e Zd ZdZeddd��Zedfdd�Zdd � Zd d � Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� Zd dd�ZdS ) �ConnectionPoolzGeneric connection poolNFc K s> t |�}i }tt|j��D ]r\}}|rt|�dkrt�|�}|r�z||d �||< W q� ttfy| t � t d| �� Y q�0 q|d ||< q|r�|j r�t |j �nd} |jr�t |j�nd} |jr�t |j�nd} |jr�t |j�nd} n |j p�d} |jp�d} |j} |j} |jdk�r&|�| | | td�� n�|jdv �r�|�| t|j�pDd�| | d�� d |v�r�| �r�zt| �d d ��|d < W n ttf�y� Y n0 |jd k�r�t|d < nd�d�} td| ��t|�d |�p�d��|d < |�|� d|v �r t � td�� |�d�|d< d|v �r0t � td�� |�d�|d< | f i |��S )a Return a connection pool configured from the given URL. For example:: redis://[[username]:[password]]@localhost:6379/0 rediss://[[username]:[password]]@localhost:6379/0 unix://[[username]:[password]]@/path/to/socket.sock?db=0 Three URL schemes are supported: - ```redis://`` <https://www.iana.org/assignments/uri-schemes/prov/redis>`_ creates a normal TCP socket connection - ```rediss://`` <https://www.iana.org/assignments/uri-schemes/prov/rediss>`_ creates a SSL wrapped TCP socket connection - ``unix://`` creates a Unix Domain Socket connection There are several ways to specify a database number. The parse function will return the first specified option: 1. A ``db`` querystring option, e.g. redis://localhost?db=0 2. If using the redis:// scheme, the path argument of the url, e.g. redis://localhost/0 3. The ``db`` argument to this function. If none of these options are specified, db=0 is used. The ``decode_components`` argument allows this function to work with percent-encoded URLs. If this argument is set to ``True`` all ``%xx`` escapes will be replaced by their single-character equivalents after the URL has been parsed. This only applies to the ``hostname``, ``path``, ``username`` and ``password`` components. Any additional querystring arguments and keyword arguments will be passed along to the ConnectionPool class's initializer. The querystring arguments ``socket_connect_timeout`` and ``socket_timeout`` if supplied are parsed as float values. The arguments ``socket_keepalive`` and ``retry_on_timeout`` are parsed to boolean values that accept True/False, Yes/No values to indicate state. Invalid types cause a ``UserWarning`` to be raised. In the case of conflicting arguments, querystring arguments always win. r z)Invalid value for `%s` in connection URL.N�unix)r� r� r �connection_class)Zredis�redissr� )r� r� r� r� r� �/r� r( r' z, )zredis://z rediss://zunix://z8Redis URL must specify one of the following schemes (%s)�charsetz/"charset" is deprecated. Use "encoding" insteadr0 r� z5"errors" is deprecated. Use "encoding_errors" insteadr1 ) r r r �queryrO �URL_QUERY_ARGUMENT_PARSERSrQ � TypeError� ValueError�warnings�warn� UserWarningr� r r� r �hostname�scheme�updater r> r� �replace�AttributeErrorr r� �DeprecationWarning�pop)�cls�urlr� Zdecode_componentsr� Z url_options�namerB �parserr� r� r r2 Z valid_schemesr4 r4 r5 �from_url� sx . � � � � � �zConnectionPool.from_urlc K sN |pd}t |ttf�r |dk r&td��|| _|| _|| _t�� | _ | � � dS )a� Create a connection pool. If max_connections is set, then this object raises redis.ConnectionError when the pool's limit is reached. By default, TCP connections are created unless connection_class is specified. Use redis.UnixDomainSocketConnection for unix sockets. Any additional keyword arguments are passed to the constructor of connection_class. l r z,"max_connections" must be a positive integerN) r7 r> r r. r' �connection_kwargsr$ � threading�Lock� _fork_lock�reset)r3 r' r$ r> r4 r4 r5 r6 0 s zConnectionPool.__init__c C s$ dt | �jt| jf i | j���f S )Nr� )r@ rA r< r' r> r_ r4 r4 r5 r� O s �zConnectionPool.__repr__c C s, t �� | _d| _g | _t� | _t�� | _ d S rU ) r? r@ �_lock�_created_connections�_available_connections�set�_in_use_connectionsr� r� r� r_ r4 r4 r5 rB U s zConnectionPool.resetc C sx | j t�� krtt� d }d}t� |k r:| j�d�}|r q:q |sBt�z$| j t�� krZ| �� W | j�� n | j�� 0 d S )N� F) r� r� r� r rA �acquirer rB �release)r3 Z timeout_atZacquiredr4 r4 r5 � _checkpidf s # zConnectionPool._checkpidc O s� | � � | j�F z| j�� }W n ty8 | �� }Y n0 | j�|� W d � n1 sZ0 Y zT|�� z|� � r�t d��W n2 t y� |� � |�� |� � r�t d��Y n0 W n t y� | � |� � Y n0 |S )z Get a connection from the poolN�Connection has data�Connection not ready)rK rC rE r8 � IndexError�make_connectionrG �addr� ry r r� r� rJ �r3 � command_name�keys�optionsr� r4 r4 r5 �get_connection� s* * z ConnectionPool.get_connectionc C s, | j }t|�dd�|�dd�|�dd�d�S )z,Return an encoder based on encoding settingsr0 r� r1 r� r2 Fr/ )r> r- rQ )r3 r� r4 r4 r5 � get_encoder� s �zConnectionPool.get_encoderc C s4 | j | jkrtd��| j d7 _ | jf i | j��S )zCreate a new connectionzToo many connectionsrL )rD r$ r r' r> r_ r4 r4 r5 rO � s z ConnectionPool.make_connectionc C s� | � � | j�r z| j�|� W n ty2 Y n0 | �|�rL| j�|� n&| jd8 _|� � W d � dS W d � n1 s�0 Y dS )z(Releases the connection back to the poolrL N) rK rC rG �remove�KeyError�owns_connectionrE r� rD r� r� r4 r4 r5 rJ � s zConnectionPool.releasec C s |j | j kS r. )r� r� r4 r4 r5 rY � s z ConnectionPool.owns_connectionTc C s^ | � � | j�< |r$t| j| j�}n| j}|D ] }|�� q.W d � n1 sP0 Y dS )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)rK rC r rE rG r� )r3 Zinuse_connections� connectionsr� r4 r4 r5 r� � s �zConnectionPool.disconnect)NF)T)rA rG rH rI � classmethodr= r� r6 r� rB rK rU rV rO rJ rY r� r4 r4 r4 r5 r% � s z 6! r% c sR e Zd ZdZddeef� fdd� Zdd� Zdd � Zd d � Z d d � Z dd� Z � Z S )�BlockingConnectionPoola6 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.connection.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.exceptions.ConnectionError`` (as the default ``:py:class: ~redis.connection.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) �2 � c s, || _ || _tt| �jf ||d�|�� d S )N)r' r$ )� queue_classrh r r\ r6 )r3 r$ rh r' r_ r> r r4 r5 r6 s ��z BlockingConnectionPool.__init__c C sL | � | j�| _z| j�d � W q ty4 Y q8Y q0 qg | _t�� | _d S r. ) r_ r$ �pool� put_nowaitr � _connectionsr� r� r� r_ r4 r4 r5 rB % s z BlockingConnectionPool.resetc C s" | j f i | j��}| j�|� |S )zMake a fresh connection.)r' r> rb r� r� r4 r4 r5 rO = s z&BlockingConnectionPool.make_connectionc O s� | � � d}z| jjd| jd�}W n ty< td��Y n0 |du rN| �� }zT|�� z|�� rjtd��W n2 ty� |� � |�� |�� r�td��Y n0 W n t y� | � |� � Y n0 |S )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)�blockrh zNo connection available.rL rM ) rK r` rQ rh r r rO r� ry r� r� rJ rQ r4 r4 r5 rU C s, z%BlockingConnectionPool.get_connectionc C sR | � � | �|�s*|�� | j�d� dS z| j�|� W n tyL Y n0 dS )z)Releases the connection back to the pool.N)rK rY r� r` ra r r� r4 r4 r5 rJ w s z BlockingConnectionPool.releasec C s | � � | jD ] }|�� qdS )z(Disconnects all connections in the pool.N)rK rb r� r� r4 r4 r5 r� � s z!BlockingConnectionPool.disconnect) rA rG rH rI r� r r6 rB rO rU rJ r� r r4 r4 r r5 r\ � s � 4r\ )_� __future__r Zdistutils.versionr � itertoolsr r rl rY r� r^ r? r/ Z redis._compatr r r r r r r r r r r r r r r r r r r Zredis.exceptionsr r r r r r r r r! r" r# r$ r% r& Z redis.utilsr' r r � ImportError� EWOULDBLOCKrj r r( �SSLWantWriteError�SSLErrorr� r� rS ri r� � __version__Zhiredis_versionr� Z HIREDIS_SUPPORTS_BYTE_BUFFERr� �msgr0 r� r� r� r r� rf �objectrd r- rJ rT r� r� r� r� r r r" r# r; r> r, r% r\ r4 r4 r4 r5 �<module> s� T@ � � � �� (#xOz E63 � H
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка