Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/asynchronous/http/__pycache__/base.cpython-39.pyc
Ðазад
a o�hC& � @ s� d Z ddlmZ ddlZddlmZ ddlmZ ddlm Z m Z m Z ddl m Z ddlmZ dd lmZ dd lmZmZ er�dd lmZ d Zeed �Zedd�dd� �ZG dd� de�Z e j G dd� d��Z G dd� d�Z eefdd��Z G dd� d�Z!dS ) z&Base async HTTP client implementation.� )� annotationsN)� responses)� TYPE_CHECKING)�Thenable� maybe_promise�promise)� HttpError)�coro)� bytes_to_str)� maybe_list�memoize)� TracebackType)�Headers�Response�Request� BaseClient�pypy_version_infoi� )�maxsizec C s d� dd� | �d�D ��S )N�-c s s | ]}|� � V qd S �N)� capitalize)�.0�p� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/asynchronous/http/base.py� <genexpr> � z#normalize_header.<locals>.<genexpr>)�join�split)�keyr r r �normalize_header s r c @ s e Zd ZdZdZdZdS )r z%Represents a mapping of HTTP headers.FN)�__name__� __module__� __qualname__�__doc__�complete� _prev_keyr r r r r s r c @ s� e Zd ZdZd Z Z Z Z Z Z Z Z Z Z Z ZZdZdZdZdZdZdZes`dZddd �Zdd d �Zd d � ZdS )r a? A HTTP Request. Arguments: --------- url (str): The URL to request. method (str): The HTTP method to use (defaults to ``GET``). Keyword Arguments: ----------------- headers (Dict, ~kombu.asynchronous.http.Headers): Optional headers for this request body (str): Optional body for this request. connect_timeout (float): Connection timeout in float seconds Default is 30.0. timeout (float): Time in float seconds before the request times out Default is 30.0. follow_redirects (bool): Specify if the client should follow redirects Enabled by default. max_redirects (int): Maximum number of redirects (default 6). use_gzip (bool): Allow the server to use gzip compression. Enabled by default. validate_cert (bool): Set to true if the server certificate should be verified when performing ``https://`` requests. Enabled by default. auth_username (str): Username for HTTP authentication. auth_password (str): Password for HTTP authentication. auth_mode (str): Type of HTTP authentication (``basic`` or ``digest``). user_agent (str): Custom user agent for this request. network_interface (str): Network interface to use for this request. on_ready (Callable): Callback to be called when the response has been received. Must accept single ``response`` argument. on_stream (Callable): Optional callback to be called every time body content has been read from the socket. If specified then the response body and buffer attributes will not be available. on_timeout (callable): Optional callback to be called if the request times out. on_header (Callable): Optional callback to be called for every header line received from the server. The signature is ``(headers, line)`` and note that if you want ``response.headers`` to be populated then your callback needs to also call ``client.on_header(headers, line)``. on_prepare (Callable): Optional callback that is implementation specific (e.g. curl client will pass the ``curl`` instance to this callback). proxy_host (str): Optional proxy host. Note that a ``proxy_port`` must also be provided or a :exc:`ValueError` will be raised. proxy_username (str): Optional username to use when logging in to the proxy. proxy_password (str): Optional password to use when authenticating with the proxy server. ca_certs (str): Custom CA certificates file to use. client_key (str): Optional filename for client SSL key. client_cert (str): Optional filename for client SSL certificate. Ng >@T� ) �url�method�on_ready� on_timeout� on_stream� on_prepare� on_header�headers� __weakref__�__dict__�GETc K s� || _ |p| j| _t|�p t� | _t|�| _t|�| _t|�| _t|�| _| rl| � � D ]\} } t | | | � qVt |t �s�t |p~i �}|| _ d S r )r( r) r r r* r+ r, r- r. �items�setattr� isinstancer r/ ) �selfr( r) r* r+ r, r- r. r/ �kwargs�k�vr r r �__init__t s zRequest.__init__c C s | j �||� d S r )r* �then)r6 �callbackZerrbackr r r r; � s z Request.thenc C s d� | �S )Nz&<Request: {0.method} {0.url} {0.body}>)�format�r6 r r r �__repr__� s zRequest.__repr__)r2 NNNNNN)N) r! r" r# r$ �body� user_agentZnetwork_interfaceZ auth_usernameZ auth_passwordZ auth_modeZ proxy_hostZ proxy_portZproxy_usernameZproxy_password�ca_certsZ client_key� client_cert�connect_timeout�request_timeoutZfollow_redirects� max_redirectsZuse_gzipZ validate_cert�PYPY� __slots__r: r; r? r r r r r * sD :��������� � r c @ sN e Zd ZdZesdZddd�Zdd� Zedd � �Z ed d � �Z ed d � �Z dS )r a HTTP Response. Arguments --------- request (~kombu.asynchronous.http.Request): See :attr:`request`. code (int): See :attr:`code`. headers (~kombu.asynchronous.http.Headers): See :attr:`headers`. buffer (bytes): See :attr:`buffer` effective_url (str): See :attr:`effective_url`. status (str): See :attr:`status`. Attributes ---------- request (~kombu.asynchronous.http.Request): object used to get this response. code (int): HTTP response code (e.g. 200, 404, or 500). headers (~kombu.asynchronous.http.Headers): HTTP headers for this response. buffer (bytes): Socket read buffer. effective_url (str): The destination url for this request after following redirects. error (Exception): Error instance if the request resulted in a HTTP error code. status (str): Human equivalent of :attr:`code`, e.g. ``OK``, `Not found`, or 'Internal Server Error'. ) �request�coder/ �buffer� effective_url�error�status�_bodyr0 Nc C s� || _ || _|d ur|nt� | _|| _|p.|j| _d | _|pHt� | jd�| _ || _ | j d u r�| jdk sp| jdkr�t | j| j | �| _ d S )N�Unknown�� i+ ) rI rJ r r/ rK r( rL rO r �getrN rM r )r6 rI rJ r/ rK rL rM rN r r r r: � s zResponse.__init__c C s | j r | j �dS )z�Raise if the request resulted in an HTTP error code. Raises ------ :class:`~kombu.exceptions.HttpError` N)rM r> r r r �raise_for_error� s zResponse.raise_for_errorc C s& | j du r | jdur | j�� | _ | j S )z�The full contents of the response body. Note: ---- Accessing this property will evaluate the buffer and subsequent accesses will be cached. N)rO rK �getvaluer> r r r r@ � s z Response.bodyc C s | j S r )rJ r> r r r � status_code� s zResponse.status_codec C s | j S r )r@ r> r r r �content� s zResponse.content)NNNNN) r! r" r# r$ rG rH r: rS �propertyr@ rU rV r r r r r � s � r c c s� d V \}}|� d�rq q |s&d|_q q |d �� rZ|j}d�|�|�pHd|�� g�||< q |�dd�\}}| |� }|_|�� ||< q d S )NzHTTP/Tr � � �:� ) � startswithr% �isspacer& r rR �lstripr �strip)Zkeyt�liner/ �pkeyr �valuer r r � header_parser� s "rc c @ s` e Zd ZdZeZeZeZdd� Zdd� Zdd� Z dd � Z d d � Z d d � Z ddddd�dd�Z dS )r z�Base class for HTTP clients. This class provides the basic structure and functionality for HTTP clients. Subclasses should implement specific HTTP client behavior. c K s || _ t� | _d S r )�hubrc �_header_parser)r6 rd r7 r r r r: � s zBaseClient.__init__c K s> t |�p g D ],}t|| j�s.| j|fi |��}| �|� q d S r )r r5 r � add_request)r6 rI r7 �reqr r r �perform� s zBaseClient.performc C s t d��d S )Nzmust implement add_request)�NotImplementedError)r6 rI r r r rf s zBaseClient.add_requestc C s d S r r r> r r r �close s zBaseClient.closec C s8 z| j �t|�|f� W n ty2 t� | _ Y n0 d S r )re �sendr � StopIterationrc )r6 r/ r` r r r r. s zBaseClient.on_headerc C s | S r r r> r r r � __enter__ s zBaseClient.__enter__ztype[BaseException] | NonezBaseException | NonezTracebackType | None�None)�exc_type�exc_val�exc_tb�returnc C s | � � d S r )rj )r6 ro rp rq r r r �__exit__ s zBaseClient.__exit__N)r! r" r# r$ r r r r: rh rf rj r. rm rs r r r r r � s r )"r$ � __future__r �sys� http.clientr �typingr Zviner r r Zkombu.exceptionsr Zkombu.utils.compatr Zkombu.utils.encodingr Zkombu.utils.functionalr r �typesr �__all__�hasattrrG r �dictr �registerr r rc r r r r r �<module> s, aP
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка