File: //usr/lib/python3/dist-packages/duplicity/backends/__pycache__/azurebackend.cpython-310.pyc
o
��`� � @ s� d dl mZ d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z d dl
m Z e� d�Z
dd � ZG d
d � d ejj�Zej�d e� dS )
� )�strN)�config)�log)�BackendException)�fsdecodez)^[a-z0-9](?!.*--)[a-z0-9-]{1,61}[a-z0-9]$c C s t �| �}|duS )z�
Check, whether the given name conforms to the rules as defined in
https://docs.microsoft.com/en-us/rest/api/storageservices/naming-and-referencing-containers--blobs--and-metadata
for valid names.
N)�_VALID_CONTAINER_NAME_RE�match)�namer � r
�A/usr/lib/python3/dist-packages/duplicity/backends/azurebackend.py�_is_valid_container_name$ s
r c @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dS )� AzureBackendz0
Backend for Azure Blob Storage Service
c
C s� t jj�| |� zdd l}dd l}dd l}ddlm} W n ty0 } zt dt
|� ��d }~ww |j � d�| _
t| j
�sAt d��dtjvrJt d��i }tjrTtj|d< tjr\tj|d < tjrdtj|d
< tjd }|j|d fi |��| _| �� d S ) Nr )�BlobServiceClientz{Azure backend requires Microsoft Azure Storage SDK for Python (https://pypi.org/project/azure-storage-blob/).
Exception: %s�/z*Invalid Azure Storage Blob container name.�AZURE_CONNECTION_STRINGz5AZURE_CONNECTION_STRING environment variable not set.�timeout�max_single_put_size�max_block_size)� duplicity�backend�Backend�__init__�azure�
azure.storage�azure.storage.blobr � ImportErrorr r �path�lstrip�container_namer �os�environr r �azure_max_single_put_size�azure_max_block_size�from_connection_string� blob_service�_get_or_create_container)�self�
parsed_urlr r �e�kwargs�conn_strr
r
r r 2 s6 ���
zAzureBackend.__init__c
C s� ddl m} z| j�| j�| _| j�� W d S |y Y d S tyE } zt� dt
|j �� dd�d tj
j� W Y d }~d S d }~ww )Nr )�ResourceExistsErrorz$Could not create Azure container: %s�
� )�azure.core.exceptionsr+ r$ �get_container_clientr � container�create_container� Exceptionr �
FatalErrorr �message�split� ErrorCode�connection_failed)r& r+ r( r
r
r r% W s ����z%AzureBackend._get_or_create_containerc C sj t |�}i }tjrtj|d< |�d��}| jj||fi |�� W d � n1 s)w Y | �|� d S )N�max_concurrency�rb)r r �azure_max_connections�openr0 � upload_blob� _set_tier)r& � source_path�remote_filenamer) �datar
r
r �_putd s
�zAzureBackend._putc C s" t jd ur| j�t j|� d S d S �N)r �azure_blob_tierr0 � set_standard_blob_tier_blobs)r& r? r
r
r r= p s
�zAzureBackend._set_tierc C sJ | j �|�}|�d��}|�|�� � W d � d S 1 s w Y d S )N�wb)r0 �
download_blobr; �write�readall)r& r? �
local_path�blob�
download_filer
r
r �_gett s "�zAzureBackend._getc C s0 g }| j �� }|D ]}|�|� q dd� |D �S )Nc S s g | ]}|j �qS r
)r )�.0rJ r
r
r �
<listcomp>� s z&AzureBackend._list.<locals>.<listcomp>)r0 �
list_blobs�append)r& �blobs� blob_listrJ r
r
r �_listz s
zAzureBackend._listc C s | j �t|�� d S rB )r0 � delete_blobr )r& �filenamer
r
r �_delete� s zAzureBackend._deletec C s& | j �t|��}|�� }dt|j�iS )N�size)r0 �get_blob_clientr �get_blob_properties�intrW )r& rU �client�propr
r
r �_query� s zAzureBackend._queryc C s t jjS rB )r r6 �backend_not_found)r& � operationr( r
r
r � _error_code� s zAzureBackend._error_codeN)
�__name__�
__module__� __qualname__�__doc__r r% rA r= rL rS rV r] r` r
r
r
r r
. s %
r
r )�builtinsr r �re�duplicity.backendr r r �duplicity.errorsr �duplicity.utilr �compiler r r r r
�register_backendr
r
r
r �<module> s
b