Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/storage/drivers/__pycache__/backblaze_b2.cpython-39.pyc
Ðазад
a q�h�R � @ sL d Z ddlZddlZz ddlZW n ey: ddlZY n0 ddlmZ ddlmZ ddlm Z ddlm Z ddl m Z ddl m Z dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ ddlmZ ddlmZmZmZ ddl m Z ddl m Z g d�Z dZ dZ!G dd� de�Z"G dd� de�Z#G dd� de�Z$G dd � d e�Z%dS ) z" Driver for Backblaze B2 service. � N)�b)�httplib)�urlparse)�next)�read_in_chunks)�exhaust_iterator)�sanitize_object_name)�ConnectionUserAndKey)� JsonResponse)�InvalidCredsError)� LibcloudError)�Provider)�Object� Container� StorageDriver)�ContainerDoesNotExistError)�ObjectDoesNotExistError)�BackblazeB2StorageDriver�BackblazeB2Connection�BackblazeB2AuthConnectionzapi.backblaze.comz /b2api/v1/c @ s e Zd Zdd� Zdd� ZdS )�BackblazeB2Responsec C s | j tjtjtjfv S �N)�statusr �OK�CREATED�ACCEPTED)�self� 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/backblaze_b2.py�success9 s zBackblazeB2Response.successc C s. t | j�}| �� }|tjkr(t|d ��| jS )N�message)�intr Z parse_bodyr � UNAUTHORIZEDr �body)r r r# r r r � parse_error< s z BackblazeB2Response.parse_errorN)�__name__� __module__� __qualname__r r$ r r r r r 8 s r c sD e Zd ZeZdZeZ� fdd�Zd dd�Z dd� Z d d d �Z � Z S ) r Tc s> t t| �j|i |�� d | _d | _d | _d | _d | _d | _d S r ) �superr �__init__� account_id�api_url�api_host� download_url� download_host� auth_token�r �args�kwargs�� __class__r r r) K s z"BackblazeB2AuthConnection.__init__Fc C s� | j |d�s| S i }d}t�td| j| jf ��}d|�d� |d< td }| j||dd�}|j t j krx| j |j d � ntd t|j � ��| S ) z� :param force: Force authentication if if we have already obtained the token. :type force: ``bool`` )�forceZb2_authorize_accountz%s:%szBasic %szutf-8� Authorization�GET)�action�headers�method��datazFailed to authenticate: %s)�_is_authentication_needed�base64� b64encoder Zuser_id�key�decode�API_PATH�requestr r r �_parse_and_set_auth_info�object� Exception�str)r r5 r9 r8 Zauth_b64�respr r r � authenticateV s z&BackblazeB2AuthConnection.authenticatec C sX i }|d | _ |d | _|d | _|d | _t�| j�}|j| _t�| j�}|j| _|S )N� accountIdZapiUrlZ downloadUrl�authorizationToken)r* r+ r- r/ r �netlocr, r. )r r< �resultZparsed_api_urlZparsed_download_urlr r r rD n s z2BackblazeB2AuthConnection._parse_and_set_auth_infoc C s | j r |rdS dS )NTF)r/ )r r5 r r r r= } s z3BackblazeB2AuthConnection._is_authentication_needed)F)F) r% r& r' � AUTH_API_HOST�host�securer � responseClsr) rI rD r= � __classcell__r r r3 r r F s r c s^ e Zd ZdZdZeZeZ� fdd�Z ddd�Z dd� Z dd d �Z d� fd d� Z dd� Z� ZS )r NTc s, t t| �j|i |�� | j|i |��| _d S r )r( r r) �authCls� _auth_connr0 r3 r r r) � s z BackblazeB2Connection.__init__c C s> | j �� }| �|j� d| }d}d}| j|||||d�}|S )Nz/file/r7 T)� auth_connr8 �paramsr: �raw)rT rI � _set_hostr. �_request)r r8 rV rU r: rW �responser r r �download_request� s �z&BackblazeB2Connection.download_requestc C s< | j �� }| j|d� d}d}| j||d |||||d�} | S )N�rO �POSTF)rU r8 rV r< r9 r: rW r/ )rT rI rX rY ) r r8 r9 � upload_hostr/ r< rU r: rW rZ r r r �upload_request� s �z$BackblazeB2Connection.upload_requestr7 Fc C s� |pi }|pi }| j �� }| j|jd� |s8|r8d|d< |rj|dkrP|j|d< n|dkrj|p^i }|j|d< t| }|r�t�|�}| j| j ||||||d�} | S )Nr\ zapplication/json� Content-Typer7 rJ r] )rU r8 rV r< r: r9 rW ) rT rI rX r, r* rB �json�dumpsrY ) r r8 rV r< r9 r: rW �include_account_idrU rZ r r r rC � s( �z BackblazeB2Connection.requestc sH |pi }|pi }|s | j j}d| |d< tt| �j||||||d�} | S )Nz%sr6 )r8 rV r< r: r9 rW )rT r/ r( r rC ) r rU r8 rV r< r9 r: rW r/ rZ r3 r r rY � s �z BackblazeB2Connection._requestc C s || _ d| | j_ dS )z� Dynamically set host which will be used for the following HTTP requests. NOTE: This is needed because Backblaze uses different hosts for API, download and upload requests. z https://%sN)rO � connection)r rO r r r rX � s z BackblazeB2Connection._set_host)N)NNNr7 FF)NNNr7 FN)r% r& r' rO rP r rQ r rS r) r[ r_ rC rY rX rR r r r3 r r � s � �r c @ s� e Zd ZeZdZdZejZ dZ dZ dd� Z d4dd �Z d d � Zd d � Zd5dd�Zdd� Zd6dd�Zd7dd�Zd8dd�Zd9dd�Zd d � Zd d � Zd d!� Zd:d"d#�Zd$d%� Zd&d'� Zd(d)� Z d*d+� Z d,d-� Z d;d.d/�Z d0d1� Z d<d2d3�Z!dS )=r z Backblaze B2z https://www.backblaze.com/b2/�sha1Fc C s$ | j jdddd�}| j|jd�}|S )NZb2_list_bucketsr7 T)r8 r: rc r; )rd rC �_to_containersrE )r rH � containersr r r �iterate_containers� s �z+BackblazeB2StorageDriver.iterate_containersNc C sH | � ||�}d|jd i}| jjdd|d�}| j|j|d�}| �||�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` �bucketId�idZb2_list_file_namesr7 �r8 r: rV �r< � container)Z_normalize_prefix_argument�extrard rC � _to_objectsrE Z _filter_listed_container_objects)r rm �prefixZ ex_prefixrV rH �objectsr r r �iterate_container_objects� s �z2BackblazeB2StorageDriver.iterate_container_objectsc s: | � � }t� fdd�|D �d �}|r(|S td | � d��d S )Nc 3 s | ]}|j � kr|V qd S r ��name)�.0�c��container_namer r � <genexpr> � z9BackblazeB2StorageDriver.get_container.<locals>.<genexpr>)�value�driverrx )rh r r )r rx rg rm r rw r � get_container s ��z&BackblazeB2StorageDriver.get_containerc sN | j |d�}| j|d�}t� fdd�|D �d �}|d ur<|S td | � d��d S )Nrw )rm c 3 s | ]}|j � kr|V qd S r rs )ru �obj�� object_namer r ry ) rz z6BackblazeB2StorageDriver.get_object.<locals>.<genexpr>)r{ r| r� )r} rr r r )r rx r� rm rq r~ r r r � get_object% s �z#BackblazeB2StorageDriver.get_object� allPrivatec C s: i }||d< ||d< | j jd|ddd�}| j|jd�}|S )N� bucketName� bucketTypeZb2_create_bucketr] T�r8 r< r: rc ��item)rd rC � _to_containerrE )r rx Zex_typer< rH rm r r r �create_container1 s �z)BackblazeB2StorageDriver.create_containerc C s2 i }|j d |d< | jjd|ddd�}|jtjkS )Nrj ri Zb2_delete_bucketr] Tr� )rn rd rC r r r )r rm r< rH r r r �delete_container< s �z)BackblazeB2StorageDriver.delete_containerTc C sD | j |j|d�}| jj|d�}| j|| j|||j|||d�tjd�S )N�rm r~ �r8 )r~ rZ �destination_path�overwrite_existing�delete_on_failure�r~ �callbackrZ �callback_kwargsZsuccess_status_code) �_get_object_download_pathrm rd r[ � _get_objectZ _save_objectrZ r r )r r~ r� r� r� r8 rZ r r r �download_objectE s � ��z(BackblazeB2StorageDriver.download_objectc C s@ | j |j|d�}| jj|d�}| j|t||�|�|d�tjd�S )Nr� r� )�iterator� chunk_sizer� ) r� rm rd r[ r� r � iter_contentr r )r r~ r� r8 rZ r r r �download_object_as_streamX s ����z2BackblazeB2StorageDriver.download_object_as_streamc C s` t |d��,}t|�}t|d�}t|d�} W d � n1 s<0 Y | j| |||||d�} | S )zq Upload an object. Note: This will override file with a same name if it already exists. �rb�r� N)r< rm r� rn � verify_hashr9 )�open�iterr r �_perform_upload) r � file_pathrm r� rn r� r9 �fpr� r< r~ r r r � upload_objectg s (�z&BackblazeB2StorageDriver.upload_objectc C s, t |d�}t|d�}| j|||||d�}|S )z� Upload an object. Note: Backblaze does not yet support uploading via stream, so this calls upload_object internally requiring the object data to be loaded into memory at once r� )r< rm r� rn r9 )r r r� )r r� rm r� rn r9 r< r~ r r r �upload_object_via_stream s �z1BackblazeB2StorageDriver.upload_object_via_streamc C s: i }|j |d< |jd |d< | jjd|dd�}|jtjkS )N�fileName�fileIdZb2_delete_file_versionr] �r8 r< r: )rt rn rd rC r r r )r r~ r< rH r r r � delete_object� s �z&BackblazeB2StorageDriver.delete_objectc C s2 i }||d< | j jdd|d�}| j|jd d�}|S )Nr� Zb2_get_file_infor7 rk �r� rm �rd rC � _to_objectrE )r Z object_idrV rH r~ r r r � ex_get_object� s �z&BackblazeB2StorageDriver.ex_get_objectc C s: i }||d< ||d< | j jd|dd�}| j|jd d�}|S )Nri r� Z b2_hide_filer] r� r� r� )r � container_idr� r< rH r~ r r r �ex_hide_object� s �z'BackblazeB2StorageDriver.ex_hide_objectc C sV i }||d< |r||d< |r$||d< |r0||d< | j jd|dd�}| j|jd d�}|S ) Nri Z startFileNameZ startFileIdZ maxFileCountZb2_list_file_versionsr7 )r8 rV r: rl )rd rC ro rE )r r� Zex_start_file_nameZex_start_file_idZex_max_file_countrV rH rq r r r �ex_list_object_versions� s �z0BackblazeB2StorageDriver.ex_list_object_versionsc C s$ i }||d< | j jdd|d�}|jS )z Retrieve information used for uploading files (upload url, auth token, etc). :rype: ``dict`` ri Zb2_get_upload_urlr7 rk )rd rC rE )r r� rV rZ r r r �ex_get_upload_data� s �z+BackblazeB2StorageDriver.ex_get_upload_datac C s | j |d�}|d }|S )zN Retrieve URL used for file uploads. :rtype: ``str`` �r� � uploadUrl)r� )r r� rM Z upload_urlr r r �ex_get_upload_url� s z*BackblazeB2StorageDriver.ex_get_upload_urlc C s, g }|d D ]}| j |d�}|�|� q |S )NZbucketsr� )r� �append)r r< rM r� rm r r r rf � s z'BackblazeB2StorageDriver._to_containersc C s2 i }|d |d< |d |d< t |d || d�}|S )Nri rj r� r� )rt rn r| )r )r r� rn rm r r r r� � s �z&BackblazeB2StorageDriver._to_containerc C s. g }|d D ] }| j ||d�}|�|� q |S )N�filesr� )r� r� )r r< rm rM r� r~ r r r ro � s z$BackblazeB2StorageDriver._to_objectsc C sj i }|d |d< |� dd �|d< |� d|� dd ��}|� dd �}|� di �}t|d |||||| d�}|S ) Nr� ZuploadTimestamp�sizeZ contentLengthZ contentSha1ZfileInfor� )rt r� �hashrn � meta_datarm r| )�getr )r r� rm rn r� r� r� r~ r r r r� � s �z#BackblazeB2StorageDriver._to_objectc C s |j d |j }|S )zW Return a path used in the download requests. :rtype: ``str`` �/rs )r rm r~ �pathr r r r� � s z2BackblazeB2StorageDriver._get_object_download_pathc C s t |t�rt|�}t|�}|p i }|�dd�}|�di �}|p@i }||d< ||d< t�� } | �t|�� | � � |d< |D ]\} } | |d| < qx| j |j d d �} | d } t � | d �}|j }|j}| jj|||| |d �}|jtjkr�| j|j|d �}|S |j�� }td|j|f | d��d S )N� content_typez b2/x-autor� zX-Bz-File-Namer` zX-Bz-Content-Sha1z X-Bz-Info-%srj r� rK r� )r8 r9 r^ r/ r< r� z&Upload failed. status_code=%s, body=%s)r| )� isinstancerG � bytearrayr r� �hashlibre �updater � hexdigestr� rn r rL r� rd r_ r r r r� rE rZ �readr )r r< rm r� rn r� r9 r� r� re r@ r{ Z upload_dataZ upload_token� parsed_urlr^ � request_pathrZ r~ r# r r r r� sH �� ��z(BackblazeB2StorageDriver._perform_upload)NN)r� )FT)N)NTN)NN)NNN)N)NTN)"r% r& r' r Z connectionClsrt Zwebsiter Z BACKBLAZE_B2�typeZ hash_typeZsupports_chunked_encodingrh rr r} r� r� r� r� r� r� r� r� r� r� r� r� r� rf r� ro r� r� r� r r r r r � sN � � � � � �r )&�__doc__r> r� Z simplejsonra � ImportErrorZlibcloud.utils.py3r r r r Zlibcloud.utils.filesr r Zlibcloud.utils.escaper Zlibcloud.common.baser r Zlibcloud.common.typesr r Zlibcloud.storage.providersr Zlibcloud.storage.baser r r Zlibcloud.storage.typesr r �__all__rN rB r r r r r r r r �<module> s8 >j
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка