File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/storage/drivers/__pycache__/atmos.cpython-310.pyc
Back
o ;j�B � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZm Z m Z m Z m Z m Z mZ d dlmZmZ d dlmZ d dlmZ d dlmZmZmZmZ d dlm Z m Z m Z m Z d d � Z G d d � d e�Z!G d d� de�Z"G dd� de�Z#G dd� de�Z$dS )� N)�FileIO)�b�next�httplib�urlparse�urlquote� urlencode� urlunquote)� XmlResponse�ConnectionUserAndKey)�read_in_chunks)� LibcloudError)� CHUNK_SIZE�Object� Container� StorageDriver)�ObjectDoesNotExistError�ContainerIsNotEmptyError�ContainerDoesNotExistError�ContainerAlreadyExistsErrorc C s d� dd� | �d�D ��S )N� c S s g | ]}|r|�qS � r ��.0�xr r �R/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/storage/drivers/atmos.py� <listcomp>$ s z collapse.<locals>.<listcomp>)�join�split)�sr r r �collapse# s r c s e Zd Zd� fdd� Z� ZS )� AtmosErrorNc s t � j||d� || _d S )N)�value�driver)�super�__init__�code)�selfr& �messager# �� __class__r r r% ( 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 r+ )�statusr �OK�CREATED� NO_CONTENT�PARTIAL_CONTENT)r' r r r �success. s �zAtmosResponse.successc C sB | � � }|d u r d S t|�d�j�}|�d�j}t||| jjd��)NZCode�Message)r& r( r# )Z parse_body�int�find�textr! � connectionr# )r' �treer& r( r r r � parse_error6 s zAtmosResponse.parse_errorN)r, r- r. r6 r= r r r r r0 - s r0 c @ s( e Zd ZeZdd� Zdd� Zdd� ZdS )�AtmosConnectionc C sN | j |d< t�dt�� �|d< |d |d< d|vr d|d< d|vr%d|d< |S ) Nz x-emc-uid�%a, %d %b %Y %H:%M:%S GMT�Datez x-emc-date� Content-Typezapplication/octet-streamZAcceptz*/*)Zuser_id�time�strftime�gmtime)r' �headersr r r �add_default_headersD s z#AtmosConnection.add_default_headersc C s | � ||�|d< ||fS )Nzx-emc-signature)�_calculate_signature)r' �paramsrE r r r �pre_connect_hookQ s z AtmosConnection.pre_connect_hookc C s t | j�}| jj}|�|�r|t|�d � }|r,t|�tu r$t|� � �}|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 c s " z8AtmosConnection._calculate_signature.<locals>.<listcomp>c S s | d S )Nr r )r r r r �<lambda>d s z6AtmosConnection._calculate_signature.<locals>.<lambda>)�keyrA � �Ranger@ c S � g | ] \}}|d t |� �qS )�:)r rL r r r r m � � zutf-8) r �actionr# �pathrK �len�type�dict�list�itemsr �lower�sort�method�get�extendr �base64� b64decoderP �hmac�newr �hashlib�sha1�digest� b64encode�decode)r' rH rE Z pathstringZ driver_pathZxhdrs� signaturerP r r r rG V s, � z$AtmosConnection._calculate_signatureN)r, r- r. r0 Z responseClsrF rI rG r r r r r> A s r> c s e Zd ZeZdZdZdZdZdZ dZ dZ d3� fdd� Z dd � Z d d � Zd d � Zdd� Zdd� Z d4dd�Zd5dd�Z d6dd�Zd7dd�Zdd � Zd d � Zd8d d �Zd!d"� Zd7d#d$�Zd%d&� Zd'd(� Z d)d*� Z e d+d,� �Z d-d.� Z d/d0� Z!d5d1d2�Z"� Z#S )9� AtmosDriverNZatmosTzhttp://atmosonline.com/i�: c s" |p| j }t� �|||||� d S r+ )�hostr$ r% )r' rP �secret�securern �portr) r r r% � s zAtmosDriver.__init__c c sP � | j �| �d��}| j|jdd�}|D ]}d|d i}t|d || �V qd S )NrQ � 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 sr | � |�d }z| j�|�}W n ty' } z |jdkr � t|| |��d }~ww | �|�}d|d i}t||| �S )Nz/?metadata/system�� ru �objectid)ry r; rx r! r& r � _emc_metar )r' �container_namerX r| �e�metar r r r � get_container� s �� zAtmosDriver.get_containerc C s^ | � |�d }z | jj|dd� W n ty) } z |jdkr � t|| |��d }~ww | �|�S )N�/�POST�r` i� )ry r; rx r! r& r r� )r' r� rX r� r r r �create_container� s �� z AtmosDriver.create_containerc C sz z| j j| �|j�d dd� W dS ty< } z |jdkr%t|| |j��|jdkr1t|| |j��W Y d }~dS d }~ww )Nr� �DELETEr� r� i� T)r; rx ry rw r! r& r r )r' � containerr� r r r �delete_container� s � ���z AtmosDriver.delete_containerc C s� | � |�}| �|�}| �|�d | }z | j�|d �}| �|�}| j�|d �}| �|�}W n tyG } z | jdkr=� t| | |��d } ~ ww t � |d d�} t � d| �} |d | d �} |� d d �} t |t|d �| | ||| �S ) Nr� �?metadata/system�?metadata/userr� �mtimez%Y-%m-%dT%H:%M:%SZr? r� )ru � last_modified�md5rQ �size)r� �_clean_object_namery r; rx r� r! r& r rB �strptimerC �popr r8 ) r' r� � object_namer� �object_name_cleanedrX r| Z system_meta� user_metar� r� r � data_hashr r r � get_object� s6 �� �zAtmosDriver.get_objectc C s@ d}|pi }| � |�}| �|j�d | } |�dd �} z | j�| d � W n ty? } z| jdkr3� d}W Y d } ~ nd } ~ ww | j|| | |i |d�} | d } |d u rVi }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_pathZrequest_methodrE � file_path�bytes_transferred� meta_datar� r� �, c S rS ��=��strrL r r r r � rU z-AtmosDriver.upload_object.<locals>.<listcomp>r� � x-emc-meta�r` rE r� �ru r� )r� ry rw ra r; rx r! r& Z_upload_objectr r\ r] r� r )r' r� r� r� r Z verify_hashrE r` r� r� r� r� Z result_dictr� r� r� r| r� r r r � upload_object� s^ ��� � ��zAtmosDriver.upload_objectc C s2 t |t�r t|�}|p i }t�� }t|td�}d} zt|�} W n ty* d} Y nw | � |j d | �} d} |d urB|� dd �} nd } | � | |�} z | j �| d � W n tyn } z|jdkrb� d } W Y d }~nd }~ww | t| � d }|�t| �� t|�}|�d |�� | d �� t| �dkr�| dkr�d | |f |d< d} | j j| | | |d�}| t| �7 } zt|�} W n ty� Y n w t| �dkr�nqp|�� }|d u r�i }n|� di �}||d< d�dd� t|�� �D ��}| j j| d d d|id� | j �| d �}| �|�}|d |d�}t|| ||||| �S )NTr rQ r� r� r� r� r� r� � zmd5=)r� rA z Bytes=%d-%drR )r` �datarE r� r� r� c S rS r� r� rL r r r r N rU z8AtmosDriver.upload_object_via_stream.<locals>.<listcomp>r� r� r� r� r� )� isinstance�file�iterrg r� r r r � StopIterationry rw ra Z_determine_content_typer; rx r! r& rY �updater r[ � hexdigestr r\ r] r� r )r' �iteratorr� r� r rE Z extra_headersr� � generatorr� �chunkrX r` r� r� �endr| r� r� r� r r r �upload_object_via_stream s| � �� �� � � � �z$AtmosDriver.upload_object_via_streamFc C sP | � |jjd |j �}| jj|ddd�}| j|| j|||j|||d�tj d�S )Nr� �GETT�r` �raw)�obj�response�destination_path�overwrite_existing�delete_on_failure�r� �callbackr� Zcallback_kwargsZsuccess_status_code) ry r� rw r; rx � _get_objectZ _save_objectr� r r2 )r' r� r� r� r� rX r� r r r �download_object] s ��zAtmosDriver.download_objectc C sH | � |jjd |j �}| jj|ddd�}| j|t||j|d�tj d�S )Nr� r� Tr� )r� � chunk_sizer� ) ry r� rw r; rx r� r r� r r2 )r' r� r� rX r� r r r �download_object_as_streamq s �z%AtmosDriver.download_object_as_streamc C sh | � |jj�d | �|j� }z | jj|dd� W dS ty3 } z |jdkr(� t|| |j��d }~ww )Nr� r� r� r� T) ry r� rw r� r; rx r! r& r )r' r� rX r� r r r � delete_object} s � ��zAtmosDriver.delete_objectc C s dS )NTr )r' r� r r r �enable_object_cdn� s z AtmosDriver.enable_object_cdnc C s� |r d|j d }n d|jj d |j }| jrd}nd}t|p(tt�� �| 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/objectsru �/rest/namespace/r� �https�http�uidZexpiresrl rQ )r� r� rw rp r� r8 rB �DEFAULT_CDN_TTLrP �append�_cdn_signaturer rX r � urlunparsern )r' r� �expiryZ use_objectrX �protocolrH r r r �get_object_cdn_url� s � z AtmosDriver.get_object_cdn_urlc C sB t �| j�}d�d|�� | j|g�}t�||tj �� � }t � |�S )NrV r� ) rc rd ro r r^ rP re rf rg rh ri rj )r' rX rH r� rP rl r r r r� � s zAtmosDriver._cdn_signaturec C s� |� | �d��}g }|�| �d��D ]+}|� | �d��j}|d ur&||kr&q|�|� | �d��j||� | �d��jd�� q|S )NZ DirectoryListZDirectoryEntry�FileTypeZObjectIDZFilename)rv rZ rw )r9 �_emc_tag�findallr: r� )r' r< rt Zlistingr} r~ Z file_typer r r rz � s ��zAtmosDriver._list_objectsc C s t |�d��S )N�ascii)r �encode)r' rw r r r r� � s z AtmosDriver._clean_object_namec C s | j d t|�d�� S )Nr� r� )rX r r� )r' rX r r r ry � s zAtmosDriver._namespace_pathc C s | j d |�d� S )Nz/rest/objects/r� )rX r� )r' ru 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|�dkri S |�d�}tdd� |D ��S )Nr� rQ r r� c S s g | ]}|� d d��qS )r� r� )r r r r r r � s z)AtmosDriver._emc_meta.<locals>.<listcomp>)rE ra rY r r[ )r' r� r� r r r r� � s zAtmosDriver._emc_metac c s6 � |D ]}d|d i}t |d ddi ||| �V qd S )Nru rv rw r rQ )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� )rE Zregularrs ) Z_normalize_prefix_argumentry rw r; rx rz r{ r� Z _filter_listed_container_objects) r' r� �prefixZ ex_prefixrE rX r| r} Zobjectsr r r �iterate_container_objects� s z%AtmosDriver.iterate_container_objects)NTNN)NTN)NN)FTr+ )NF)$r, r- r. r> Z connectionClsrn rX Zapi_nameZsupports_chunked_encodingZwebsiterw r� r% r� r� r� r� r� r� r� r� r� r� r� r� r� rz r� ry r� � staticmethodr� r� r� r� r/ r r r) r rm u sH $ � ?P � & rm )%re rB rc rg �ior r� Zlibcloud.utils.py3r r r r r r r Zlibcloud.common.baser r Zlibcloud.utils.filesr Zlibcloud.common.typesr Zlibcloud.storage.baser r r r Zlibcloud.storage.typesr r r r r r! r0 r> rm r r r r �<module> s $ 4
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings