File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/storage/drivers/__pycache__/azure_blobs.cpython-310.pyc
Back
o ;jݩ � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZmZ d dl m Z m Z m Z m Z mZmZ d dlmZ d dlmZ d dlmZmZ d dlmZ d d lmZmZm Z d d l m Z m Z m Z m!Z!m"Z"m#Z# d Z$e%e �&d d ��d d Z'e%e �&dd ��d d Z(e%e �&dd��Z)dZ*dZ+dZ,dZ-dZ.e/e �&dd��Z0e/e �&dd��Z1G dd � d �Z2G d d � d �Z3G d d � d e�Z4G d!d"� d"e�Z5G d#d$� d$e �Z6dS )%� N)�Literal)�datetime� timedelta)�ET�b�httplib�tostring�urlquote� urlencode)�fixxpath)�read_in_chunks)�AzureConnection� AzureActiveDirectoryConnection)� LibcloudError)�Object� Container� StorageDriver)�ObjectDoesNotExistError�ObjectHashMismatchError�ContainerIsNotEmptyError�InvalidContainerNameError�ContainerDoesNotExistError�ContainerAlreadyExistsError�d Z#LIBCLOUD_AZURE_UPLOAD_CHUNK_SIZE_MB�4i Z%LIBCLOUD_AZURE_DOWNLOAD_CHUNK_SIZE_MBZ#LIBCLOUD_AZURE_LEASE_PERIOD_SECONDS�60zblob.core.windows.netzblob.core.chinacloudapi.cnzblob.core.usgovcloudapi.netz!privatelink.blob.core.windows.netz%Y-%m-%dT%H:%M:%SZZ,LIBCLOUD_AZURE_STORAGE_CDN_URL_START_MINUTES�5Z+LIBCLOUD_AZURE_STORAGE_CDN_URL_EXPIRY_HOURSZ24c @ s e Zd ZdZdS )�AuthTypeZazureADN)�__name__� __module__� __qualname__ZAZURE_AD� r! r! �X/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/storage/drivers/azure_blobs.pyr M s r c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �AzureBlobLeasezI A class to help in leasing an azure blob and renewing the lease c C s& || _ || _|| _d| _ddi| _dS )aL :param driver: The Azure storage driver that is being used :type driver: :class:`AzureStorageDriver` :param object_path: The path of the object we need to lease :type object_path: ``str`` :param use_lease: Indicates if we must take a lease or not :type use_lease: ``bool`` N�comp�lease)� object_path�driver� use_lease�lease_id�params)�selfr' r& r( r! r! r" �__init__V s zAzureBlobLease.__init__c C sR | j du rdS d| j dd�}| jjj| j|| jdd�}|jtjkr't d| d��dS ) zN Renew the lease if it is older than a predefined time period N�renewr )�x-ms-lease-action� x-ms-lease-id�x-ms-lease-duration�PUT��headersr* �method�Unable to obtain lease�r' � r) r' � connection�requestr& r* �statusr �OKr �r+ r3 �responser! r! r" r- g s � � �zAzureBlobLease.renewc C s | j r | j |d< dS dS )z4 Update the lease id in the headers r/ N)r) )r+ r3 r! r! r" �update_headers{ s �z AzureBlobLease.update_headersc C sf | j s| S ddd�}| jjj| j|| jdd�}|jtjkr | S |jtj kr+t d| d��|j d | _ | S ) N�acquirer )r. r0 r1 r2 r5 r6 r/ ) r( r' r8 r9 r& r* r: r � NOT_FOUND�CREATEDr r3 r) r< r! r! r" � __enter__� s � zAzureBlobLease.__enter__c C sP | j d u rd S d| j d�}| jjj| j|| jdd�}|jtjkr&t d| d��d S )N�release)r. r/ r1 r2 zUnable to release leaser6 r7 )r+ �type�value� tracebackr3 r= r! r! r" �__exit__� s � �zAzureBlobLease.__exit__N) r r r �__doc__r, r- r> rB rG r! r! r! r" r# Q s r# c �0 e Zd ZdZ� fdd�Z� fdd�ZdZ� ZS )�AzureBlobsConnectionaJ Represents a single connection to Azure Blobs. The main Azure Blob Storage service uses a prefix in the hostname to distinguish between accounts, e.g. ``theaccount.blob.core.windows.net``. However, some custom deployments of the service, such as the Azurite emulator, instead use a URL prefix such as ``/theaccount``. To support these deployments, the parameter ``account_prefix`` must be set on the connection. This is done by instantiating the driver with arguments such as ``host='somewhere.tld'`` and ``key='theaccount'``. To specify a custom host without an account prefix, e.g. to connect to Azure Government or Azure China, the driver can be instantiated with the appropriate storage endpoint suffix, e.g. ``host='blob.core.usgovcloudapi.net'`` and ``key='theaccount'``. :param account_prefix: Optional prefix identifying the storage account. Used when connecting to a custom deployment of the storage service like Azurite or IoT Edge Storage. :type account_prefix: ``str`` c �$ |� dd �| _t� j|i |�� d S �N�account_prefix��poprM �superr, �r+ �args�kwargs�� __class__r! r" r, � � z AzureBlobsConnection.__init__c �( t � �|�}| jd urd�| j|�}|S �Nz/{}{}�rP �morph_action_hookrM �format�r+ �actionrT r! r" rZ � � z&AzureBlobsConnection.morph_action_hook� 2018-11-09�r r r rH r, rZ � API_VERSION� __classcell__r! r! rT r" rJ � s rJ c rI )�#AzureBlobsActiveDirectoryConnectiona� Represents a single connection to Azure Blobs. The main Azure Blob Storage service uses a prefix in the hostname to distinguish between accounts, e.g. ``theaccount.blob.core.windows.net``. However, some custom deployments of the service, such as the Azurite emulator, instead use a URL prefix such as ``/theaccount``. To support these deployments, the parameter ``account_prefix`` must be set on the connection. This is done by instantiating the driver with arguments such as ``host='somewhere.tld'`` and ``key='theaccount'``. To specify a custom host without an account prefix, e.g. to connect to Azure Government or Azure China, the driver can be instantiated with the appropriate storage endpoint suffix, e.g. ``host='blob.core.usgovcloudapi.net'`` and ``key='theaccount'``. This connection is similar to AzureBlobsConnection, but uses Azure Active Directory to authenticate :param account_prefix: Optional prefix identifying the storage account. Used when connecting to a custom deployment of the storage service like Azurite or IoT Edge Storage. :type account_prefix: ``str`` c rK rL rN rQ rT r! r" r, � rV z,AzureBlobsActiveDirectoryConnection.__init__c rW rX rY r\ rT r! r" rZ � r^ z5AzureBlobsActiveDirectoryConnection.morph_action_hookr_ r` r! r! rT r" rc � s rc c sf e Zd ZdZdZeZdZdZ dE� fdd � Z d d � Z d d � Z dd� Z dd� Z dd� Zdd� ZdFdd�Zdd� Zdd� Zed fd ed fd d �Zd!d"� Zd#d$� Zd%d&� Zd'd(� Z dGd)d*�ZdHd+d,�Z dId-d.�Z dFd/d0�Z d1d2� Z d3d4� Z dJd5d6�Z dJd7d8�Z!d9d:� Z"d;d<� Z#d=d>� Z$ dKd?d@�Z%dAdB� Z&dCdD� Z'� Z(S )L�AzureBlobsStorageDriverzMicrosoft Azure (blobs)zhttp://windows.azure.com/�md5FNT�defaultc s` || _ || _|| _| | _|| _| jdkrt| _nt�t |��}t � j d|||||d�| �� d S )N�azureAd)�key�secret�secure�host�portr! ) �_host� _tenant_id� _identity�_cloud_environment� _auth_typerc � connectionCls�base64� b64decoder rP r, ) r+ rh ri rj rk rl � tenant_id�identityZ auth_type�cloud_environmentrS rT r! r" r, � s "z AzureBlobsStorageDriver.__init__c s� i }� j dkr� j|d< � j|d< � j|d< � jd u r&d�� jt�|d< |S zt� fdd�t t t fD ��}W n t y? Y n w d�� j|�|d< |S � j|d < |S ) Nrg ru rv rw z{}.{}rk c 3 s � | ] }� j �|�r|V qd S �N)rm �endswith)�.0� host_suffix�r+ r! r" � <genexpr>$ s � � �zFAzureBlobsStorageDriver._ex_connection_class_kwargs.<locals>.<genexpr>rM ) rq rn ro rp rm r[ rh �AZURE_STORAGE_HOST_SUFFIX�next� AZURE_STORAGE_HOST_SUFFIX_CHINA�$AZURE_STORAGE_HOST_SUFFIX_GOVERNMENT�%AZURE_STORAGE_HOST_SUFFIX_PRIVATELINK� StopIteration)r+ rS r{ r! r| r" �_ex_connection_class_kwargs s, � � � z3AzureBlobsStorageDriver._ex_connection_class_kwargsc C s� |� tdd��}|�tdd��}|�tdd��}|� tdd��|� tdd��|� tdd��|� tdd��|� td d��|� td d��d �i d �}|d rV|d �dd�|d < |durit|�D ] }|j|d |j< q^t||| d�S )z� Converts a container XML node to a container instance :param node: XML info of the container :type node: :class:`xml.etree.ElementTree.Element` :return: A container instance :rtype: :class:`Container` �Name�Zxpath� Properties�Metadata�Url� Last-Modified�Etag� LeaseStatus� LeaseState� LeaseDuration�r: �stateZduration)�url� last_modified�etagr% � meta_datar� �"� Nr� ��name�extrar' )�findtextr �find�replace�list�text�tagr )r+ �noder� �props�metadatar� �metar! r! r" �_xml_to_container: s$ �� z)AzureBlobsStorageDriver._xml_to_containerc C s� |j }| jrdnd}d�||jj|jj�|d |d |�dd�|�dd�|�d d�d �i d �}|j �� D ]\}}|�d �rJ|� d �d }||d |< q4t ||| d�S )a( Converts a HTTP response to a container instance :param container_name: Name of the container :type container_name: ``str`` :param response: HTTP Response :type node: L{} :return: A container instance :rtype: :class:`Container` �https�http� {}://{}{}r� � last-modified�x-ms-lease-statusN�x-ms-lease-stater0 r� )r� r� r� r% r� � x-ms-meta-� r� r� ) r3 rj r[ r8 rk r] �get�items� startswith�splitr )r+ �container_namer= r3 �schemer� rh rE r! r! r" �_response_to_container` s" �� �z.AzureBlobsStorageDriver._response_to_containerc C sh |� tdd��}|�tdd��}|�tdd��}|� tdd��}t|� tdd���}|� tdd��||� tdd��|� td d��|� td d��|� tdd��|� td d��|� td d��|� td d��d�|� tdd��|� tdd��|� tdd��d� }|d r�t�t�t|d ���} | � d�} | |d< i } |dur�t |�D ]} | j | | j < q�t |||| ||| d�S )a0 Converts a BLOB XML node to an object instance :param container: Instance of the container holding the blob :type: :class:`Container` :param blob: XML info of the blob :type blob: L{} :return: An object instance :rtype: :class:`Object` r� r� r� r� r� �Content-Lengthz Content-Type� Content-MD5r� r� r� r� r� r� zContent-EncodingzContent-LanguageZBlobType) � content_typer� �md5_hashr� r� �hashr% �content_encoding�content_language� blob_typer� �asciiN)r� �sizer� r� r� � containerr' )r� r r� �int�binascii�hexlifyrs rt r �decoder� r� r� r ) r+ r� �blobr� r� r� r� r� r� rE r� r� r! r! r" �_xml_to_object� sH �� �z&AzureBlobsStorageDriver._xml_to_objectc C s |j }t|d �}|d }| jrdnd}d�||jj|jj�||�dd�|�dd�|�d d�|�d d�|d |�d d�|�d d�|�dd�d�|d d� }|d rft� t � t |d ���} | � d�} | |d< i } |j �� D ]\} } | �d�r�| �d�d } | | | < qmt||||| || d�S )a� Converts a HTTP response to an object (from headers) :param object_name: Name of the object :type object_name: ``str`` :param container: Instance of the container holding the blob :type: :class:`Container` :param response: HTTP Response :type node: L{} :return: An object instance :rtype: :class:`Object` zcontent-lengthr� r� r� r� � content-md5Nz content-type�content-language�content-encodingr� r� r� r0 r� �x-ms-blob-type) r� r� r� r� r� r� r� r% r� r� r� r� r� �r� r� r� r� r� r� r' )r3 r� rj r[ r8 rk r] r� r� r� rs rt r r� r� r� r� r ) r+ � object_namer� r= r3 r� r� r� r� rE r� rh r! r! r" �_response_to_object� sH �� ��z+AzureBlobsStorageDriver._response_to_objectc c s� � dt dd�} | j�d|�}|jtjkr td|j | d��|�� }|�t dd ��}|� t d d ��}|D ]}| � |�V q4|� d �|d < |d sJd S q)zF @inherits: :class:`StorageDriver.iterate_containers` r� r� )r$ � maxresults�includeT�/�Unexpected status code: %sr6 Z Containersr� r � NextMarker�markerN) �RESPONSES_PER_REQUESTr8 r9 r: r r; r � parse_bodyr� r �findallr� r� )r+ r* r= �bodyZ containersr� r! r! r" �iterate_containers� s$ �� �z*AzureBlobsStorageDriver.iterate_containersc c s� � | � ||�}ddtdd�}|r||d< | �|�} | jj||d�}|jtjkr0td| |j d ��|jtj kr?t d |j | d ��|� � }|� td d ��}|�tdd ��}|D ] } | �|| �V qU|�d�|d< |d sldS q)zM @inherits: :class:`StorageDriver.iterate_container_objects` r� r� r� )�restyper$ r� r� �prefixT)r* N�rE r' r� r� r6 ZBlobsr� ZBlobr� r� )Z_normalize_prefix_argumentr� �_get_container_pathr8 r9 r: r r@ r r� r; r r� r� r r� r� r� ) r+ r� r� Z ex_prefixr* �container_pathr= r� Zblobsr� r! r! r" �iterate_container_objects s6 � � � �z1AzureBlobsStorageDriver.iterate_container_objectsc C sj ddi}d| }| j j||dd�}|jtjkr td| | |d��|jtjkr/td|j | d ��| �||�S ) zA @inherits: :class:`StorageDriver.get_container` r� r� �/%s�HEAD�r* r4 zContainer %s does not exist)r' r� r� r6 ) r8 r9 r: r r@ r r; r r� �r+ r� r* r� r= r! r! r" � get_container: s � z%AzureBlobsStorageDriver.get_containerc C sT | j |d�}| �||�}| jj|dd�}|jtjkr#| �|||�}|S td| |d��)z> @inherits: :class:`StorageDriver.get_object` )r� r� �r4 N�rE r' r� ) r� �_get_object_pathr8 r9 r: r r; r� r )r+ r� r� r� r& r= �objr! r! r" � get_objectO s z"AzureBlobsStorageDriver.get_object�GET� ex_method)r� r1 �DELETEc C s( | � |j|j�}t�� }|ttd� }|t|d� }|dkr!d}n |dkr(d}nd}|�t�|�t�|| j r8dnd | j j d d �} d � | d | d | d d� | j|�dd| d | d | d ddddddf�} t�t�| j| �d�tj��� ��d�| d< dj | j r�dnd| jj| jj| j� |�t | �d�S )a Return a SAS URL that enables reading the given object. :param obj: Object instance. :type obj: :class:`Object` :param ex_expiry: The number of hours after which the URL expires. Defaults to 24 hours. :type ex_expiry: ``float`` :param ex_method: The HTTP method for which the URL is valid. Defaults to "GET". :type ex_method: ``str`` :return: A SAS URL for the object. :rtype: ``str`` )�minutes)�hoursr1 Zwcr� �d�rr� z http,httpsr )�st�se�sp�spr�sv�sr� r� r� r� z /blob/{}{}r� r� r� r� �utf-8�sigz,{scheme}://{host}:{port}{action}?{sas_token}r� )r� rk rl r] Z sas_token) r� r� r� r �utcnowr �#AZURE_STORAGE_CDN_URL_START_MINUTES�strftime�!AZURE_STORAGE_CDN_URL_DATE_FORMATrj rr ra �joinr[ rh rs � b64encode�hmac�newri �encode�hashlib�sha256�digestr� r8 rk rl rZ r ) r+ r� Z ex_expiryr� r& �now�startZexpiryr� r* Zstring_to_signr! r! r" �get_object_cdn_url_ s\ � ���� �z*AzureBlobsStorageDriver.get_object_cdn_urlc C s d|j S )z� Return a container path :param container: Container instance :type container: :class:`Container` :return: A path for this container. :rtype: ``str`` r� )r� )r+ r� r! r! r" r� � s z+AzureBlobsStorageDriver._get_container_pathc C s" | � |�}t|�}d�||�}|S )a Return an object's CDN path. :param container: Container instance :type container: :class:`Container` :param object_name: Object name :type object_name: :class:`str` :return: A path for this object. :rtype: ``str`` z{}/{})r� r r[ )r+ r� r� Z container_urlZobject_name_cleanedr& r! r! r" r� � s z(AzureBlobsStorageDriver._get_object_pathc C s� ddi}d| }| j j||dd�}|jtjkr | �||�S |jtjkr*td|| d��|jtjkr7t d|| d��t d |j | d ��) zD @inherits: :class:`StorageDriver.create_container` r� r� r� r1 r� zgContainer with this name already exists. The name must be unique among all the containers in the system�rE r� r' z+Container name contains invalid characters.r� r6 ) r8 r9 r: r rA r� �CONFLICTr � BAD_REQUESTr r r� r! r! r" �create_container� s$ � �z(AzureBlobsStorageDriver.create_containerc C sp |� � D ] }td|j| d��ddi}| �|�}| jj||dd�}|jtjkr(dS |jtj kr6t d| |jd ��d S ) zD @inherits: :class:`StorageDriver.delete_container` z1Container must be empty before it can be deleted.r r� r� r� r� TNr� F) Ziterate_objectsr r� r� r8 r9 r: r �ACCEPTEDr@ r )r+ r� r� r* r� r= r! r! r" �delete_container� s � z(AzureBlobsStorageDriver.delete_containerc C sH | � |j|j�}| jj|ddd�}| j|| j|||j|||d�tj d�S )zC @inherits: :class:`StorageDriver.download_object` TN)�raw�data)r� r= �destination_path�overwrite_existing�delete_on_failure�r� �callbackr= Zcallback_kwargsZsuccess_status_code) r� r� r� r8 r9 � _get_object� _save_objectr= r r; )r+ r� r r r �obj_pathr= r! r! r" �download_object� s ��z'AzureBlobsStorageDriver.download_objectc C sJ | � |j|j�}| jj|dddd�}|�t�}| j|t|||d�t j d�S )zM @inherits: :class:`StorageDriver.download_object_as_stream` r� T)r4 �streamr ��iterator� chunk_sizer ) r� r� r� r8 r9 � iter_content�AZURE_DOWNLOAD_CHUNK_SIZEr r r r; )r+ r� r r r= r r! r! r" �download_object_as_stream s �z1AzureBlobsStorageDriver.download_object_as_streamc C st | j ||d� | �|j|j�}d| �||�i}| jj||dd d�} tjtj g} | j || j | || j |||dd�| d�S )N�� start_bytes� end_bytes� x-ms-rangeT)r3 r r )r� r= r r r Zpartial_downloadr ) � _validate_start_and_end_bytesr� r� r� �_get_standard_range_strr8 r9 r r; �PARTIAL_CONTENTr r r= ) r+ r� r r r r r r r3 r= �success_status_codesr! r! r" �download_object_range& s$ ��z-AzureBlobsStorageDriver.download_object_rangec C st | j ||d� | �|j|j�}d| �||�i}| jj|d|ddd�}|�t�}t j t j g} | j |t |||d�| d�S )Nr r! r� T)r4 r3 r r r r )r" r� r� r� r# r8 r9 r r r r; r$ r r ) r+ r� r r r r r3 r= r r% r! r! r" � download_object_range_as_streamJ s � �z7AzureBlobsStorageDriver.download_object_range_as_streamc C s~ d} |r| � � } d} d} g } | pi } |�| � ddi}t|tdd�D ]s}t|�}t|�}| |7 } |r7| �|� | � � }|�|� t�t|� � ��}|� d�| d < t |�| d < t�td | ��}|� d�}||d < | � |� |� � | jj|d || |d�}|jtjkr�|�� td| |jf | d��| d7 } q"|r�t�t| � � ��} | � d�} | j|| || ||| ||d� }d|jd< || | d�S )zV Uploads data from an iterator in fixed sized chunks to Azure Storage Nr r� r$ �blockT)Z fill_sizer� r� r� z%10dZblockidr1 )r4 r r3 r* z"Error uploading chunk %d. Code: %dr6 ) r& �chunksr% r3 r� r� � data_hashr� � file_pathr� )r= r* �bytes_transferred)�_get_hash_functionr> r �AZURE_UPLOAD_CHUNK_SIZEr �len�updaters r� r r� �str�appendr- r8 r9 r: r rA � parse_errorr �_commit_blocksr3 )r+ r r& r% r� r� r� r+ � verify_hashr3 r* r, �countr) r* r �content_lengthZ chunk_hash�block_idZrespr= r! r! r" �_upload_in_chunks^ sl � � � �z)AzureBlobsStorageDriver._upload_in_chunksc C s t �d�} |D ] } t �| d�} t| �| _qt| �} ddi}|p i }|�|� |�� | �||| �|d< |dur;||d< | � ||� | � � }|� | � d�� t �t|�� ��}|�d�|d < t| �|d < | �|�}| jj|| ||d d �}|jtjkrtd | d��|S )z3 Makes a final commit of the data. Z BlockListZ Uncommittedr$ Z blocklistzx-ms-blob-content-typeNzx-ms-blob-content-md5r� r� r� r1 )r r* r3 r4 zError in blocklist commitr6 )r ZElementZ SubElementr1 r� r r> r- Z_determine_content_type�_update_metadatar- r0 r� rs r� r r r� r/ � _fix_headersr8 r9 r: r rA r )r+ r& r) r% r3 r� r� r* r� r+ �rootr8 �partr r* r= r! r! r" r4 � s6 � � z&AzureBlobsStorageDriver._commit_blocksc K sp |r t dd�|�� � ��t�|�j} t|d��} | j||||||| || d� W d � S 1 s1w Y dS )z� Upload an object currently located on a disk. @inherits: :class:`StorageDriver.upload_object` :param ex_use_lease: Indicates if we must take a lease before upload :type ex_use_lease: ``bool`` �%Support for arguments was removed: %s�, �rb) r� r� r� r5 r( r3 � blob_sizer+ r N)� ValueErrorr� �keys�os�stat�st_size�open� _put_object) r+ r+ r� r� r5 r� r3 � ex_use_lease�deprecated_kwargsrA Zfobjr! r! r" � upload_object� s$ � �$�z%AzureBlobsStorageDriver.upload_objectc K s4 |r t dd�|�� � ��| j||||||d|d�S )z� @inherits: :class:`StorageDriver.upload_object_via_stream` :param ex_use_lease: Indicates if we must take a lease before upload :type ex_use_lease: ``bool`` r> r? N)r� r� r� r5 r( r3 rA r )rB r� rC rH ) r+ r r� r� r5 r� r3 rI rJ r! r! r" �upload_object_via_stream! s ��z0AzureBlobsStorageDriver.upload_object_via_streamc C sP | � |j|j�}| jj|dd�}|jtjkrdS |jtjkr&t d| |jd��dS )zA @inherits: :class:`StorageDriver.delete_object` r� r� TNr� F) r� r� r� r8 r9 r: r r r@ r )r+ r� r& r= r! r! r" � delete_objectB s z%AzureBlobsStorageDriver.delete_objectc C sD d}i }|� � D ]\}}|�� }||v r||d| < q|||< q|S )z� Update common HTTP headers to their equivalent in Azure Storage :param headers: The headers dictionary to be updated :type headers: ``dict`` )z cache-controlr� r� z x-ms-blob-%s)r� �lower)r+ r3 Zto_fix�fixedrh rE Z key_lowerr! r! r" r; P s z$AzureBlobsStorageDriver._fix_headersc C s* t |�� �D ] \}}d| }|||< qdS )z� Update the given metadata in the headers :param headers: The headers dictionary to be updated :type headers: ``dict`` :param meta_data: Metadata key value pairs :type meta_data: ``dict`` z x-ms-meta-%sN)r� r� )r+ r3 r� rh rE r! r! r" r: i s �z(AzureBlobsStorageDriver._update_metadatac C sF |pi }|� dd�} |� di �} | �||�} t| | | ��<} |dur4|tkr4| j|| | || || ||d� }n| j|| | | || |||d� }|d }|d }|d }|j}W d � n1 s[w Y |jtj krot d |j | d ��|� d �}|r�t � t �t|���}|�d �}n |r�|r�||kr�td || d��t|||d d| || d�S )zU Control function that does the real job of uploading data to a blob r� Nr� ) r r& r% rA r� r3 r� r� r+ ) r r& r% r� r3 r� r� r+ r5 r= r, r* z&Unexpected status code, status_code=%sr6 r� r� z MD5 hash checksum does not match)rE r� r' r� r� )r� r� r# r. �_upload_directlyr9 r3 r: r rA r r� r� rs rt r r� r r )r+ r� r� r r� r5 r3 rA r+ r( r� r� r& r% Z result_dictr= r, r* Z server_hashr! r! r" rH w st � � � � ��z#AzureBlobsStorageDriver._put_objectc C sH | pi } |� | � | �| |� t|�| d< d| d< | j|||||| d�S )Nr� Z BlockBlobr� )r� r+ r� Z request_pathr r3 )r> r: r1 Z_upload_object) r+ r r& r% rA r� r� r� r+ r3 r! r! r" rP � s �z(AzureBlobsStorageDriver._upload_directlyc C sZ | � |j|j�}ddi}i }| �||� | jj|d||d�}|jtjkr+|� d� dS dS )z� Set metadata for an object :param obj: The blob object :type obj: :class:`Object` :param meta_data: Metadata key value pairs :type meta_data: ``dict`` r$ r� r1 )r4 r* r3 zSetting metadataN) r� r� r� r: r8 r9 r: r r; r3 )r+ r� r� r& r* r3 r= r! r! r" �ex_set_object_metadata� s � �z.AzureBlobsStorageDriver.ex_set_object_metadata)NTNNNNNrf )NN)FTrx )NFT)TNNF)NTNNNF))r r r r� ZwebsiterJ rr Z hash_typeZsupports_chunked_encodingr, r� r� r� r� r� r� r� r� r� �"AZURE_STORAGE_CDN_URL_EXPIRY_HOURSr r r� r� r r r r r& r' r9 r4 rK rL rM r; r: rH rP rQ rb r! r! rT r" rd � s� � )&$9; (� �M � � $d= �, �! �V rd )7rD r� rs r r� �typingr r r Zlibcloud.utils.py3r r r r r r Zlibcloud.utils.xmlr Zlibcloud.utils.filesr Zlibcloud.common.azurer r Zlibcloud.common.typesr Zlibcloud.storage.baser r r Zlibcloud.storage.typesr r r r r r r� r� �getenvr. r ZAZURE_LEASE_PERIODr~ r� r� r� r� �floatr� rR r r# rJ rc rd r! r! r! r" �<module> sF � � �P%(
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings