Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/transport/__pycache__/redis.cpython-39.pyc
Ðазад
a o�hz� � @ s� d Z ddlmZ ddlZddlZddlZddlmZ ddlmZ ddl m Z ddl m Z ddl m Z dd lmZ dd lmZmZ dd lmZ dd lmZ dd lmZ ddlmZmZm Z ddl m Z ddl m Z m!Z! ddl"m#Z# ddl$m%Z% ddl&m'Z' ddl(m)Z) z ddl*Z*W n e+�y( dZ*Y n0 zddl*m,Z, W n e+�yR dZ,Y n0 ed�Z-e-j.e-j/ Z0Z/dZ1dZ2dZ3g d�Z4edd �Z5d d � Z6d d � Z7G d!d"� d"e8�Z9e d#d$� �Z:d%d&� Z;G d'd(� d(�Z<G d)d*� d*e<e*j=�Z>G d+d,� d,e<e*j?j@�ZAG d-d.� d.e*j?jB�ZCG d/d0� d0e)jD�ZDG d1d2� d2�ZEG d3d4� d4e)jF�ZFG d5d6� d6e)jG�ZGe,�rhG d7d8� d8e,jHe*jI�ZJG d9d:� d:eF�ZKG d;d<� d<eG�ZLdS )=a� Redis transport module for Kombu. Features ======== * Type: Virtual * Supports Direct: Yes * Supports Topic: Yes * Supports Fanout: Yes * Supports Priority: Yes * Supports TTL: No Connection String ================= Connection string has the following format: .. code-block:: redis://[USER:PASSWORD@]REDIS_ADDRESS[:PORT][/VIRTUALHOST] rediss://[USER:PASSWORD@]REDIS_ADDRESS[:PORT][/VIRTUALHOST] To use sentinel for dynamic Redis discovery, the connection string has following format: .. code-block:: sentinel://[USER:PASSWORD@]SENTINEL_ADDRESS[:PORT] Transport Options ================= * ``sep`` * ``ack_emulation``: (bool) If set to True transport will simulate Acknowledge of AMQP protocol. * ``unacked_key`` * ``unacked_index_key`` * ``unacked_mutex_key`` * ``unacked_mutex_expire`` * ``visibility_timeout`` * ``unacked_restore_limit`` * ``fanout_prefix`` * ``fanout_patterns`` * ``global_keyprefix``: (str) The global key prefix to be prepended to all keys used by Kombu * ``socket_timeout`` * ``socket_connect_timeout`` * ``socket_keepalive`` * ``socket_keepalive_options`` * ``queue_order_strategy`` * ``max_connections`` * ``health_check_interval`` * ``retry_on_timeout`` * ``priority_steps`` � )� annotationsN)�bisect)� namedtuple)�contextmanager)�Empty)�time)�promise)�InconsistencyError�VersionMismatch)� get_logger)�register_after_fork)� bytes_to_str)�ERR�READ�poll)�accepts_argument)�dumps�loads)�cached_property)� cycle_by_name)� _parse_url� )�virtual)�sentinelzkombu.transport.redisi� � )r � � � �error_classes_t)�connection_errors�channel_errorsc C sb ddl m} t| d�r | j}n| j}ttjjt t j t t | j| j| j| jf tjj|| j| jf �S )z$Return tuple of redis error classes.r �� exceptions� InvalidData)�redisr" �hasattrr# � DataErrorr r � Transportr r �socket�error�IOError�OSError�ConnectionErrorZBusyLoadingError�AuthenticationError� TimeoutErrorr ZInvalidResponse� ResponseError)r" r& � r0 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/transport/redis.py�get_redis_error_classesy s* � ��r2 c C s ddl m} | jS )z1Return the redis ConnectionError exception class.r r! )r$ r" r, r! r0 r0 r1 �get_redis_ConnectionError� s r3 c @ s e Zd ZdZdS )� MutexHeldz)Raised when another party holds the lock.N��__name__� __module__� __qualname__�__doc__r0 r0 r0 r1 r4 � s r4 c c s� | j ||d�}d}zJ|jdd�}|r,dV nt� �W |r�z |�� W q� tjjyZ Y q�0 n*|r�z |�� W n tjjy� Y n0 0 dS )zTAcquire redis lock in non blocking way. Raise MutexHeld if not successful. ��timeoutF)�blockingN)�lock�acquirer4 �releaser$ r" ZLockNotOwnedError)�client�nameZexpirer= Z lock_acquiredr0 r0 r1 �Mutex� s" � rB c C s | � � d S �N)� _after_fork��channelr0 r0 r1 �_after_fork_cleanup_channel� s rG c sl e Zd ZdZg d�Zddd�ddd�ddd�ddd�d �Zd d � Z� fd d �Z� fdd�Zddd�Z � Z S )�GlobalKeyPrefixMixina Mixin to provide common logic for global key prefixing. Overriding all the methods used by Kombu with the same key prefixing logic would be cumbersome and inefficient. Hence, we override the command execution logic that is called by all commands. )ZHDELZHGETZHLENZHSETZLLENZLPUSHZPUBLISHZRPUSHZRPOPZSADDZSREMZSETZSMEMBERSZZADDZZREMZZREVRANGEBYSCOREr N)� args_start�args_end���� r )ZDEL�BRPOPZEVALSHAZWATCHc s� t |�}|�d�}|� jv r4� jt|d � |d< nx|� jv r�� j| d }� j| d }|dkrn|d |� ng }g }|d ur�||d � }|� fdd�|||� D � | }|g|�S )Nr rI rJ c s g | ]}� j t|� �qS r0 ��global_keyprefix�str��.0�arg��selfr0 r1 � <listcomp>� s �z5GlobalKeyPrefixMixin._prefix_args.<locals>.<listcomp>)�list�pop�PREFIXED_SIMPLE_COMMANDSrO rP �PREFIXED_COMPLEX_COMMANDS)rU �args�commandrI rJ Zpre_argsZ post_argsr0 rT r1 � _prefix_args� s" ��z!GlobalKeyPrefixMixin._prefix_argsc sH t � j||fi |��}|dkrD|rD|\}}|t| j�d� }||fS |S )z�Parse a response from the Redis server. Method wraps ``redis.parse_response()`` to remove prefixes of keys returned by redis command. rM N)�super�parse_response�lenrO )rU � connection� command_name�options�ret�key�value�� __class__r0 r1 r_ � s z#GlobalKeyPrefixMixin.parse_responsec s t � j| �|�i |��S rC �r^ �execute_commandr] �rU r[ �kwargsrg r0 r1 rj � s z$GlobalKeyPrefixMixin.execute_commandTc C s t | j| j||| jd�S )N�rO )�PrefixedRedisPipeline�connection_poolZresponse_callbacksrO )rU � transactionZ shard_hintr0 r0 r1 �pipeline s �z GlobalKeyPrefixMixin.pipeline)TN) r6 r7 r8 r9 rY rZ r] r_ rj rq � __classcell__r0 r0 rg r1 rH � s � rH c @ s e Zd ZdZdd� Zdd� ZdS )�PrefixedStrictRedisz@Returns a ``StrictRedis`` client that prefixes the keys it uses.c O s, |� dd�| _tjj| g|�R i |�� d S �NrO � )rX rO r$ �Redis�__init__rk r0 r0 r1 rw s z PrefixedStrictRedis.__init__c K s t | jfd| ji|��S )NrO )�PrefixedRedisPubSubro rO )rU rl r0 r0 r1 �pubsub s ���zPrefixedStrictRedis.pubsubN)r6 r7 r8 r9 rw ry r0 r0 r0 r1 rs s rs c @ s e Zd ZdZdd� ZdS )rn a Custom Redis pipeline that takes global_keyprefix into consideration. As the ``PrefixedStrictRedis`` client uses the `global_keyprefix` to prefix the keys it uses, the pipeline called by the client must be able to prefix the keys as well. c O s. |� dd�| _tjjj| g|�R i |�� d S rt )rX rO r$ r@ �Pipelinerw rk r0 r0 r1 rw " s z PrefixedRedisPipeline.__init__N)r6 r7 r8 r9 rw r0 r0 r0 r1 rn s rn c sD e Zd ZdZdZ� fdd�Zdd� Z� fdd�Z� fd d �Z� Z S ) rx zCRedis pubsub client that takes global_keyprefix into consideration.)Z SUBSCRIBEZ UNSUBSCRIBEZ PSUBSCRIBEZ PUNSUBSCRIBEc s$ |� dd�| _t� j|i |�� d S rt )rX rO r^ rw rk rg r0 r1 rw 1 s z PrefixedRedisPubSub.__init__c s8 t |�}|�d�}|� jv r.� fdd�|D �}|g|�S )Nr c s g | ]}� j t|� �qS r0 rN rQ rT r0 r1 rV : s �z4PrefixedRedisPubSub._prefix_args.<locals>.<listcomp>)rW rX �PUBSUB_COMMANDS)rU r[ r\ r0 rT r1 r] 5 s �z PrefixedRedisPubSub._prefix_argsc sF t � j|i |��}|du r |S |�^}}}|g� fdd�|D ��|�S )z�Parse a response from the Redis server. Method wraps ``PubSub.parse_response()`` to remove prefixes of keys returned by redis command. Nc s g | ]}|t � j�d � �qS rC )r` rO )rR rF rT r0 r1 rV S � z6PrefixedRedisPubSub.parse_response.<locals>.<listcomp>)r^ r_ )rU r[ rl rd Z message_typeZchannels�messagerg rT r1 r_ A s ���z"PrefixedRedisPubSub.parse_responsec s t � j| �|�i |��S rC ri rk rg r0 r1 rj W s z#PrefixedRedisPubSub.execute_command) r6 r7 r8 r9 r{ rw r] r_ rj rr r0 r0 rg r1 rx ' s rx c s� e Zd ZdZdZ� fdd�Z� fdd�Zd#dd �Z� fd d �Zd$� fd d� Z e d%dd��Z d&dd�Z d'dd�Z d(dd�Zedd� �Zedd � �Zed d � �Zed d � �Zed!d"� �Z� ZS ))�QoSzRedis Ack Emulation.Tc s t � j|i |�� d| _d S )Nr )r^ rw �_vrestore_countrk rg r0 r1 rw ` s z QoS.__init__c s� |j }|d |d }}tjd dkr4|t� ig}n t� |g}| �� �N}|j| jg|�R � �| j|t |j ||g��� � t � � ||� W d � n1 s�0 Y d S )N�exchange� routing_keyr r )� delivery_infor$ �VERSIONr �pipe_or_acquireZzadd�unacked_index_keyZhset� unacked_keyr �_raw�executer^ �append)rU r} � delivery_tagZdelivery�EX�RKZ zadd_args�piperg r0 r1 r� d s �z QoS.appendNc C sT | j �|��*}| jD ]}| j||d� qW d � n1 s<0 Y | j�� d S )N�r@ )rF �conn_or_acquireZ _delivered�restore_by_tag�clear)rU r@ �tagr0 r0 r1 �restore_unackedu s .zQoS.restore_unackedc s | � |��� t� �|� d S rC )�_remove_from_indicesr� r^ �ack)rU r� rg r0 r1 r� { s zQoS.ackFc s2 |r| j |dd� n| �|��� t� �|� d S �NT)�leftmost)r� r� r� r^ r� )rU r� Zrequeuerg r0 r1 �reject s z QoS.rejectc c sF |r |V n6| j �|��}|�� V W d � n1 s80 Y d S rC )rF r� rq )rU r� r@ r0 r0 r1 r� � s zQoS.pipe_or_acquirec C sF | � |��(}|�| j|��| j|�W d � S 1 s80 Y d S rC )r� Zzremr� �hdelr� )rU r� r� r0 r0 r1 r� � s �zQoS._remove_from_indicesr � c C s� | j d7 _ | j d | r d S | j�� ��}t� | j }znt|| j| j��J |j| j |d|o^||dd�}|png D ]\}}| � ||� qpW d � n1 s�0 Y W n t y� Y n0 W d � n1 s�0 Y d S )Nr r T)�start�numZ withscores) r rF r� r �visibility_timeoutrB �unacked_mutex_key�unacked_mutex_expireZzrevrangebyscorer� r� r4 ) rU r� r� �intervalr@ �ceil�visibler� Zscorer0 r0 r1 �restore_visible� s" � �0 zQoS.restore_visiblec sN � ��fdd�}�j �|�� }|�|�j� W d � n1 s@0 Y d S )Nc sP | � �j��}| �� ���| � |rLtt|��\}}}�j�|||| � � d S rC )�hgetr� �multir� r r rF �_do_restore_message)r� �p�Mr� r� �r� rU r� r0 r1 �restore_transaction� s z/QoS.restore_by_tag.<locals>.restore_transaction)rF r� rp r� )rU r� r@ r� r� r0 r� r1 r� � s zQoS.restore_by_tagc C s | j jS rC )rF r� rT r0 r0 r1 r� � s zQoS.unacked_keyc C s | j jS rC )rF r� rT r0 r0 r1 r� � s zQoS.unacked_index_keyc C s | j jS rC )rF r� rT r0 r0 r1 r� � s zQoS.unacked_mutex_keyc C s | j jS rC )rF r� rT r0 r0 r1 r� � s zQoS.unacked_mutex_expirec C s | j jS rC )rF r� rT r0 r0 r1 r� � s zQoS.visibility_timeout)N)F)NN)N)r r� r� )NF)r6 r7 r8 r9 Zrestore_at_shutdownrw r� r� r� r� r r� r� r� r� r r� r� r� r� r� rr r0 r0 rg r1 r~ [ s, r~ c @ s� e Zd ZdZeeB ZdZdZdd� Z dd� Z dd � Z d d � Z d d � Z dd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd(d$d%�Zed&d'� �ZdS ))�MultiChannelPollerz%Async I/O poller for Redis transport.FNc C s( t � | _i | _i | _t� | _t � | _d S rC )�set� _channels� _fd_to_chan� _chan_to_sockr �poller� after_readrT r0 r0 r1 rw � s zMultiChannelPoller.__init__c C sZ | j �� D ],}z| j�|� W q ttfy4 Y q 0 q | j�� | j�� | j �� d S rC ) r� �valuesr� � unregister�KeyError� ValueErrorr� r� r� )rU �fdr0 r0 r1 �close� s zMultiChannelPoller.closec C s | j �|� d S rC )r� �add�rU rF r0 r0 r1 r� � s zMultiChannelPoller.addc C s | j �|� d S rC )r� �discardr� r0 r0 r1 r� � s zMultiChannelPoller.discardc C s. z| j �|j� W n ttfy( Y n0 d S rC )r� r� �_sock�AttributeError� TypeError�rU ra r0 r0 r1 �_on_connection_disconnect� s z,MultiChannelPoller._on_connection_disconnectc C sr |||f| j v r | �|||� |jjd u r4|j�� |jj}||f| j|�� < || j |||f< | j�|| j � d S rC ) r� � _unregisterra r� �connectr� �filenor� �register� eventflags)rU rF r@ �type�sockr0 r0 r1 � _register� s z MultiChannelPoller._registerc C s | j �| j|||f � d S rC )r� r� r� )rU rF r@ r� r0 r0 r1 r� � s z MultiChannelPoller._unregisterc C s: t |dd �d u r |j�d�|_|jjd uo8|||f| jv S )Nra �_)�getattrro �get_connectionra r� r� )rU rF r@ �cmdr0 r0 r1 �_client_registered s �z%MultiChannelPoller._client_registeredc C s> ||j df}| �||j d�s,d|_| j|� |js:|�� dS )z Enable BRPOP mode for channel.rM FN)r@ r� �_in_pollr� � _brpop_start)rU rF �identr0 r0 r1 �_register_BRPOP s z"MultiChannelPoller._register_BRPOPc C s8 | � ||jd�s&d|_| �||jd� |js4|�� dS )z Enable LISTEN mode for channel.�LISTENFN)r� � subclient� _in_listenr� � _subscriber� r0 r0 r1 �_register_LISTEN s z#MultiChannelPoller._register_LISTENc C s: | j D ].}|jr$|j�� r$| �|� |jr| �|� qd S rC )r� � active_queues�qos� can_consumer� �active_fanout_queuesr� r� r0 r0 r1 � on_poll_start s z MultiChannelPoller.on_poll_startc C s( || _ | jD ]}|jj|jd� S d S �N)r� )r� r� r� r� �unacked_restore_limit)rU r� rF r0 r0 r1 � on_poll_init s �z MultiChannelPoller.on_poll_initc C s* | j D ] }|jr|jj|jd� S qd S r� )r� r� r� r� r� r� r0 r0 r1 �maybe_restore_messages& s �z)MultiChannelPoller.maybe_restore_messagesc C s< | j D ]0}|j�d�}|d urtt|dd ��r|�� qd S )Nr� � check_health)r� �__dict__�get�callabler� r� )rU rF r@ r0 r0 r1 � maybe_check_subclient_health. s �z/MultiChannelPoller.maybe_check_subclient_healthc C s( | j | \}}|j�� r$|j| � d S rC )r� r� r� �handlers)rU r� �chanr� r0 r0 r1 � on_readable6 s z MultiChannelPoller.on_readablec C s: |t @ r| �|�| fS |t@ r6| j| \}}|�|� d S rC )r r� r r� � _poll_error)rU r� �eventr� r� r0 r0 r1 � handle_event; s z MultiChannelPoller.handle_eventc C sB d| _ z�| jD ].}|jr,|j�� r,| �|� |jr| �|� q| j� |�}|r�|D ]Z\}}| � ||�}|rR W d| _ | j r�z| j � � }W n t y� Y q�Y qt0 |� qtd S qR| �� t� �W d| _ | j r�z| j � � }W n t y� Y q�Y q�0 |� q�nDd| _ | j �r<z| j � � }W n t �y0 Y �q<Y n0 |� �q 0 d S )NTF)�_in_protected_readr� r� r� r� r� r� r� r� r r� r� rX r� r� r ) rU �callbackr; rF �eventsr� r� rd Zfunr0 r0 r1 r� B sL � � zMultiChannelPoller.getc C s | j S rC )r� rT r0 r0 r1 �fds` s zMultiChannelPoller.fds)N) r6 r7 r8 r9 r r r� r� r� rw r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� �propertyr� r0 r0 r0 r1 r� � s. r� c sz e Zd ZdZeZdZdZdZdZdZ dZ dZ dZ dZ i ZdZdZd Zd Zd ZdZd ZeZdZdZdZdZdZ d Z e Z dZ dZ!dZ"dZ#dZ$dZ%e&j'j(d Z(e)r�e)j*ndZ+e)r�e)j,ndZ-� fdd�Z.dd� Z/dd� Z0dd� Z1drdd�Z2ds� fdd � Z3d d � Z4� fd d �Z5d!d"� Z6� fd#d$�Z7d%d&� Z8d'd(� Z9d)d*� Z:d+d,� Z;d-d.� Z<d/d0� Z=d1d2� Z>dtd4d5�Z?d6d7� Z@d8d9� ZAd:d;� ZBd<d=� ZCd>d?� ZDd@dA� ZEdBdC� ZFdDdE� ZGdudFdG�ZHdHdI� ZIdJdK� ZJdLdM� ZKdNdO� ZLdPdQ� ZM� fdRdS�ZNdTdU� ZOdVdW� ZPdvdXdY�ZQdwdZd[�ZRdxd\d]�ZSdyd^d_�ZTd`da� ZUeVdzdbdc��ZWeXddde� �ZYeXdfdg� �ZZe[dhdi� �Z\e[djdk� �Z]dldm� Z^dndo� Z_eXdpdq� �Z`� ZaS ){�ChannelzRedis Channel.NFTz_kombu.binding.%sz/{db}.zZunackedZ unacked_indexZ unacked_mutexi, i r� ru Z round_robin)�sep� ack_emulationr� r� r� r� r� r� � fanout_prefix�fanout_patternsrO �socket_timeout�socket_connect_timeout�socket_keepalive�socket_keepalive_options�queue_order_strategy�max_connections�health_check_interval�retry_on_timeout�priority_stepsc s� t � j|i |�� | js tj| _d| _t| j�� | _| � � | _ | � � | _ t � | _t � | _i | _| j| jd�| _| jr�t| jt�r�| j| _nd| _z| j�� W n ty� | �� � Y n0 | j j � | � d| _| j j | _ t d ur�t | t!� d S )NF)rM r� ru T)"r^ rw r� r r~ � _registeredr r� � _queue_cycle� _get_client�Client�_get_response_errorr/ r� r� �auto_delete_queues�_fanout_to_queue� _brpop_read�_receiver� r� � isinstancerP �keyprefix_fanoutr@ Zping� Exception�_disconnect_poolsra �cycler� r r rG rk rg r0 r1 rw � s2 zChannel.__init__c C s | � � d S rC )r rT r0 r0 r1 rD � s zChannel._after_forkc C s< | j }| j}d | _| _ |d ur(|�� |d ur8|�� d S rC )�_pool� _async_pool� disconnect)rU �pool� async_poolr0 r0 r1 r � s zChannel._disconnect_poolsc C s@ | j |u rd | _ | j|u r d | _| jr<| jjr<| jj�|� d S rC )r� r� ra r r� r� r0 r0 r1 r� s z!Channel._on_connection_disconnectc C s� zzz d|d d< d|d d d< W n t y4 Y n0 | �||�D ]4}| j|dd�}|r^|jn|j| �||�t|�� qBW n ty� td|dd � Y n0 d S ) NT�headersZ redelivered� propertiesr� F��reversez Could not restore message: %r��exc_info) r� Z_lookup�_get_message_priority�lpushZrpush� _q_for_prir r �crit)rU �payloadr� r� r� r� �queue�prir0 r0 r1 r� s � zChannel._do_restore_messagec sb �j st� �|�S |j�� ��fdd�}��� � }|�|�j� W d � n1 sT0 Y d S )Nc sP | � �j��}| �� | ��j�� |rLtt|��\}}}��|||| � � d S rC )r� r� r� r� r r r� )r� �Pr� r� r� r� r0 r1 r� % s z-Channel._restore.<locals>.restore_transaction)r� r^ �_restorer� r� rp r� )rU r} r� r� r@ rg r� r1 r s zChannel._restorec C s | j |dd�S r� )r )rU r} r0 r0 r1 �_restore_at_beginning0 s z Channel._restore_at_beginningc sT || j v r.| j | \}}| j�|� || j|< t� j|g|�R i |��}| �� |S rC )�_fanout_queuesr� r� r r^ � basic_consume�_update_queue_cycle)rU r r[ rl r� r� rd rg r0 r1 r! 3 s zChannel.basic_consumec C s8 | j }|r4|jjr*|jj�t| j|f��S | �|�S d S rC )ra r r� r� r� r � _basic_cancel)rU � consumer_tagra r0 r0 r1 � basic_cancelG s �zChannel.basic_cancelc s� z| j | }W n ty" Y d S 0 z| j�|� W n tyF Y n 0 | �|� z | j| \}}| j�|� W n ty� Y n0 t� � |�}| � � |S rC ) Z _tag_to_queuer� r� �remove�_unsubscribe_fromr r rX r^ r% r" )rU r$ r r� r� rd rg r0 r1 r# T s" zChannel._basic_cancelc C s. |r | j r d�| j|d|g�S d�| j|g�S )Nru �/)r� �joinr )rU r� r� r0 r0 r1 �_get_publish_topich s zChannel._get_publish_topicc C s | j | \}}| �||�S rC )r r* )rU r r� r� r0 r0 r1 �_get_subscribe_topicm s z Channel._get_subscribe_topicc sN � fdd�� j D �}|s d S � j}|jjd u r8|j�� |j� _|�|� d S )Nc s g | ]}� � |��qS r0 )r+ �rR r rT r0 r1 rV r s �z&Channel._subscribe.<locals>.<listcomp>)r� r� ra r� r� r� Z psubscribe)rU �keys�cr0 rT r1 r� q s � zChannel._subscribec C s. | � |�}| j}|jr*|jjr*|�|g� d S rC )r+ r� ra r� � unsubscribe)rU r �topicr. r0 r0 r1 r' | s zChannel._unsubscribe_fromc C s� t |d �dkr&|d dkr&d|_d S t |d �dkr\|d |d |d |d f\}}}}n |d d |d |d f\}}}}||||d�S ) Nr r/ rL FZpmessager r )r� �patternrF �data)r Z subscribed)rU r@ �rr� r1 rF r2 r0 r0 r1 �_handle_message� s & �zChannel._handle_messagec C sd | j }g }z|�| �|�� W n ty0 Y n0 |jd ur\|jjdd�r\|�| �|�� q2t|�S )Nr r: )r� r� � _receive_oner ra Zcan_read�any)rU r. rd r0 r0 r1 r � s zChannel._receivec C s d }z |� � }W n | jy, d | _� Y n0 t|ttf��r| �||�}t|d ��d��rt|d �}|d �r|d dkr�|� d�\}}}zt t|d ��}W n8 t t fy� t d|t|�d d � d d � t� �Y n0 |�dd �d }| j�|| j| � d S d S ) Nr� r} rF r2 r r( �.z&Cannot process event on channel %r: %si r r T)r_ r r� r rW �tupler4 r �endswith� partitionr r� r� �warning�reprr �splitra �_deliverr )rU r. �responser rF r� r} r� r0 r0 r1 r5 � s2 � �zChannel._receive_oner c sr �j �t�j��� � sd S � �fdd��jD �|p4dg }�jj�_dg|�}�jr`�j� |�}�jjj |� d S )Nc s" g | ]}� D ]}�� ||��q qS r0 )r )rR r r �ZqueuesrU r0 r1 rV � s �z(Channel._brpop_start.<locals>.<listcomp>r rM ) r� �consumer` r� r� r@ ra r� rO r] Z send_command)rU r; r- � command_argsr0 r@ r1 r� � s � zChannel._brpop_startc K s� z�z | j j| j jdfi |��}W n" | jyB | j j�� � Y n0 |r�|\}}t|��| jd�d }| j� |� | j� t t|��|� W d | _ dS t � �W d | _ nd | _ 0 d S )NrM r r T)r@ r_ ra r r r �rsplitr� r� �rotater> r r� r )rU rc Z dest__item�dest�itemr0 r0 r1 r � s( �� �zChannel._brpop_readc K s* |dkr| j �� n| j�| jj|� d S )Nr� )r� r_ r@ ra )rU r� rc r0 r0 r1 r� � s zChannel._poll_errorc C sr | � � �V}| jD ]8}|�| �||��}|rtt|�� W d � S qt� �W d � n1 sd0 Y d S rC )r� r� Zrpopr r r r )rU r r@ r rF r0 r0 r1 �_get� s z Channel._getc C s� | � � �~}|�� �V}| jD ]}|�| �||��}q|�� }tdd� |D ��W d � W d � S 1 sn0 Y W d � n1 s�0 Y d S )Nc s s | ]}t |tj�r|V qd S rC )r �numbers�Integral)rR �sizer0 r0 r1 � <genexpr>� s �z Channel._size.<locals>.<genexpr>)r� rq r� �llenr r� �sum)rU r r@ r� r �sizesr0 r0 r1 �_size� s z Channel._sizec C s$ | � |�}|r |� | j� |� �S |S rC )�priorityr� )rU r r r0 r0 r1 r � s zChannel._q_for_pric C s | j }|t||�d S )Nr )r� r )rU �nZstepsr0 r0 r1 rP � s zChannel.priorityc K sR | j |dd�}| �� �(}|�| �||�t|�� W d � n1 sD0 Y dS )zDeliver message.Fr N)r r� r r r )rU r r} rl r r@ r0 r0 r1 �_put� s z Channel._putc K sD | � � �(}|�| �||�t|�� W d � n1 s60 Y dS )zDeliver fanout message.N)r� �publishr* r )rU r� r} r� rl r@ r0 r0 r1 � _put_fanout s �zChannel._put_fanoutc K s |r| j �|� d S rC )r r� )rU r Z auto_deleterl r0 r0 r1 � _new_queue s zChannel._new_queuec C s� | � |�jdkr&||�dd�f| j|< | �� �>}|�| j|f | j�|pJd|pPd|pVdg�� W d � n1 sr0 Y d S )N�fanout�#�*ru ) Ztypeofr� �replacer r� Zsadd�keyprefix_queuer� r) )rU r� r� r1 r r@ r0 r0 r1 � _queue_bind s � ��zChannel._queue_bindc O s� | j �|� | j|�d�d���}|�| j|f | j�|p:d|p@d|pFdg�� |�� �6}| j D ]} |� | � || ��}q^|� � W d � n1 s�0 Y W d � n1 s�0 Y d S )Nr@ r� ru ) r r� r� r� ZsremrZ r� r) rq r� �deleter r� ) rU r r� r� r1 r[ rl r@ r� r r0 r0 r1 �_delete s �� zChannel._deletec K s� | � � �p}|�� �H}| jD ]}|�| �||��}qt|�� �W d � W d � S 1 s`0 Y W d � n1 s~0 Y d S rC )r� rq r� �existsr r6 r� )rU r rl r@ r� r r0 r0 r1 � _has_queue& s zChannel._has_queuec sh � j | }� �� �B}|�|�}|s4g W d � S � fdd�|D �W d � S 1 sZ0 Y d S )Nc s g | ]}t t|��� j���qS r0 )r8 r r= r� )rR �valrT r0 r1 rV 5 r| z%Channel.get_table.<locals>.<listcomp>)rZ r� Zsmembers)rU r� re r@ r� r0 rT r1 � get_table- s zChannel.get_tablec C s� | � � ��}|�� �`}| jD ] }| �||�}|�|��|�}q|�� }t|d d d� �W d � W d � S 1 sx0 Y W d � n1 s�0 Y d S )NrL )r� rq r� r rL r\ r� rM )rU r r@ r� r ZpriqrN r0 r0 r1 �_purge7 s zChannel._purgec s� d| _ | jr,z | �� W n ty* Y n0 | js�| jj�| � | j� d�}|d urx| j D ] }|| j v rZ| j ||d� qZ| � � | �� t� �� d S )NTr@ r� )�_closingr� r r �closedra r r� r� r� r r Z queue_deleter �_close_clientsr^ r� )rU r@ r rg r0 r1 r� @ s z Channel.closec C sN dD ]D}z$| j | }|jd }|_|�� W q tt| jfyF Y q0 qd S )N)r@ r� )r� ra r r� r� r/ )rU �attrr@ ra r0 r0 r1 re U s zChannel._close_clientsc C sf t |tj�sb|r|dkr t}n|�d�r4|dd � }z t|�}W n ty` td�|���Y n0 |S )Nr( r z/Database is int between 0 and limit - 1, not {})r rH rI � DEFAULT_DB� startswith�intr� �format)rU Zvhostr0 r0 r1 �_prepare_virtual_host_ s �� z Channel._prepare_virtual_hostc K s |S rC r0 )rU r� r� �paramsr0 r0 r1 �_filter_tcp_connparamsn s z Channel._filter_tcp_connparamsc s� | j j}|jpd|jp | j j|j|j|j| j| j | j | j | j | j | jd� }| j}t|d�r�|g}t|d�rx|t|j�7 }|D ]}t|jd�r| q�q||�d� |jr�z|�|j� | j|d< W n ty� Y n0 |d }d|v �r|t|�\}} } } } } } |d k�rT| jf i |��}|jt j d | d �fi | �� |�d d � |�d d � |�dd � | |d< | |d< |�dd � |�dd � | � |�dd ��|d< | � |� d��p�| j}|�r�G � fdd�d|�}|}||d< |S )Nz 127.0.0.1) �host�port� virtual_host�username�passwordr� r� r� r� r� r� r� rw � __bases__r� �connection_classrn z://r( r( )rt �pathr� r� r� rq rr ro rp �dbc s e Zd Z� �fdd�Z� ZS )z'Channel._connparams.<locals>.Connectionc s t � j|� �jr ��| � d S rC )r^ r r� r� )rU r[ )rh rF r0 r1 r � s z2Channel._connparams.<locals>.Connection.disconnect)r6 r7 r8 r rr r0 rE rg r1 � Connection� s rw ) ra r@ �hostnamero � default_portrp Zuseridrr r� r� r� r� r� r� r� rt r% rW rs r rw rX �ssl�update�connection_class_sslr� r rm r$ ZUnixDomainSocketConnectionrk r� )rU � asynchronousZconninfo� connparamsZ conn_class�classes�klassrn �schemer� rq rr ru �queryZconnection_clsrw r0 rE r1 � _connparamsr sv � �� � �zChannel._connparamsc C s |r| j | jd�S | j | jd�S )N)ro )r r r )rU r} r0 r0 r1 �_create_client� s zChannel._create_clientc C s0 | j |d�}| jj|d d�| _tjf i |��S �N�r} rv )rv )r� r rj r$ �ConnectionPool�rU r} rl r0 r0 r1 � _get_pool� s zChannel._get_poolc C s4 t jdk rtd�t ���| jr.tjt| jd�S t jS )N)r rL r zSRedis transport requires redis-py versions 3.2.0 or later. You have {0.__version__}rm ) r$ r� r rj rO � functools�partialrs rv rT r0 r0 r1 r� � s ���zChannel._get_clientc c s |r |V n | � � V d S rC �r� �rU r@ r0 r0 r1 r� � s zChannel.conn_or_acquirec C s | j d u r| �� | _ | j S rC )r r� rT r0 r0 r1 r � s z Channel.poolc C s | j d u r| jdd�| _ | j S )NTr� )r r� rT r0 r0 r1 r � s zChannel.async_poolc C s | j dd�S )z+Client used to publish messages, BRPOP etc.Tr� r� rT r0 r0 r1 r@ � s zChannel.clientc C s | j dd�}|�� S )z1Pub/Sub connection used to consume fanout queues.Tr� )r� ry r� r0 r0 r1 r� � s zChannel.subclientc C s | j �| j� d S rC )r� r{ r� rT r0 r0 r1 r" � s zChannel._update_queue_cyclec C s ddl m} |jS )Nr r! )r$ r" r/ )rU r" r0 r0 r1 r � s zChannel._get_response_errorc s � fdd�� j D �S )z<Set of queues being consumed from (excluding fanout queues).c s h | ]}|� j vr|�qS r0 )r� r, rT r0 r1 � <setcomp> s �z(Channel.active_queues.<locals>.<setcomp>)Z_active_queuesrT r0 rT r1 r� s zChannel.active_queues)F)F)r )F)NN)F)F)F)N)br6 r7 r8 r9 r~ Z_clientZ _subclientrc Zsupports_fanoutrZ r r� r� r� r r� r� r� r� r� r� r� �PRIORITY_STEPSr� r� r� r� r� r� r� � DEFAULT_HEALTH_CHECK_INTERVALr� r� r� rO r� r r r r� �from_transport_optionsr$ rw rt � SSLConnectionr| rw rD r r� r� r r r! r% r# r* r+ r� r' r4 r r5 r� r r� rG rO r rP rR rT rU r[ r] r_ ra rb r� re rk rm r� r� r� r� r r� r� r r r r@ r� r" r r� rr r0 r0 rg r1 r� e s� �� ( � � Q r� c st e Zd ZdZeZdZeZdZdZ e j j j deg d��d�Z erHe� \ZZ� fdd�Zd d � Zd d � Zd d� Z� ZS )r' zRedis Transport.Nr$ T)�directr0 rV )r} Z exchange_typec s. t d u rtd��t� j|i |�� t� | _d S )Nz)Missing redis library (pip install redis))r$ � ImportErrorr^ rw r� r rk rg r0 r1 rw s zTransport.__init__c C s t jS rC )r$ � __version__rT r0 r0 r1 �driver_version! s zTransport.driver_versionc s� | j ����j� �j��j� | j����fdd�}|�_� ���fdd���j��� �� d�j � |j j � dt�}�� |�j� d S )Nc s@ | j r��| j � � jr<z�j��� W n ty: Y n0 d S rC )r� r& r� �on_tickr� )ra )r �loopr� r0 r1 �_on_disconnect+ s z:Transport.register_with_event_loop.<locals>._on_disconnectc s �� � �fdd��j D � d S )Nc s g | ]}� |�|��qS r0 r0 )rR r� )� add_readerr� r0 r1 rV : r| zMTransport.register_with_event_loop.<locals>.on_poll_start.<locals>.<listcomp>)r� r0 )r� r �cycle_poll_startr� r0 r1 r� 8 s z9Transport.register_with_event_loop.<locals>.on_poll_startr� r� )r r� r� r� r� r� r� r� r� Zcall_repeatedlyr� r@ Ztransport_optionsr� r� r� )rU ra r� r� r� r0 )r� r r� r� r� r� r1 �register_with_event_loop$ s$ ��z"Transport.register_with_event_loopc C s | j �|� dS )z1Handle AIO event for one of our file descriptors.N)r r� )rU r� r0 r0 r1 r� F s zTransport.on_readable)r6 r7 r8 r9 r� Zpolling_interval� DEFAULT_PORTry Z driver_typeZ driver_namer r' Z implements�extend� frozensetr$ r2 r r rw r� r� r� rr r0 r0 rg r1 r' s � "r' c @ s e Zd ZdZdS )� SentinelManagedSSLConnectionz�Connect to a Redis server using Sentinel + TLS. Use Sentinel to identify which Redis server is the current master to connect to and when connecting to the Master server, use an SSL Connection. Nr5 r0 r0 r0 r1 r� L s r� c @ sH e Zd ZdZejd Zer ejndZer,e ndZ d dd�Z d dd�Z dS ) �SentinelChannela Channel with explicit Redis Sentinel knowledge. Broker url is supposed to look like: .. code-block:: sentinel://0.0.0.0:26379;sentinel://0.0.0.0:26380/... where each sentinel is separated by a `;`. Other arguments for the sentinel should come from the transport options (see `transport_options` of :class:`~kombu.connection.Connection`). You must provide at least one option in Transport options: * `master_name` - name of the redis group to poll Example: ------- .. code-block:: python >>> import kombu >>> c = kombu.Connection( 'sentinel://sentinel1:26379;sentinel://sentinel2:26379', transport_options={'master_name': 'mymaster'} ) >>> c.connect() )� master_name�min_other_sentinels�sentinel_kwargsNFc C s� | � |�}|�� }|�dd � |�dd � g }| jjjD ]4}t|�}|jdkr8|jpZ| jj }|� |j |f� q8|s�|� |d |d f� t j |ft| dd�t| dd �d�|��}t| dd �}|d u r�td ��|�|tj�jS ) Nrn ro r r� r r� )r� r� r� z1'master_name' transport option must be specified.)r� �copyrX ra r@ Zaltr r� ro ry r� rx r ZSentinelr� r� Z master_forr$ rv ro ) rU r} r~ Zadditional_paramsZ sentinels�urlro Z sentinel_instr� r0 r0 r1 �_sentinel_managed_pool~ s: � �� ��z&SentinelChannel._sentinel_managed_poolc C s* | j |d�}| jj|d d�| _| �|�S r� )r� r rj r� r� r0 r0 r1 r� � s zSentinelChannel._get_pool)F)F) r6 r7 r8 r9 r� r� r �SentinelManagedConnectionrt r� r| r� r� r0 r0 r0 r1 r� Y s %r� c @ s e Zd ZdZdZeZdS )�SentinelTransportzRedis Sentinel Transport.i g N)r6 r7 r8 r9 ry r� r� r0 r0 r0 r1 r� � s r� )Mr9 � __future__r r� rH r( r � collectionsr � contextlibr r r r Zviner Zkombu.exceptionsr r Z kombu.logr Zkombu.utils.compatr Zkombu.utils.encodingr Zkombu.utils.eventior r r Zkombu.utils.functionalr Zkombu.utils.jsonr r Zkombu.utils.objectsr Zkombu.utils.schedulingr Zkombu.utils.urlr ru r r$ r� r �logger�criticalr; r r� rg r� r� r r2 r3 r r4 rB rG rH rv rs r@ rz rn ZPubSubrx r~ r� r� r' r� r� r� r� r� r0 r0 r0 r1 �<module> s~ 5 S 4k 'D � P
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка