Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/storage/drivers/__pycache__/atmos.cpython-39.pyc
Ðазад
a q�hE � @ s4 d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlm Z d dlm Z d dlm Z d d lm Z er�d d l mZ d d lmZ d d lmZmZ d d lmZ d dlmZmZmZmZ d dl m Z m Z m Z m Z dd� Z!G dd� de�Z"G dd� de�Z#G dd� de�Z$G dd� de�Z%dS )� N)�PY3)�b)�httplib)�next)�urlparse)� urlencode)�urlquote)� urlunquote)�FileIO)�read_in_chunks)�ConnectionUserAndKey� XmlResponse)� LibcloudError)�Object� Container� StorageDriver� CHUNK_SIZE)�ContainerAlreadyExistsError�ContainerDoesNotExistError�ContainerIsNotEmptyError�ObjectDoesNotExistErrorc C s d� dd� | �d�D ��S )N� c S s g | ] }|r|�qS � r ��.0�xr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/storage/drivers/atmos.py� <listcomp>, � z collapse.<locals>.<listcomp>)�join�split)�sr r r �collapse+ s r" c s e Zd Zd� fdd� Z� ZS )� AtmosErrorNc s t t| �j||d� || _d S )N)�value�driver)�superr# �__init__�code)�selfr( �messager% �� __class__r r r' 0 s zAtmosError.__init__)N)�__name__� __module__� __qualname__r' � __classcell__r r r+ r r# / s r# c @ s e Zd Zdd� Zdd� ZdS )� AtmosResponsec C s | j tjtjtjtjfv S �N)�statusr �OK�CREATED� NO_CONTENT�PARTIAL_CONTENT)r) r r r �success6 s �zAtmosResponse.successc C sF | � � }|d u rd S t|�d�j�}|�d�j}t||| jjd��d S )NZCode�Message)r( r* r% )Z parse_body�int�find�textr# � connectionr% )r) �treer( r* r r r � parse_error: s �zAtmosResponse.parse_errorN)r- r. r/ r8 r? r r r r r1 5 s r1 c @ s( e Zd ZeZdd� Zdd� Zdd� ZdS )�AtmosConnectionc C sN | j |d< t�dt�� �|d< |d |d< d|vr:d|d< d|vrJd|d< |S ) Nz x-emc-uid�%a, %d %b %Y %H:%M:%S GMT�Datez x-emc-date� Content-Typezapplication/octet-stream�Acceptz*/*)Zuser_id�time�strftime�gmtime)r) �headersr r r �add_default_headersI s � z#AtmosConnection.add_default_headersc C s | � ||�|d< ||fS )Nzx-emc-signature)�_calculate_signature)r) �paramsrH r r r �pre_connect_hookV s z AtmosConnection.pre_connect_hookc C s t | j�}| jj}|�|�r,|t|�d � }|rXt|�tu rHt|� � �}|dt |� 7 }|� � }dd� t|� � �D �}|j dd� d� | j |�dd�|�d d�|�d d�|g}|�d d� |D �� d �|�}t�| j�}t�t|�t|�tj��� }t�t|���d �S )N�?c S s" g | ]\}}|� d �r||f�qS )zx-emc-)� startswith�r �k�vr r r r f s �z8AtmosConnection._calculate_signature.<locals>.<listcomp>c S s | d S )Nr r )r r r r �<lambda>h r z6AtmosConnection._calculate_signature.<locals>.<lambda>)�keyrC � �RangerB c S s g | ]\}}|d t |� �qS )�:)r" rO r r r r q r � zutf-8) r �actionr% �pathrN �len�type�dict�list�itemsr �lower�sort�method�get�extendr �base64� b64decoderS �hmac�newr �hashlib�sha1�digest� b64encode�decode)r) rK rH Z pathstringZ driver_pathZxhdrs� signaturerS r r r rJ [ s, � z$AtmosConnection._calculate_signatureN)r- r. r/ r1 Z responseClsrI rL rJ r r r r r@ F s r@ c s� e Zd ZeZdZdZdZdZdZ dZ dZ d3� fdd� Z dd � Z d d � Zd d � Zdd� Zdd� Zd4dd�Zd5dd�Zd6dd�Zd7dd�Zdd � Zd d � Zd8d d �Zd!d"� Zd9d#d$�Zd%d&� Zd'd(� Z d)d*� Z e d+d,� �Z d-d.� Z d/d0� Z!d:d1d2�Z"� Z#S );� AtmosDriverNZatmosTzhttp://atmosonline.com/i�: c s& |p| j }tt| ��|||||� d S r2 )�hostr& rn r' )r) rS �secret�securero �portr+ r r r' � s zAtmosDriver.__init__c c sN | j �| �d��}| j|jdd�}|D ]"}d|d i}t|d || �V q&d S )NrT � directory�� object_type� object_id�id�name)r= �request�_namespace_path� _list_objects�objectr )r) �result�entries�entry�extrar r r �iterate_containers� s �z AtmosDriver.iterate_containersc C s~ | � |�d }z| j�|�}W n< tyZ } z$|jdkr:� t|| |��W Y d }~n d }~0 0 | �|�}d|d i}t||| �S )Nz/?metadata/system�� rv �objectid)rz r= ry r# r( r � _emc_metar )r) �container_namerY r} �e�metar� r r r � get_container� s " �zAtmosDriver.get_containerc C sj | � |�d }z| jj|dd� W n< ty^ } z$|jdkr>� t|| |��W Y d }~n d }~0 0 | �|�S )N�/�POST�ra i� )rz r= ry r# r( r r� )r) r� rY r� r r r �create_container� s "z AtmosDriver.create_containerc C s| z | j j| �|j�d dd� W nV tyv } z>|jdkrJt|| |j��n|jdkrbt|| |j��W Y d }~n d }~0 0 dS )Nr� �DELETEr� r� i� T)r= ry rz rx r# r( r r )r) � containerr� r r r �delete_container� s � $z AtmosDriver.delete_containerc C s� | � |�}| �|�}| �|�d | }z8| j�|d �}| �|�}| j�|d �}| �|�}W n< ty� } z$| jdkrz� t| | |��W Y d } ~ n d } ~ 0 0 t � |d d�} t � d| �} |d | d �} |� d d �} t |t|d �| | ||| �S ) Nr� �?metadata/system�?metadata/userr� �mtimez%Y-%m-%dT%H:%M:%SZrA r� )rv � last_modified�md5rT �size)r� �_clean_object_namerz r= ry r� r# r( r rE �strptimerF �popr r: ) r) r� � object_namer� �object_name_cleanedrY r} Z system_meta� user_metar� r� r� � data_hashr r r � get_object� s2 " ��� �zAtmosDriver.get_objectc C s@ d}|p i }| � |�}| �|j�d | } |�dd �} z| j�| d � W n4 ty~ } z | jdkrf� d}W Y d } ~ n d } ~ 0 0 | j|| | |i |d�} | d } |d u r�i }n |�d i �}| d |d < d � d d� t |� � �D ��}| jj| d dd|id� | j�| d �}| � |�}|d = |d |d�}t || | d |||| �S )N�PUTr� � content_typer� r� r� )r� r� � request_path�request_methodrH � file_path�bytes_transferred� meta_datar� r� �, c S s g | ]\}}|d t |� �qS ��=��strrO r r r r � r z-AtmosDriver.upload_object.<locals>.<listcomp>r� � x-emc-meta�ra rH r� �rv r� )r� rz rx rb r= ry r# r( Z_upload_objectr r] r^ r� r )r) r� r� r� r� Z verify_hashrH ra r� r� r� r� Z result_dictr� r� r� r} r� r r r � upload_object� sP � � �� � �zAtmosDriver.upload_objectc C s@ t |t�rt|�}|pi }t�� }t|td�}d} z t|�} W n tyT d} Y n0 | � |j d | �} d} |d ur�|� dd �} nd } | � | |�} z| j �| d � W n4 ty� } z |jdkrĂ d } W Y d }~n d }~0 0 | t| � d }|�t| �� t|�}|�d |�� | d �� t| �dk�rH| dk�rHd | |f |d< d} | j j| | | |d�}| t| �7 } z t|�} W n t�y� Y �q�Y n0 t| �dkrސq�q�|�� }|d u �r�i }n |� di �}||d< d�dd� t|�� �D ��}| j j| d d d|id� | j �| d �}| �|�}|d |d�}t|| ||||| �S )NTr rT r� r� r� r� r� r� � zmd5=)r� rC z Bytes=%d-%drU )ra �datarH r� r� r� c S s g | ]\}}|d t |� �qS r� r� rO r r r r = r z8AtmosDriver.upload_object_via_stream.<locals>.<listcomp>r� r� r� r� r� )� isinstance�file�iterrh r� r r r � StopIterationrz rx rb Z_determine_content_typer= ry r# r( rZ �updater r\ � hexdigestr r] r^ r� r )r) �iteratorr� r� r� rH � extra_headersr� � generatorr� �chunkrY ra r� r� �endr} r� r� r� r r r �upload_object_via_stream� sz � � �� � �z$AtmosDriver.upload_object_via_streamFc C sP | � |jjd |j �}| jj|ddd�}| j|| j|||j|||d�tj d�S )Nr� �GETT�ra �raw)�obj�response�destination_path�overwrite_existing�delete_on_failure�r� �callbackr� �callback_kwargsZsuccess_status_code) rz r� rx r= ry � _get_objectZ _save_objectr� r r4 )r) r� r� r� r� rY r� r r r �download_objectM s ��zAtmosDriver.download_objectc C sH | � |jjd |j �}| jj|ddd�}| j|t||j|d�tj d�S )Nr� r� Tr� )r� � chunk_sizer� ) rz r� rx r= ry r� r r� r r4 )r) r� r� rY r� r r r �download_object_as_stream] s ��z%AtmosDriver.download_object_as_streamc C sv | � |jj�d | �|j� }z| jj|dd� W n> typ } z&|jdkrN� t|| |j��W Y d }~n d }~0 0 dS )Nr� r� r� r� T) rz r� rx r� r= ry r# r( r )r) r� rY r� r r r � delete_objecti s � $zAtmosDriver.delete_objectc C s dS )NTr )r) r� r r r �enable_object_cdnt s z AtmosDriver.enable_object_cdnc C s� |rd|j d }nd|jj d |j }| jr6d}nd}t|pPtt�� �| j �}d| jfd|fg}|� d | � |||�f� t |�}| j | }t �|| j|d |d f�S ) a Return an object CDN URL. :param obj: Object instance :type obj: :class:`Object` :param expiry: Expiry :type expiry: ``str`` :param use_object: Use object :type use_object: ``bool`` :rtype: ``str`` z /rest/objectsrv �/rest/namespace/r� �https�http�uid�expiresrm rT )r� r� rx rq r� r: rE �DEFAULT_CDN_TTLrS �append�_cdn_signaturer rY r � urlunparsero )r) r� �expiryZ use_objectrY �protocolrK r r r �get_object_cdn_urlw s � z AtmosDriver.get_object_cdn_urlc C sB t �| j�}d�d|�� | j|g�}t�||tj �� � }t � |�S )NrW r� ) rd re rp r r_ rS rf rg rh ri rj rk )r) rY rK r� rS rm r r r r� � s zAtmosDriver._cdn_signaturec C s� |� | �d��}g }|�| �d��D ]V}|� | �d��j}|d urL||krLq$|�|� | �d��j||� | �d��jd�� q$|S )NZ DirectoryListZDirectoryEntry�FileTypeZObjectIDZFilename)rw r[ rx )r; �_emc_tag�findallr< r� )r) r> ru Zlistingr~ r � file_typer r r r{ � s � zAtmosDriver._list_objectsc C s t |�d��S )N�ascii)r �encode)r) rx r r r r� � s z AtmosDriver._clean_object_namec C s | j d t|�d�� S )Nr� r� )rY r r� )r) rY r r r rz � s zAtmosDriver._namespace_pathc C s | j d |�d� S )Nz/rest/objects/r� )rY r� )r) rv r r r � _object_path� s zAtmosDriver._object_pathc C s d| S )Nz{http://www.emc.com/cos/}r )�tagr r r r� � s zAtmosDriver._emc_tagc C s: |j �dd�}t|�dkr i S |�d�}tdd� |D ��S )Nr� rT r r� c S s g | ]}|� d d��qS )r� r� )r r r r r r � r z)AtmosDriver._emc_meta.<locals>.<listcomp>)rH rb rZ r r\ )r) r� r� r r r r� � s zAtmosDriver._emc_metac c s4 |D ]*}d|d i}t |d ddi ||| �V qd S )Nrv rw rx r rT )r )r) r� r~ r �metadatar r r �_entries_to_objects� s z AtmosDriver._entries_to_objectsc C s\ | � ||�}ddi}| �|j�d }| jj||d�}| j|jdd�}| �||�}| �||�S )aO Return a generator of objects for the given container. :param container: Container instance :type container: :class:`Container` :param prefix: Filter objects starting with a prefix. Filtering is performed client-side. :type prefix: ``str`` :param ex_prefix: (Deprecated.) Filter objects starting with a prefix. Filtering is performed client-side. :type ex_prefix: ``str`` :return: A generator of Object instances. :rtype: ``generator`` of :class:`Object` zx-emc-include-meta�1r� )rH Zregularrt ) Z_normalize_prefix_argumentrz rx r= ry r{ r| r� Z _filter_listed_container_objects) r) r� �prefixZ ex_prefixrH rY r} r~ �objectsr r r �iterate_container_objects� s z%AtmosDriver.iterate_container_objects)NTNN)NTN)NN)FT)N)NF)N)NN)$r- r. r/ r@ Z connectionClsro rY Zapi_nameZsupports_chunked_encodingZwebsiterx r� r' r� r� r� r� r� r� r� r� r� r� r� r� r� r{ r� rz r� � staticmethodr� r� r� r� r0 r r r+ r rn x sL � / � O � $ �rn )&rd rh rf rE Zlibcloud.utils.py3r r r r r r r r �ior r� Zlibcloud.utils.filesr Zlibcloud.common.baser r Zlibcloud.common.typesr Zlibcloud.storage.baser r r r Zlibcloud.storage.typesr r r r r" r# r1 r@ rn r r r r �<module> s. 2
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка