Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/amqp/__pycache__/connection.cpython-39.pyc
Ðазад
a k�h�k � @ s> d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddl m Z m Z m Z ddlmZ dd lmZ dd lmZmZmZmZmZmZmZmZmZ dd l m Z m Z dd l m Z zdd l!m"Z" W n" e#y� G dd� de$�Z"Y n0 dZ%d�&� Z'dZ(e�)d�Z*e�)d�Z+de d�Z,dddd�Z-G dd� de�Z.dS )zAMQP Connections.� N)�array)� monotonic)�ensure_promise� )� __version__�sasl�spec)�AbstractChannel)�Channel) �AMQPDeprecationWarning� ChannelError�ConnectionError�ConnectionForced� MessageNacked�RecoverableChannelError�RecoverableConnectionError� ResourceError�error_for_code)� frame_handler� frame_writer�� Transport)�SSLErrorc @ s e Zd ZdS )r N)�__name__� __module__� __qualname__� r r �/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/amqp/connection.pyr s r z�The .{attr} attribute on the connection was accessed before the connection was established. This is supported for now, but will be deprecated in amqp 2.2.0. Since amqp 2.0 you have to explicitly call Connection.connect() before using the connection. zP Start from server, version: %d.%d, properties: %s, mechanisms: %s, locales: %s )� ConnectionZamqpz)amqp.connection.Connection.heartbeat_tickzpy-amqp)�productZproduct_versionT)Zconsumer_cancel_notifyzconnection.blockedZ authentication_failure_closec s� e Zd ZdZeZeZeZdZ dZ dZ dZ dZ dZdZdZdZe�ejjd�e�ejj�e�ejjd�e�ejjd�e�ejjd�e�ejj�e�ejj�e�ejj �hZ dd � e D �Z ejjejj fZ e e j!e"e#fZ$e%fZ&e'e(e j!e"e#fZ)e*fZ+d d d ddd d ddddddddddddddde,e-f� fdd� Z.dd� Z/dd� Z0dd� Z1d`dd�Z2dd� Z3dad d �Z4d d � Z5e6d d!� �Z7e7j8d"d!� �Z7e6d#d$� �Z9e9j8d%d$� �Z9e6d&d'� �Z-e-j8d(d'� �Z-dbd*d+�Z:d,d-� Z;dcd.d/�Z<ddd1d2�Z=d3d4� Z>ded5d6�Z?e6d7d8� �Z@d9d:� ZAd;d<� ZBd=d>� ZCdfd?d@�ZDdAdB� ZEdgdCdD�ZFdhdEdF�ZGdGdH� ZHdidKdL�ZIdMdN� ZJdOdP� ZKdQdR� ZLdSdT� ZMdUdV� ZNdWdX� ZOdjdZd[�ZPe6d\d]� �ZQe6d^d_� �ZR� ZSS )kr a� AMQP Connection. The connection class provides methods for a client to establish a network connection to a server, and for both peers to operate the connection thereafter. GRAMMAR:: connection = open-connection *use-connection close-connection open-connection = C:protocol-header S:START C:START-OK *challenge S:TUNE C:TUNE-OK C:OPEN S:OPEN-OK challenge = S:SECURE C:SECURE-OK use-connection = *channel close-connection = C:CLOSE S:CLOSE-OK / S:CLOSE C:CLOSE-OK Create a connection to the specified host, which should be a 'host[:port]', such as 'localhost', or '1.2.3.4:5672' (defaults to 'localhost', if a port is not specified then 5672 is used) Authentication can be controlled by passing one or more `amqp.sasl.SASL` instances as the `authentication` parameter, or setting the `login_method` string to one of the supported methods: 'GSSAPI', 'EXTERNAL', 'AMQPLAIN', or 'PLAIN'. Otherwise authentication will be performed using any supported method preferred by the server. Userid and passwords apply to AMQPLAIN and PLAIN authentication, whereas on GSSAPI only userid will be used as the client name. For EXTERNAL authentication both userid and password are ignored. The 'ssl' parameter may be simply True/False, or a dictionary of options to pass to :class:`ssl.SSLContext` such as requiring certain certificates. For details, refer ``ssl`` parameter of :class:`~amqp.transport.SSLTransport`. The "socket_settings" parameter is a dictionary defining tcp settings which will be applied as socket options. When "confirm_publish" is set to True, the channel is put to confirm mode. In this mode, each published message is confirmed using Publisher confirms RabbitMQ extension. Nr ZooFSS�s�BlB�BsBBc C s i | ] }|j |�qS r )� method_sig��.0�mr r r � <dictcomp>� � zConnection.<dictcomp>zlocalhost:5672Zguestr �/�en_USFc s t �� j| _| pd} | pd} |r:t|tj�r2|f}|| _n�|d ur�|dkrVt�|�}n�|dkrht� � }n||dkr�|d u s�|d u r�t d��t� ||�}nN|dkr�|d u s�|d u r�t d��t� ||�}n |d ur�t� ||�}n t d|��|f| _n,tj|d d �t� � t� ||�t� ||�f| _t| jfi | �p,i ��| _|| _|| _|| _t|�| _|| _|| _d | _i | _t� �| d � d | _ d | _ d | _ | | _ | | _ || _!|| _"| | _#|| _$|| _%|| _&|| _'|| _(t|�| _)t*d �| _+d | _,d | _-i | _.g | _/g | _0| | _1d S )Ni�� i �GSSAPI�EXTERNAL�AMQPLAINz-Must supply authentication or userid/password�PLAINzInvalid login methodT)Z fail_softFr �H)2�uuid�uuid4�hex�_connection_id� isinstancer ZSASL�authenticationr+ r, � ValueErrorr- r. ZRAW�dict�library_properties�client_properties�locale�host� virtual_hostr � on_tune_ok�frame_handler_cls�frame_writer_cls�_handshake_complete�channels�super�__init__� _frame_writer�_on_inbound_frame� _transport� channel_max� frame_max�client_heartbeat�confirm_publish�ssl� read_timeout� write_timeout�socket_settings� on_blocked� on_unblocked�on_openr �_used_channel_ids� version_major� version_minor�server_properties� mechanisms�locales�connect_timeout)�selfr; Zuserid�passwordZ login_method�login_responser5 r< r: r9 rK rX rG rH � heartbeatrQ rO rP rJ r= rL rM rN r r �kwargs�auth�� __class__r r rC � s� �� ��� zConnection.__init__c C sV | j r0d| j� d| j� d| j � dt| �d�d� S d| j� d| j� dt| �d�d�S d S )Nz<AMQP Connection: r) z using z at z#x�>z (disconnected) at )rF r; r< �id�rY r r r �__repr__ s ���zConnection.__repr__c C s | � � | S �N)�connectrc r r r � __enter__" s zConnection.__enter__c G s | � � d S re )�close)rY Zeargsr r r �__exit__& s zConnection.__exit__c C s | j �||�S re )rQ �then)rY Z on_successZon_errorr r r rj ) s zConnection.thenc C s` | j �tjj| jtjj| jtjj| j tjj | j tjj | j tjj| jtjj| jtjj| ji� d S re )Z _callbacks�updater r �Start� _on_start�OpenOk� _on_open_ok�Secure� _on_secure�Tune�_on_tune�Close� _on_close�Blocked� _on_blocked� Unblocked� _on_unblocked�CloseOk� _on_close_okrc r r r �_setup_listeners, s �zConnection._setup_listenersc C s� | j r|r|� S d S zh| j| j| j| j| j| j| jd�| _| j� � | � | | j �| _ | � | | j�| _| jsz| j| jd� qdW n ttfy� | �� � Y n0 d S )N)rN )�timeout)� connectedr r; rX rK rL rM rN � transportrf r> �on_inbound_method�on_inbound_framer? r r@ � drain_events�OSErrorr �collect)rY �callbackr r r rf 8 s$ � �zConnection.connectc C s t �ttj|d��� d S )N)�attr)�warnings�warnr �W_FORCE_CONNECT�format)rY r� r r r �_warn_force_connectP s �z Connection._warn_force_connectc C s" | j d u r | �d� | �� | j S )Nr )rF r� rf rc r r r r T s zConnection.transportc C s || _ d S re )rF )rY r r r r r [ s c C s" | j d u r | �d� | �� | j S )Nr� )rE r� rf rc r r r r� _ s zConnection.on_inbound_framec C s || _ d S re )rE )rY r� r r r r� f s c C s" | j d u r | �d� | �� | j S )Nr )rD r� rf rc r r r r j s zConnection.frame_writerc C s || _ d S re )rD )rY r r r r r q s �FsSsc s. | j }|| _|| _|| _t|t�r,|�d�}|�d�| _|�d�| _ t � t | j| j| j| j| j � |� d�pni � |�di �}|�� fdd�| j�� D �� |s�|�dd � | jD ](} | j| jv r�| �| �} | tur� �q q�td�d�d d � | jD ���� d�| j��� ���| �t j j ||| j| | j f� d S ) Nzutf-8� � � capabilitiesc s i | ]\}}� � |�r||�qS r )�get)r% Z wanted_capZ enable_cap�Zscapr r r' � s �z(Connection._on_start.<locals>.<dictcomp>zGCouldn't find appropriate auth mechanism (can offer: {}; available: {})s , c s s | ]}|j r|j V qd S re )� mechanismr$ r r r � <genexpr>� s �z'Connection._on_start.<locals>.<genexpr>) r9 rS rT rU r4 �str�encode�splitrV rW � AMQP_LOGGER�debug�START_DEBUG_FMTr� � setdefaultrk �negotiate_capabilities�items�popr5 r� �start�NotImplementedr r� �join�decode� send_methodr r ZStartOkr: ) rY rS rT rU rV rW �argsigr9 �capr5 r[ r r� r rm u sN � � � ����zConnection._on_startc C s d S re r )rY � challenger r r rq � s zConnection._on_securec C s� | j pd}|p| j| _|p | j| _|p(d| _| jdks>|dkrNt| j|�| _nt| j|�| _| j shd| _| jtj j || j| j| jf| j d� d S )Nr �r� ) rI rG rH �server_heartbeat�maxr\ �minr� r r ZTuneOk� _on_tune_sent)rY rG rH r� r� rI r r r rs � s �zConnection._on_tune�ssbc C s | � tjj|| jddf� d S )N� F)r� r r �Openr< )rY r� r r r r� � s �zConnection._on_tune_sentc C s d| _ | �| � d S )NT)r@ rQ rc r r r ro � s zConnection._on_open_okc K s t |f|||||d�|��S )N)rX rK rL rM rN r )rY r; rX rK rL rM rN r] r r r r � s ���zConnection.Transportc C s | j o | j jS re )rF r~ rc r r r r~ � s zConnection.connectedc sV � j r� j �� � jr@� fdd�� j�� D �}|D ] }|�� q2d � _ � _� _d S )Nc s g | ]}|� ur|�qS r r )r% �chrc r r � <listcomp>� s �z&Connection.collect.<locals>.<listcomp>)rF rh rA �valuesr� � connection)rY rA r� r rc r r� � s � zConnection.collectc C s^ t | j�}td| jd �D ] }||vr| j�|� | S qtd�t| j�| j�t j j ��d S )Nr z/No free channel ids, current={}, channel_max={}) �setrR �rangerG �appendr r� �lenrA r r r� )rY Zused_channel_ids� channel_idr r r �_get_free_channel_id� s ��z Connection._get_free_channel_idc C s0 || j v r td|�d���n| j �|� |S d S )NzChannel z already open)rR r r� )rY r� r r r �_claim_channel_id� s z Connection._claim_channel_idc C sR | j du rtd��z | j | W S tyL | j| ||d�}|�� | Y S 0 dS )z�Create new channel. Fetch a Channel object identified by the numeric channel_id, or create that object if it doesn't already exist. NzConnection already closed.)rQ )rA r �KeyErrorr �open)rY r� r� �channelr r r r� � s zConnection.channelc C s t d��d S )NzUse AMQP heartbeats)�NotImplementedErrorrc r r r �is_alive s zConnection.is_alivec C s | � |�s q d S re )� blocking_read)rY r} r r r r� s zConnection.drain_eventsc C s@ | j �|�� | j �� }W d � n1 s,0 Y | �|�S re )r Zhaving_timeoutZ read_framer� )rY r} �framer r r r� s (zConnection.blocking_readc C s& | j d u rtd��| j | �|||�S )NzConnection already closed)rA r Zdispatch_method)rY r� r# �payload�contentr r r r� s �z Connection.on_inbound_methodr� �r r c C s� | j du rdS zfz:d| _| jtjj||||d |d ftjjd�W W d| _S ttfyj | � � � Y n0 W d| _nd| _0 dS )� Request a connection close. This method indicates that the sender wants to close the connection. This may be due to internal conditions (e.g. a forced shut-down) or due to an error handling a specific method, i.e. an exception. When a close is due to an exception, the sender provides the class and method id of the method which caused the exception. RULE: After sending this method any received method except the Close-OK method MUST be discarded. RULE: The peer sending this method MAY use a counter or timeout to detect failure of the other peer to respond correctly with the Close-OK method. RULE: When a server receives the Close method from a client it MUST delete all server-side resources associated with the client's context. A client CANNOT reconnect to a context after sending or receiving a Close method. PARAMETERS: reply_code: short The reply code. The AMQ reply codes are defined in AMQ RFC 011. reply_text: shortstr The localised reply text. This text can be logged as an aid to resolving issues. class_id: short failing method class When the close is provoked by a method exception, this is the class of the method. method_id: short failing method ID When the close is provoked by a method exception, this is the ID of the method. NTr r )�waitF) rF Z is_closingr� r r rt rz r� r r� )rY � reply_code� reply_textr# r� r r r rh s 6 � � zConnection.closec C s | � � t||||ft��dS )r� N)� _x_close_okr r )rY r� r� Zclass_idZ method_idr r r ru f s 5�zConnection._on_closec C s | j tjj| jd� dS )ah Confirm a connection close. This method confirms a Connection.Close method and tells the recipient that it is safe to release resources for the connection and close the socket. RULE: A peer that detects a socket closure without having received a Close-Ok handshake method SHOULD log the error. r� N)r� r r rz r{ rc r r r r� � s zConnection._x_close_okc C s | � � dS )ai Confirm a connection close. This method confirms a Connection.Close method and tells the recipient that it is safe to release resources for the connection and close the socket. RULE: A peer that detects a socket closure without having received a Close-Ok handshake method SHOULD log the error. N)r� rc r r r r{ � s zConnection._on_close_okc C s d}| j r| � |�S dS )zlCallback called when connection blocked. Notes: This is an RabbitMQ Extension. z#connection blocked, see broker logsN)rO )rY �reasonr r r rw � s zConnection._on_blockedc C s | j r| � � S d S re )rP rc r r r ry � s zConnection._on_unblockedc C s | � ddd d d � d S )N� r )r rc r r r �send_heartbeat� s zConnection.send_heartbeat� c C s t �d| j� | jsdS |dkr$d}| j}| j}| jdu sD| j|krLt� | _| j du s`| j |krht� | _ t� }t �d| j| j |||| j| j| j� || | _| _ || j| j| kr�t �d| j� | � � t� | _d| j }| j | }|t� k }| j �r|�rt d��dS )a� Send heartbeat packets if necessary. Raises: ~amqp.exceptions.ConnectionForvced: if none have been received recently. Note: This should be called frequently, on the order of once per second. Keyword Arguments: rate (int): Number of heartbeat frames to send during the heartbeat timeout z"heartbeat_tick : for connection %sNr r� z�heartbeat_tick : Prev sent/recv: %s/%s, now - %s/%s, monotonic - %s, last_heartbeat_sent - %s, heartbeat int. - %s for connection %sz3heartbeat_tick: sending heartbeat for connection %szToo many heartbeats missed) �AMQP_HEARTBEAT_LOGGERr� r3 r\ � bytes_sent� bytes_recv� prev_sentr �last_heartbeat_sent� prev_recv�last_heartbeat_receivedr� r )rY ZrateZsent_nowZrecv_now�nowZtwo_heartbeatsZtwo_heartbeats_intervalZheartbeats_missedr r r �heartbeat_tick� sF �� � zConnection.heartbeat_tickc C s | j jS re )r �sockrc r r r r� s zConnection.sockc C s | j �d�pi S )Nr� )rU r� rc r r r �server_capabilities s z Connection.server_capabilities)N)N)r� )r! )r� )FNNN)NN)N)N)r r� r� r" )r� )Tr r r �__doc__r �NEGOTIATE_CAPABILITIESr� �LIBRARY_PROPERTIESr8 r\ rI r� r� r� r� r� r� r� r �methodr rl rn rp rr rt rv rx rz Z_METHODSZ _ALLOWED_METHODS_WHEN_CLOSINGr �socket�error�IOErrorr� Zconnection_errorsr Zchannel_errorsr r Z recoverable_connection_errorsr Zrecoverable_channel_errorsr r rC rd rg ri rj r| rf r� �propertyr �setterr� rm rq rs r� ro r r~ r� r� r� r� r� r� r� r� rh ru r� r{ rw ry r� r� r� r� � __classcell__r r r_ r r ? s� . � �����[ � 1 � � H9 ? r )/r� �loggingr� r0 r� r �timer Zviner r� r r r Zabstract_channelr r� r � exceptionsr r r r r r r r r Zmethod_framingr r r r rK r � ImportError� Exceptionr� �stripr� �__all__� getLoggerr� r� r� r� r r r r r �<module> s@ , ���
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка