Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/common/__pycache__/aws.cpython-39.pyc
Ðазад
a q�h�D � @ s� d dl mZ d dl mZ d dl mZ d dlZd dlmZ d dlZd dlZd dlZd dlm Z z d dl Z W n e y� d dl Z Y n0 d dl mZ d dl mZ d d l mZ d d lmZmZmZ d d lmZ d d lmZmZ d d l mZmZmZ d dl m Z m Z g d�Z dZ dZ!d�"� Z#G dd� de�Z$G dd� de$�Z%G dd� de�Z&G dd� de'�Z(G dd � d e(�Z)G d d � d e(�Z*G d d � d �Z+G d!d"� d"e&�Z,G d#d$� d$e�Z-d,d&d'�Z.d(d)� Z/G d*d+� d+e�Z0dS )-� )�Dict)�Optional)�TypeN)�datetime)�sha256)�ET)� _real_unicode)� basestring)�ConnectionUserAndKey� XmlResponse� BaseDriver)� JsonResponse)�InvalidCredsError�MalformedResponseError)�b�httplib�urlquote)�findtext�findall)�AWSBaseResponse�AWSGenericResponse�AWSTokenConnection�SignedAWSConnection�AWSRequestSignerAlgorithmV2�AWSRequestSignerAlgorithmV4� AWSDriver�2zUNSIGNED-PAYLOADa� "params" dictionary contains an attribute "%s" which value (%s, %s) is not a string. Parameters are sent via query parameters and not via request body and as such, all the values need to be of a simple type (string, int, bool). For arrays and other complex types, you should use notation similar to this one: params['TagSpecification.1.Tag.Value'] = 'foo' params['TagSpecification.2.Tag.Value'] = 'bar' See https://docs.aws.amazon.com/AWSEC2/latest/APIReference/Query-Requests.html for details. c @ s e Zd ZdZdd� ZdS )r Nc C s( t |d| jd�}t |d| jd�}||fS )z� Parse code and message from the provided error element. :return: ``tuple`` with two elements: (code, message) :rtype: ``tuple`` ZCode��element�xpath� namespace�Message)r r )�selfr �code�message� r% ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/common/aws.py�_parse_error_detailsN s ��z$AWSBaseResponse._parse_error_details)�__name__� __module__� __qualname__r r' r% r% r% r& r K s r c @ s$ e Zd ZdZi Zdd� Zdd� ZdS )r Nc C s | j tjtjtjfv S �N)�statusr �OK�CREATED�ACCEPTED)r" r% r% r& �successi s zAWSGenericResponse.successc C s8 | j j}t| j�}|tjkrF| js<tt| j�d | j ��n t| j��zt � | j�}W n& t y| t d| j| j jd��Y n0 | jr�t|| j| jd�}n|g}g }|D ]�}| j|d�\}}| j�|d �} | d u r�|�d||f � q�i } t| d��r| jD ]} | |v r�|| | | < q�| f || j jd�| ���q�d �|�S ) Nz: zFailed to parse XML)�body�driverr )r �%s: %s�kwargs)�valuer2 � )� connection�context�intr, r � FORBIDDENr1 r �str�errorr �XML� Exceptionr r2 r r r r' � exceptions�get�append�hasattrr4 �join) r" r8 r, r1 ZerrsZmsgs�errr# r$ Z exceptionCls�params�keyr% r% r& � parse_errorl sD � � �z AWSGenericResponse.parse_error)r( r) r* r r? r0 rG r% r% r% r& r ] s r c s6 e Zd Zd � fdd� Z� fdd�Z� fdd�Z� ZS ) r TNc s. | | _ tt| �j|||||||| | |d� d S )N)�secure�host�port�url�timeout� retry_delay�backoff� proxy_url)�token�superr �__init__) r" �user_idrF rH rI rJ rK rL rO rP rM rN �� __class__r% r& rR � s �zAWSTokenConnection.__init__c s | j r| j |d< tt| ��|�S �Nzx-amz-security-token)rP rQ r �add_default_params�r" rE rT r% r& rW � s z%AWSTokenConnection.add_default_paramsc s | j r| j |d< tt| ��|�S rV )rP rQ r �add_default_headers�r" �headersrT r% r& rY � s z&AWSTokenConnection.add_default_headers) TNNNNNNNN)r( r) r* rR rW rY � __classcell__r% r% rT r& r � s � r c @ s, e Zd ZdZdd� Zd dd�Zd d d �ZdS ) �AWSRequestSignerz@ Class which handles signing the outgoing AWS requests. c C s || _ || _|| _|| _dS )aI :param access_key: Access key. :type access_key: ``str`` :param access_secret: Access secret. :type access_secret: ``str`` :param version: API version. :type version: ``str`` :param connection: Connection instance. :type connection: :class:`Connection` N�� access_key� access_secret�versionr7 )r" r_ r` ra r7 r% r% r& rR � s zAWSRequestSigner.__init__�GET�/c C s |S r+ r% �r" rE �method�pathr% r% r& �get_request_params� s z#AWSRequestSigner.get_request_paramsNc C s ||fS r+ r% �r" rE r[ re rf �datar% r% r& �get_request_headers� s z$AWSRequestSigner.get_request_headers)rb rc )rb rc N)r( r) r* �__doc__rR rg rj r% r% r% r& r] � s �r] c @ s e Zd Zddd�Zd dd�ZdS ) r rb rc c C sR d|d< d|d< | j |d< | j|d< t�dt�� �|d< | j|| j|d �|d < |S ) Nr ZSignatureVersionZ HmacSHA256ZSignatureMethodZAWSAccessKeyId�Versionz%Y-%m-%dT%H:%M:%SZ� Timestamp)rE � secret_keyrf � Signature)r_ ra �time�strftime�gmtime�_get_aws_auth_paramr` rd r% r% r& rg � s �� z.AWSRequestSignerAlgorithmV2.get_request_paramsc C s� | j }t|�� �}|�� g }|D ]2}t|| �}|�t|dd�d t|dd� � q"d�|�} |j} |j rv|j dks�|j s�|j dkr�| dt|j � 7 } d �d | || f�} t � t jt|�t| �td ��� �} | �d �S ) aU Creates the signature required for AWS, per http://bit.ly/aR7GaQ [docs.amazonwebservices.com]: StringToSign = HTTPVerb + " " + ValueOfHostHeaderInLowercase + " " + HTTPRequestURI + " " + CanonicalizedQueryString <from the preceding step> � ��safe�=z-_~�&i� �P �:r6 rb )� digestmodzutf-8)r7 �list�keys�sortr; rA r rC rI rH rJ �base64� b64encode�hmac�newr r �digest�decode) r" rE rn rf r7 r} �pairsrF r5 �qs�hostname�string_to_signZb64_hmacr% r% r& rs � s0 � ����z/AWSRequestSignerAlgorithmV2._get_aws_auth_paramN)rb rc )rc )r( r) r* rg rs r% r% r% r& r � s r c @ st e Zd Zd dd�Zd dd�Zd dd �Zd d � Zd d � Zdd� Zdd� Z dd� Z dd� Z d dd�Z dd� Z dd� ZdS ) r rb rc c C s |dkr| j |d< |S )Nrb rl )ra rd r% r% r& rg s z.AWSRequestSignerAlgorithmV4.get_request_paramsNc C sH t �� }|�d�|d< | �||�|d< | j||||||d�|d< ||fS )N�%Y%m%dT%H%M%SZz X-AMZ-DatezX-AMZ-Content-SHA256�rE r[ �dtre rf ri � Authorization)r �utcnowrq �_get_payload_hash� _get_authorization_v4_header)r" rE r[ re rf ri �nowr% r% r& rj s ��z/AWSRequestSignerAlgorithmV4.get_request_headersc C sB | j |d�}| j|d�}| j||||||d�} d| j||| d� S )N)r� )r[ r� zNAWS4-HMAC-SHA256 Credential=%(u)s/%(c)s, SignedHeaders=%(sh)s, Signature=%(s)s)�u�c�sh�s)�_get_credential_scope�_get_signed_headers�_get_signaturer_ ) r" rE r[ r� re rf ri Zcredentials_scopeZsigned_headers� signaturer% r% r& r� s ���z8AWSRequestSignerAlgorithmV4._get_authorization_v4_headerc C s. | � |�}| j||||||d�}t||dd�S )Nr� T�rF �msg�hex)�_get_key_to_sign_with�_get_string_to_sign�_sign) r" rE r[ r� re rf ri rF r� r% r% r& r� + s �z*AWSRequestSignerAlgorithmV4._get_signaturec C s2 t t t t d| j |�d��| jjj�| jj�d�S )NZAWS4�%Y%m%d� aws4_request)r� r` rq r7 r2 � region_name� service_name�r" r� r% r% r& r� 3 s ����z1AWSRequestSignerAlgorithmV4._get_key_to_sign_withc C s6 | j |||||d�}d�d|�d�| �|�t|�g�S )N�rE r[ re rf ri r6 zAWS4-HMAC-SHA256r� )�_get_canonical_requestrC rq r� �_hash)r" rE r[ r� re rf ri Zcanonical_requestr% r% r& r� = s ��z/AWSRequestSignerAlgorithmV4._get_string_to_signc C s" d� |�d�| jjj| jjdg�S )Nrc r� r� )rC rq r7 r2 r� r� r� r% r% r& r� I s �z1AWSRequestSignerAlgorithmV4._get_credential_scopec C s d� dd� t|�� �D ��S )N�;c S s g | ] }|� � �qS r% )�lower)�.0�kr% r% r& � <listcomp>P � zCAWSRequestSignerAlgorithmV4._get_signed_headers.<locals>.<listcomp>)rC �sortedr} rZ r% r% r& r� O s z/AWSRequestSignerAlgorithmV4._get_signed_headersc C s d� dd� t|�� �D ��d S )Nr6 c S s* g | ]"\}}d � |�� t|��� g��qS )rz )rC r� r; �strip�r� r� �vr% r% r& r� S s �zFAWSRequestSignerAlgorithmV4._get_canonical_headers.<locals>.<listcomp>�rC r� �itemsrZ r% r% r& �_get_canonical_headersR s ��z2AWSRequestSignerAlgorithmV4._get_canonical_headersc C sJ |t u r tS |dv r>|r8t|d�s,t|d�r0tS t|�S tS ntd�S d S )N)�POST�PUT�next�__next__rt )�UnsignedPayloadSentinel�UNSIGNED_PAYLOADrB r� )r" re ri r% r% r& r� V s z-AWSRequestSignerAlgorithmV4._get_payload_hashc C s d� dd� t|�� �D ��S )Nrx c S s0 g | ](\}}d t |dd�t t|�dd�f �qS )z%s=%srt ru �~)r r; r� r% r% r& r� f s ��zCAWSRequestSignerAlgorithmV4._get_request_params.<locals>.<listcomp>r� rX r% r% r& �_get_request_paramsd s �z/AWSRequestSignerAlgorithmV4._get_request_paramsc C s0 d� ||| �|�| �|�| �|�| �||�g�S )Nr6 )rC r� r� r� r� rh r% r% r& r� j s �z2AWSRequestSignerAlgorithmV4._get_canonical_request)rb rc )rb rc N)rb rc N)N)r( r) r* rg rj r� r� r� r� r� r� r� r� r� r� r% r% r% r& r s � � r c @ s e Zd ZdS )r� N)r( r) r* r% r% r% r& r� u s r� c sF e Zd ZdZdddddddddef � fdd� Zdd� Zdd� Z� ZS ) r NTc sx t t| �j|||||||| | | |d� t| �| _| jdkr@t} n | jdkrPt} n td| ��| | j| j | j | d�| _ d S )N) rS rF rH rI rJ rK rL rP rM rN rO r �4z!Unsupported signature_version: %sr^ ) rQ r rR r; �signature_versionr r � ValueErrorrS rF ra �signer)r" rS rF rH rI rJ rK rL rO rP rM rN r� Z signer_clsrT r% r& rR | s* � ��z SignedAWSConnection.__init__c C sX | j j|| j| jd�}|�� D ]4\}}t|tttt f�s t ||t |�f }t |��q |S )N)rE re rf ) r� rg re �actionr� � isinstancer r r9 �bool�PARAMS_NOT_STRING_ERROR_MSG�typer� )r" rE rF r5 r� r% r% r& rW � s � z&SignedAWSConnection.add_default_paramsc C s( | j j||| j| j| jd�\}}||fS )Nr� )r� rj re r� ri )r" rE r[ r% r% r& �pre_connect_hook� s � z$SignedAWSConnection.pre_connect_hook) r( r) r* ra �DEFAULT_SIGNATURE_VERSIONrR rW r� r\ r% r% rT r& r y s �r c @ s e Zd ZdZdd� ZdS )�AWSJsonResponsezU Amazon ECS response class. ECS API uses JSON unlike the s3, elb drivers c C s0 t �| j�}|d }|�d|d �}d||f S )NZ__typer! r$ r3 )�json�loadsr1 r@ )r" �responser# r$ r% r% r& rG � s zAWSJsonResponse.parse_errorN)r( r) r* rk rG r% r% r% r& r� � s r� Fc C s@ |r t �t| �t|�tj��� S t �t| �t|�tj��� S d S r+ )r� r� r �hashlibr � hexdigestr� r� r% r% r& r� � s r� c C s t �t| ���� S r+ )r� r r r� )r� r% r% r& r� � s r� c s* e Zd Zd� fdd� Z� fdd�Z� ZS )r NTc s2 || _ tt| �j|f|||||||d�| �� d S )N)�secretrH rI rJ � api_version�regionrP )rP rQ r rR ) r" rF r� rH rI rJ r� r� rP r4 rT r% r& rR � s ��zAWSDriver.__init__c s t t| ��� }| j|d< |S )NrP )rQ r �_ex_connection_class_kwargsrP )r" r4 rT r% r& r� � s z%AWSDriver._ex_connection_class_kwargs)NTNNNNN)r( r) r* rR r� r\ r% r% rT r& r � s �r )F)1�typingr r r r r r� r� rp r Z simplejsonr� � ImportErrorZlibcloud.utils.py3r r r Zlibcloud.common.baser r r r Zlibcloud.common.typesr r r r r Zlibcloud.utils.xmlr r �__all__r� r� r� r� r r r �objectr] r r r� r r� r� r� r r% r% r% r& �<module> sH >!3l5
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка