Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/test/storage/__pycache__/test_oss.cpython-39.pyc
Ðазад
a r�h�{ � @ s� d dl mZ d dlZd dlZd dlZz d dlZW n eyN d dlmZ Y n0 d dlmZ d dlm Z d dlm Z d dlm Z d dl m Z d d lmZmZ d d lmZ d d lmZ d d lmZ d d lmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dl m Z d dl m Z m Z m!Z! d dl"m#Z# d dl$m%Z% G dd� dej&�Z'G dd� dej&�Z(G dd � d e ej&�Z)G d d � d ej&�Z*e+d k�r�e�,e�-� � dS ) � )�unicode_literalsN)�mock)�b)�httplib)�urlparse)�parse_qs)�InvalidCredsError)� Container�Object)�ContainerDoesNotExistError)�ContainerError)�ContainerIsNotEmptyError)�InvalidContainerNameError)�ObjectDoesNotExistError)�ObjectHashMismatchError)� OSSConnection)�OSSStorageDriver)� CHUNK_SIZE)� DummyIterator)�MockHttp�generate_random_data� make_response)�StorageFileFixtures)�STORAGE_OSS_PARAMSc @ s e Zd Zdd� Zdd� ZdS )�OSSConnectionTestCasec C s t dd�| _d S )NZ44CF9590006BF252F707Z(OtxrzxIsfpFjA7SwPzILwy8Bw21TLhquhboDYROV)r �conn��self� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/test/storage/test_oss.py�setUp1 s �zOSSConnectionTestCase.setUpc C sL t d�}ddddddd�}d }t�d |i |d | jj|d �}| �||� d S ) Nz 26NBxoKdsyly4EDv6inkoDft/yA=z,ODBGOERFMDMzQTczRUY3NUE3NzA5QzdFNUYzMDQxNEM=z text/htmlz Thu, 17 Nov 2005 18:49:58 GMTz foo@bar.comZ abracadabraz(oss-example.oss-cn-hangzhou.aliyuncs.com)z Content-MD5z Content-Type�ExpireszX-OSS-Meta-Authorz X-OSS-Magic�Hostz/oss-example/nelson�PUTr! zx-oss-)r r Z_get_auth_signaturer �key� assertEqual)r �expected�headers�action�actualr r r �test_signature5 s � �z$OSSConnectionTestCase.test_signatureN)�__name__� __module__� __qualname__r r* r r r r r 0 s r c @ s e Zd Zdd� ZdS )�ObjectTestCasec C s4 t t� }tddd d d d |d�}| �|�� d u� d S )Nu 中文r ��name�size�hash�extra� meta_data� container�driver)r r r � assertTrue�__repr__)r r6 �objr r r � test_object_with_chinese_nameI s �z,ObjectTestCase.test_object_with_chinese_nameN)r+ r, r- r: r r r r r. H s r. c @ s� e Zd Zed�Zi Zdd� Zdd� Zdd� Zdd � Z d d � Z d d � Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Z d0d1� Z d2S )3� OSSMockHttpZossc C s t jd| jt jt j fS �N� )r � UNAUTHORIZED� base_headers� responses�OK�r �method�url�bodyr' r r r � _unauthorizedU s �zOSSMockHttp._unauthorizedc C s$ | j �d�}tj|| jtjtj fS )Nzlist_containers_empty.xml��fixtures�loadr rA r? r@ rB r r r �_list_containers_empty[ s �z"OSSMockHttp._list_containers_emptyc C s$ | j �d�}tj|| jtjtj fS )Nzlist_containers.xmlrG rB r r r �_list_containersb s �z OSSMockHttp._list_containersc C s$ | j �d�}tj|| jtjtj fS )Nz list_container_objects_empty.xmlrG rB r r r � _list_container_objects_emptyi s �z)OSSMockHttp._list_container_objects_emptyc C s$ | j �d�}tj|| jtjtj fS )Nzlist_container_objects.xmlrG rB r r r �_list_container_objectsp s �z#OSSMockHttp._list_container_objectsc C s$ | j �d�}tj|| jtjtj fS )Nz"list_container_objects_chinese.xmlrG rB r r r � _list_container_objects_chinesew s �z+OSSMockHttp._list_container_objects_chinesec C s< d| j ji}| �||� | j�d�}tj|| jtjtj fS )N�prefixz!list_container_objects_prefix.xml) �testrO Z assertUrlContainsQueryParamsrH rI r rA r? r@ )r rC rD rE r' �paramsr r r � _list_container_objects_prefix~ s �z*OSSMockHttp._list_container_objects_prefixc C s | � ||||�S �N�rK rB r r r �_get_container� s zOSSMockHttp._get_containerc C s | � ||||�S rS rT rB r r r � _get_object� s zOSSMockHttp._get_objectc C s t j|| jt jt j fS rS )r � NOT_FOUNDr? r@ rB r r r �_notexisted_get_object� s �z"OSSMockHttp._notexisted_get_objectc C s< | j �ddddddddd d d d � � tj|| j tjtj fS ) N�bytesz keep-alive�0�application/octet-streamz Sat, 16 Jan 2016 15:38:14 GMTz""D41D8CD98F00B204E9800998ECF8427E"� Fri, 15 Jan 2016 14:43:15 GMTZ AliyunOSSZNormalZ569A63E6257784731E3D877F�monkeys) z accept-ranges� connectionzcontent-lengthz content-type�date�etagz last-modified�serverzx-oss-object-typezx-oss-request-idzx-oss-meta-rabbits)r? �updater rA r@ rB r r r �_test_get_object� s& �� �z OSSMockHttp._test_get_objectc C s t j||t jt j fS rS )r � BAD_REQUESTr@ rA rB r r r � _invalid_name� s �zOSSMockHttp._invalid_namec C s t j||t jt j fS rS �r �CONFLICTr@ rA rB r r r �_already_exists� s �zOSSMockHttp._already_existsc C s. | � d|� | � d|� tj||tjtj fS )Nr# r= )r% r rA r@ rB r r r �_create_container� s �z OSSMockHttp._create_containerc C s: | � d|� d| jj }| � ||� tj||tjtj fS )Nr# zb<CreateBucketConfiguration><LocationConstraint>%s</LocationConstraint></CreateBucketConfiguration>)r% rP � ex_locationr rA r@ )r rC rD rE r' Zlocation_constraintr r r �_create_container_location� s � �z&OSSMockHttp._create_container_locationc C s t j||t jt j fS rS �r rW r@ rA rB r r r � _delete_container_doesnt_exist� s �z*OSSMockHttp._delete_container_doesnt_existc C s t j||t jt j fS rS rf rB r r r �_delete_container_not_empty� s �z'OSSMockHttp._delete_container_not_emptyc C s t j|| jt jt j fS rS )r � NO_CONTENTr? r@ rB r r r �_delete_container� s �z OSSMockHttp._delete_containerc C s t j||t jt j fS rS rl rB r r r �_foo_bar_object_not_found� s �z%OSSMockHttp._foo_bar_object_not_foundc C s t j||t jt j fS rS )r ro r@ rA rB r r r �_foo_bar_object_delete� s �z"OSSMockHttp._foo_bar_object_deletec C sL t �|�j}t|�}d|vr*| j�d�}n | j�d�}tj||tjtj fS )Nz key-markerz#ex_iterate_multipart_uploads_p1.xmlz#ex_iterate_multipart_uploads_p2.xml) r �urlsplit�queryr rH rI r rA r@ )r rC rD rE r' Z query_stringrt r r r �_list_multipart� s �zOSSMockHttp._list_multipartc C s t d�}tj||tjtj fS )N�� )r r rA r@ rB r r r �_foo_bar_object� s �zOSSMockHttp._foo_bar_objectc C s d}t j||t jt j fS r< �r rA r@ rB r r r � _foo_bar_object_invalid_size s �z(OSSMockHttp._foo_bar_object_invalid_sizec C s& i }d}ddi}t j||t jt j fS )Nr= r` z""0cc175b9c0f1b6a831c399e269772661"rx rB r r r � _foo_test_stream_data_multipart s �z+OSSMockHttp._foo_test_stream_data_multipartN) r+ r, r- r rH r? rF rJ rK rL rM rN rR rU rV rX rc re rh ri rk rm rn rp rq rr ru rw ry rz r r r r r; P s4 r; c @ sL e Zd ZeZeZeZe dd� �Z dd� Z dd� Z dd� Z d d � Zd d � Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Z d'd(� Z d)d*� Z d+d,� Z d-d.� Z d/d0� Z!d1d2� Z"d3d4� Z#d5d6� Z$d7d8� Z%d9d:� Z&d;d<� Z'd=d>� Z(d?d@� Z)dAdB� Z*dCdD� Z+dEdF� Z,dGdH� Z-dIdJ� Z.dKdL� Z/dMS )N�OSSStorageDriverTestCasec C s | j | j� S rS )� driver_type� driver_argsr r r r � create_driver s z&OSSStorageDriverTestCase.create_driverc C s* | j | jj_d | j _| | j _| �� | _d S rS )�mock_response_klassr| Z connectionClsZ conn_class�typerP r~ r6 r r r r r s z OSSStorageDriverTestCase.setUpc C s | � � d S rS )�_remove_test_filer r r r �tearDown# s z!OSSStorageDriverTestCase.tearDownc C s6 t j�t�d }zt �|� W n ty0 Y n0 d S )N�.temp)�os�path�abspath�__file__�unlink�OSError)r � file_pathr r r r� & s z*OSSStorageDriverTestCase._remove_test_filec C s d| j _| �t| jj� d S )N� unauthorized)r r� � assertRaisesr r6 �list_containersr r r r �test_invalid_credentials. s z1OSSStorageDriverTestCase.test_invalid_credentialsc C s& d| j _| j�� }| �t|�d� d S )NZlist_containers_emptyr )r r� r6 r� r% �len)r � containersr r r �test_list_containers_empty2 s z3OSSStorageDriverTestCase.test_list_containers_emptyc C s� d| j _| j�� }| �t|�d� |d }| �d|j� | �d|jv � | �d|jd � | �d|jv � | �d|jd � | �| j|j� d S ) Nr� � r �xz02tphky6fjfiuc0Z creation_datez2014-05-15T11:18:32.000Z�locationzoss-cn-hangzhou-a) r r� r6 r� r% r� r0 r7 r3 )r r� r5 r r r � test_list_containers_success7 s �z5OSSStorageDriverTestCase.test_list_containers_successc C s: d| j _tdi | jd�}| jj|d�}| �t|�d� d S )NZ list_container_objects_empty�test_container�r0 r3 r6 �r5 r )r r� r r6 �list_container_objectsr% r� �r r5 �objectsr r r �!test_list_container_objects_emptyE s �z:OSSStorageDriverTestCase.test_list_container_objects_emptyc C s� d| j _tdi | jd�}| jj|d�}| �t|�d� |d }| �|jd� | �|jd� | �|j d� | �|j jd� | �|j d d � | � d |j v � d S ) Nr� r� r� r� r� r zen/� D41D8CD98F00B204E9800998ECF8427E� last_modifiedz2016-01-15T14:43:15.000Z�owner)r r� r r6 r� r% r� r0 r2 r1 r5 r3 r7 r4 �r r5 r� r9 r r r �#test_list_container_objects_successL s � �z<OSSStorageDriverTestCase.test_list_container_objects_successc C s� d| j _tdi | jd�}| jj|d�}| �t|�d� dd� |D �d }| �|jd � | �|jd � | �|j j d� | �|j d d � | � d |j v � d S )NZ list_container_objects_chineser� r� r� r� c S s g | ]}|j d kr|�qS )u WEB控制台.odp)r0 )�.0�or r r � <listcomp>c s �zUOSSStorageDriverTestCase.test_list_container_objects_with_chinese.<locals>.<listcomp>r Z 281371EA1618CF0E645D6BB90A158276i�� r� z2016-01-15T14:43:06.000Zr� )r r� r r6 r� r% r� r2 r1 r5 r0 r3 r7 r4 r� r r r �(test_list_container_objects_with_chinese\ s � � �zAOSSStorageDriverTestCase.test_list_container_objects_with_chinesec C sD d| j _tdi | jd�}d| _| jj|| jd�}| �t|�d� d S )NZ list_container_objects_prefixr� r� Z test_prefix)r5 rO r� )r r� r r6 rO r� r% r� r� r r r �'test_list_container_objects_with_prefixl s ��z@OSSStorageDriverTestCase.test_list_container_objects_with_prefixc C s d| j _| jt| jjdd� d S )N� get_containerz not-existed��container_name)r r� r� r r6 r� r r r r � test_get_container_doesnt_existu s �z8OSSStorageDriverTestCase.test_get_container_doesnt_existc C s( d| j _| jjdd�}| �|jd� d S )Nr� r� r� )r r� r6 r� r7 r0 �r r5 r r r �test_get_container_success{ s �z3OSSStorageDriverTestCase.test_get_container_successc C s" d| j _| jt| jjddd� d S )N� get_objectr� Z notexisted�r� � object_name)r r� r� r r6 r� r r r r �&test_get_object_container_doesnt_exist� s �z?OSSStorageDriverTestCase.test_get_object_container_doesnt_existc C s� d| j _| jjddd�}| �|jd� | �|jjd� | �|jd� | �|jd� | �|j d d� | �|j d d � | �|j d d � d S ) Nr� r� rP r� r r� r� r\ � content_typer[ Zrabbitsr] ) r r� r6 r� r% r0 r5 r1 r2 r3 r4 )r r9 r r r �test_get_object_success� s � �z0OSSStorageDriverTestCase.test_get_object_successc C s d| j _| jt| jjdd� d S )NZ invalid_namer� )r r� r� r r6 �create_containerr r r r �!test_create_container_bad_request� s �z:OSSStorageDriverTestCase.test_create_container_bad_requestc C s d| j _| jt| jjdd� d S )NZalready_existsz new-containerr� )r r� r� r r6 r� r r r r �$test_create_container_already_exists� s �z=OSSStorageDriverTestCase.test_create_container_already_existsc C s, d| j _d}| jj|d�}| �|j|� d S )Nr� � new_containerr� )r r� r6 r� r% r0 �r r0 r5 r r r � test_create_container_success� s z6OSSStorageDriverTestCase.test_create_container_successc C sJ d| j _d}d| _| jj|| jd�}| �|j|� | �|jd | j� d S )NZcreate_container_locationr� zoss-cn-beijing)r� rj r� ) r r� rj r6 r� r% r0 r7 r3 r� r r r �&test_create_container_with_ex_location� s �z?OSSStorageDriverTestCase.test_create_container_with_ex_locationc C s0 t dd | jd�}d| j_| jt| jj|d� d S )Nr� r� Z delete_container_doesnt_existr� )r r6 r r� r� r �delete_containerr� r r r �"test_delete_container_doesnt_exist� s ��z;OSSStorageDriverTestCase.test_delete_container_doesnt_existc C s0 t dd | jd�}d| j_| jt| jj|d� d S )Nr� r� Zdelete_container_not_emptyr� )r r6 r r� r� r r� r� r r r � test_delete_container_not_empty� s ��z8OSSStorageDriverTestCase.test_delete_container_not_emptyc C s0 d| j _tdd | jd�}| �| jj|d�� d S )Nr� r� r� r� )r r� r r6 r7 r� r� r r r � test_delete_container_success� s �z6OSSStorageDriverTestCase.test_delete_container_successc C sZ t di | jd�}tddd i |d | jd�}tj�t�d }| jj||ddd �}| � |� d S ) N�foo_bar_containerr� �foo_bar_objectrv �r0 r1 r2 r3 r5 r4 r6 r� FT�r9 �destination_pathZoverwrite_existingZdelete_on_failure) r r6 r r| r� r� r� r� �download_objectr7 �r r5 r9 r� �resultr r r � test_download_object_success� s � ��z5OSSStorageDriverTestCase.test_download_object_successc C sb d| j _tdi | jd�}tddd i |d | jd�}tj�t �d }| jj ||dd d �}| � |� d S ) NZ invalid_sizer� r� r� rv r� r� FTr� ) r r� r r6 r r| r� r� r� r� r� Z assertFalser� r r r �&test_download_object_invalid_file_size� s � ��z?OSSStorageDriverTestCase.test_download_object_invalid_file_sizec C s^ d| j _tdi | jd�}tddd i |d | jd�}tj�t �d }| j t | jj ||dd d � d S ) N� not_foundr� r� r� rv r� r� FTr� ) r r� r r6 r r| r� r� r� r� r� r r� )r r5 r9 r� r r r � test_download_object_not_found� s � ��z7OSSStorageDriverTestCase.test_download_object_not_foundc C sL t di | jd�}tddd i |d | jd�}| jj|d d�}| �t|d�� d S )Nr� r� r� rv r� )r9 � chunk_size�__iter__)r r6 r r| Zdownload_object_as_streamr7 �hasattr)r r5 r9 �streamr r r �&test_download_object_as_stream_success� s � ��z?OSSStorageDriverTestCase.test_download_object_as_stream_successc C s� d dd�}d| j _| jj}|| j_tj�t�}tdi | j d�}d}zBz| j j |||dd� W n t yn Y n 0 | � d � W || j_n || j_0 d S ) Nc S s t dddid�ddd�S )N�� r` Z2345�r' rv Zhash343hhash89h932439jsaa89��responseZbytes_transferredZ data_hash�r �r r� r� � request_path�request_methodr' r� r� r r r � upload_file s �zNOSSStorageDriverTestCase.test_upload_object_invalid_hash1.<locals>.upload_fileZ INVALID_HASH1r� r� �foo_test_uploadT)r� r5 r� � verify_hashz9Invalid hash was returned but an exception was not thrown)NNNNNNN) r r� r| �_upload_objectr� r� r� r� r r6 � upload_objectr Zfail)r r� �old_funcr� r5 r� r r r � test_upload_object_invalid_hash1 s. � � � �z9OSSStorageDriverTestCase.test_upload_object_invalid_hash1c C s� d dd�}d | j _| jj}|| j_tj�t�}tdi | j d�}d}dddii}| j j ||||d d �}| � |j d� | � |j d � | �d|jv � || j_d S ) Nc S s t dddid�ddd�S �Nr� r` Z 0cc175b9c0f1b6a831c399e269772661r� rv r� r� r� r r r r� s ��zHOSSStorageDriverTestCase.test_upload_object_success.<locals>.upload_filer� r� r� r4 z some-valueZfoobarT�r� r5 r� r3 r� rv )NNNNNNN)r r� r| r� r� r� r� r� r r6 r� r% r0 r1 r7 r4 �r r� r� r� r5 r� r3 r9 r r r �test_upload_object_success s. � � �z3OSSStorageDriverTestCase.test_upload_object_successc C s� d dd�}d | j _| jj}|| j_tj�t�}tdi | j d�}d}ddi}| j j ||||dd �}| � |j d� | � |j d � | � |jd d� || j_d S ) Nc S s t dddid�ddd�S r� r� r� r r r r� 7 s �zIOSSStorageDriverTestCase.test_upload_object_with_acl.<locals>.upload_filer� r� r� �aclz public-readTr� rv )NNNNNNN)r r� r| r� r� r� r� r� r r6 r� r% r0 r1 r3 r� r r r �test_upload_object_with_acl6 s. � ��z4OSSStorageDriverTestCase.test_upload_object_with_aclc C sH t j�t�}tdi | jd�}d}ddi}| jt| jj||||dd� d S )Nr� r� r� r� z invalid-aclTr� ) r� r� r� r� r r6 r� �AttributeErrorr� )r r� r5 r� r3 r r r �#test_upload_object_with_invalid_aclQ s ��z<OSSStorageDriverTestCase.test_upload_object_with_invalid_aclc C sv | j jrd| j_nd | j_tdi | j d�}d}tdgd�}ddi}| j j||||d �}| �|j|� | �|j d � d S ) N� multipartr� r� �foo_test_stream_datar= ��datar� � text/plain�r5 r� �iteratorr3 r � r6 �supports_multipart_uploadr r� r r �upload_object_via_streamr% r0 r1 �r r5 r� r� r3 r9 r r r �#test_upload_empty_object_via_stream_ s � �z<OSSStorageDriverTestCase.test_upload_empty_object_via_streamc C sx | j jrd| j_nd | j_tdi | j d�}d}tg d�d�}ddi}| j j||||d �}| �|j|� | �|j d � d S ) Nr� r� r� r� )�2�3�5r� r� r� r� � r� r� r r r �#test_upload_small_object_via_streamr s ��z<OSSStorageDriverTestCase.test_upload_small_object_via_streamc C s� | j jrd| j_nd | j_tdi | j d�}d}tdt dt dgd�}d d i}| j j||||d �}| �|j |� | �|j td d � d S )Nr� r� r� r� r� r� r� r� r� r� r� r� � ) r6 r� r r� r r r r� r% r0 r1 r� r r r �!test_upload_big_object_via_stream� s$ ���z:OSSStorageDriverTestCase.test_upload_big_object_via_streamc C sn | j js d S d| j_dd� }tdi | j d�}d}|� }ddi}z| j j||||d � W n tyh Y n0 d S ) NZ MULTIPARTc s s& t dd�D ]} t| �V q td��d S )Nr � zError in fetching data)�range�str� RuntimeError)�ir r r �_faulty_iterator� s zVOSSStorageDriverTestCase.test_upload_object_via_stream_abort.<locals>._faulty_iteratorr� r� r� r� r� r� )r6 r� r r� r r� � Exception)r r� r5 r� r� r3 r r r �#test_upload_object_via_stream_abort� s& �� z<OSSStorageDriverTestCase.test_upload_object_via_stream_abortc C sn | j js d S d| j_tdi | j d�}| j j|dd�D ]4}| �|jd u� | �|jd u� | �|j d u� q4d S )N�list_multipartr� r� r� )Z max_uploads) r6 r� r r� r Z ex_iterate_multipart_uploadsr7 r$ �idZ initiated)r r5 �uploadr r r �!test_ex_iterate_multipart_uploads� s �� z:OSSStorageDriverTestCase.test_ex_iterate_multipart_uploadsc C sp | j js d S d| j_tdi | j d�}tjddd��*}| j �|� | �d|j � W d � n1 sb0 Y d S )Nr r� r� z>libcloud.storage.drivers.oss.OSSStorageDriver._abort_multipartT)Zautospecr� ) r6 r� r r� r r �patchZ ex_abort_all_multipart_uploadsr% Z call_count)r r5 Z mock_abortr r r �#test_ex_abort_all_multipart_uploads� s �� z<OSSStorageDriverTestCase.test_ex_abort_all_multipart_uploadsc C sH d| j _tdi | jd�}tddd d d || jd�}| jt| jj|d� d S )Nr� r� r� r� �� r/ �r9 )r r� r r6 r r� r � delete_object)r r5 r9 r r r � test_delete_object_not_found� s � ��z5OSSStorageDriverTestCase.test_delete_object_not_foundc C sL d| j _tdi | jd�}tddd d d || jd�}| jj|d�}| �|� d S )N�deleter� r� r� r r/ r )r r� r r6 r r r7 )r r5 r9 r� r r r �test_delete_object_success� s � �z3OSSStorageDriverTestCase.test_delete_object_successN)0r+ r, r- r r| r r} r; r � classmethodr~ r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r r r r r{ sT r{ �__main__).� __future__r r� �sysZunittestr � ImportErrorZlibcloud.utils.py3r r r r Zlibcloud.common.typesr Zlibcloud.storage.baser r Zlibcloud.storage.typesr r r r r r Z libcloud.storage.drivers.ossr r r Z libcloud.storage.drivers.dummyr Z libcloud.testr r r Zlibcloud.test.file_fixturesr Zlibcloud.test.secretsr ZTestCaser r. r; r{ r+ �exit�mainr r r r �<module> sH E V
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка