Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/storage/drivers/__pycache__/local.cpython-39.pyc
Ðазад
a q�hRT � @ s0 d Z ddlmZ ddlZddlZddlZz ddlZddlmZmZ W n e y^ e d��Y n0 ddl m Z ddl m Z ddl mZ dd l mZ dd lmZ dd lmZmZmZ dd lmZ dd lmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z ddgZ G dd� de �Z!G dd� de�Z"dS )z; Provides storage driver for working with local filesystem � )�with_statementN)� LockTimeout� mkdirlockfilezOMissing lockfile dependency, you can install it using pip: pip install lockfile)�read_in_chunks)�exhaust_iterator)�relpath)�u)� Connection)�Object� Container� StorageDriver)� LibcloudError)�ContainerAlreadyExistsError)�ContainerDoesNotExistError)�ContainerIsNotEmptyError)� ObjectError)�ObjectDoesNotExistError��InvalidContainerNameErrorz.lockz.hashc @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �LockLocalStoragezF A class to help in locking a local path before being updated c C s || _ tj| j dd�| _d S )NT�Zthreaded)�pathr Z MkdirLockFile�lock)�selfr � 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/local.py�__init__6 s zLockLocalStorage.__init__c C s2 z| j jdd� W n ty, td��Y n0 d S )Ng�������?)�timeoutz Lock timeout)r �acquirer r )r r r r � __enter__: s zLockLocalStorage.__enter__c C s$ | j �� r| j �� |d ur |�d S )N)r Z is_locked�release)r �type�value� tracebackr r r �__exit__@ s zLockLocalStorage.__exit__N)�__name__� __module__� __qualname__�__doc__r r r$ r r r r r 2 s r c s� e Zd ZdZeZdZdZdZd8� fdd� Z d9d d �Z d d � Z d d� Z dd� Z dd� Zdd� Zd:dd�Zdd� Zd;dd�Zd d � Zd d � Zd d!� Zd"d#� Zd<d$d%�Zd=d&d'�Zd>d(d)�Zd?d*d+�Zd@d,d-�ZdAd.d/�Z d0d1� Z d2d3� Z d4d5� Z dBd6d7�Z � Z!S )C�LocalStorageDriverz� Implementation of local file-system based storage. This is helpful where the user would want to use the same code (using libcloud) and switch between cloud storage and local storage z Local Storagezhttp://example.com�md5NTc sB || _ tj�| j �s td��tt| �jf |||||d�|�� d S )Nz The base path is not a directory)�key�secret�secure�host�port)� base_path�osr �isdirr �superr) r )r r+ r, r- r. r/ �kwargs�� __class__r r r T s ��zLocalStorageDriver.__init__c C sL zt �|� W n8 tyF } z |jtjkr2|s2|�W Y d}~n d}~0 0 dS )z@ Create a path by checking if it already exists N)r1 �makedirs�OSError�errno�EEXIST)r r �ignore_existing�expr r r � _make_patha s z LocalStorageDriver._make_pathc C s" d|v sd|v r t d| |d��dS )z� Check if the container name is valid :param container_name: Container name :type container_name: ``str`` �/�\N�r" �driver�container_namer �r rB r r r �_check_container_namel s �z(LocalStorageDriver._check_container_namec C s� | � |� tj�| j|�}z"t�|�}tj�|�s:td��W n ty\ td| |d��Y n0 i }|j |d< |j |d< |j |d< t ||| d�S )z� Create a container instance :param container_name: Container name. :type container_name: ``str`` :return: Container instance. :rtype: :class:`Container` z Target path is not a directoryNr@ � creation_time� access_time� modify_time)�name�extrarA ) rD r1 r �joinr0 �statr2 r8 r �st_ctime�st_atime�st_mtimer )r rB � full_pathrK rI r r r �_make_containerx s � z"LocalStorageDriver._make_containerc C s� t j�| j|j|�}t j�|�r.td| |d��zt �|�}W n ty\ t d| |d��Y n0 | � � }|� t |j ��d�� |�� }i }|j|d< |j|d< |j |d< t||j|| ||dd�S )a Create an object instance :param container: Container. :type container: :class:`Container` :param object_name: Object name. :type object_name: ``str`` :return: Object instance. :rtype: :class:`Object` N)r" rA � object_name�asciirE rF rG )rH �sizerI rA � container�hashZ meta_data)r1 r rJ r0 rH r2 r rK � Exceptionr Z_get_hash_function�updater rN �encode� hexdigestrL rM r �st_size)r rT rQ rO rK Z data_hashrI r r r � _make_object� s( � �z LocalStorageDriver._make_objectc c s@ t �| j�D ].}t j�| j|�}t j�|�s.q | �|�V q dS )z� Return a generator of containers. :return: A generator of Container instances. :rtype: ``generator`` of :class:`Container` N)r1 �listdirr0 r rJ r2 rP )r rB rO r r r �iterate_containers� s z%LocalStorageDriver.iterate_containersc c sz | j |dd�}tj|dd�D ]X\}}}tD ]}||v r*|�|� q*|D ],}tj�||�}t||d�} | �|| �V qFq dS )zY Recursively iterate through the file-system and return the object names T��check)�topdown)�startN) �get_container_cdn_urlr1 �walk�IGNORE_FOLDERS�remover rJ r r[ ) r rT Zcpath�folderZ subfolders�filesZsubfrH rO rQ r r r � _get_objects� s z LocalStorageDriver._get_objectsc C s" | � ||�}| �|�}| �||�S )a� Returns a generator of objects for the given container. :param container: Container instance :type container: :class:`Container` :param prefix: Filter objects starting with a prefix. :type prefix: ``str`` :param ex_prefix: (Deprecated.) Filter objects starting with a prefix. :type ex_prefix: ``str`` :return: A generator of Object instances. :rtype: ``generator`` of :class:`Object` )Z_normalize_prefix_argumentrh Z _filter_listed_container_objects)r rT �prefixZ ex_prefix�objectsr r r �iterate_container_objects� s z,LocalStorageDriver.iterate_container_objectsc C s | � |�S )z� Return a container instance. :param container_name: Container name. :type container_name: ``str`` :return: :class:`Container` instance. :rtype: :class:`Container` )rP rC r r r � get_container� s z LocalStorageDriver.get_containerFc C s6 t j�| j|j�}|r2t j�|�s2td| |jd��|S )a7 Return a container CDN URL. :param container: Container instance :type container: :class:`Container` :param check: Indicates if the path's existence must be checked :type check: ``bool`` :return: A CDN URL for this container. :rtype: ``str`` Nr@ )r1 r rJ r0 rH r2 r )r rT r_ r r r r rb s �z(LocalStorageDriver.get_container_cdn_urlc C s | � |�}| �||�S )a Return an object instance. :param container_name: Container name. :type container_name: ``str`` :param object_name: Object name. :type object_name: ``str`` :return: :class:`Object` instance. :rtype: :class:`Object` )rP r[ )r rB rQ rT r r r � get_object s z LocalStorageDriver.get_objectc C s t j�| j|jj|j�S )z� Return an object CDN URL. :param obj: Object instance :type obj: :class:`Object` :return: A CDN URL for this object. :rtype: ``str`` )r1 r rJ r0 rT rH )r �objr r r �get_object_cdn_url& s z%LocalStorageDriver.get_object_cdn_urlc C sN | � |�}tj|dd� t|�� | �|� W d � n1 s@0 Y dS )z� Enable container CDN. :param container: Container instance :type container: :class:`Container` :rtype: ``bool`` Tr N)rb �lockfileZ MkdirFileLockr r= )r rT r r r r �enable_container_cdn2 s (z'LocalStorageDriver.enable_container_cdnc C s� | � |�}t|��d tj�|�r0W d � dS zt|d�}|�� W n tyf Y W d � dS 0 W d � n1 s|0 Y dS )z� Enable object CDN. :param obj: Object instance :type obj: :class:`Object` :rtype: ``bool`` NF�wT)ro r r1 r �exists�open�closerV )r rn r �obj_filer r r �enable_object_cdnD s 2z$LocalStorageDriver.enable_object_cdnc C sj | � |�}| j|||d�}zt�||� W n: tyd |r^zt�|� W n ty\ Y n0 Y dS 0 dS )a Download an object to the specified destination path. :param obj: Object instance. :type obj: :class:`Object` :param destination_path: Full path to a file or a directory where the incoming file will be saved. :type destination_path: ``str`` :param overwrite_existing: True to overwrite an existing file, defaults to False. :type overwrite_existing: ``bool`` :param delete_on_failure: True to delete a partially downloaded file if the download was not successful (hash mismatch / file size). :type delete_on_failure: ``bool`` :return: True if an object has been successfully downloaded, False otherwise. :rtype: ``bool`` �rn �destination_path�overwrite_existingFT)ro �_get_obj_file_path�shutil�copy�IOErrorr1 �unlinkrV )r rn ry rz �delete_on_failure�obj_path� file_pathr r r �download_objectZ s � z"LocalStorageDriver.download_objectc c sP | � |�}t|d��(}t||d�D ] }|V q"W d � n1 sB0 Y dS )a4 Return a generator which yields object data. :param obj: Object instance :type obj: :class:`Object` :param chunk_size: Optional chunk size (in bytes). :type chunk_size: ``int`` :return: A stream of binary chunks of data. :rtype: ``object`` �rb)� chunk_sizeN)ro rt r )r rn r� r rv �datar r r �download_object_as_stream� s z,LocalStorageDriver.download_object_as_streamc C sj | j ||d� | j|||d�}| j|||d�}t|d�� } | �t|�� W d � n1 s\0 Y dS )N�� start_bytes� end_bytesrx )rn r� r� �wbT)� _validate_start_and_end_bytesr{ � download_object_range_as_streamrt �writer ) r rn ry r� r� rz r� r� �iterator�fpr r r �download_object_range� s ��� ,z(LocalStorageDriver.download_object_rangec c s� | j ||d� | �|�}t|d��h}t|�� �}|rD||krDtd��|d u rZ|| d }n|| }|�|� |�|�} | V W d � n1 s�0 Y d S )Nr� r� z"end_bytes is larger than file size� )r� ro rt �len�read� ValueError�seek) r rn r� r� r� r rv � file_size� read_bytesr� r r r r� � s � z2LocalStorageDriver.download_object_range_as_streamc C s� | j |dd�}tj�||�}tj�|�} | �| � t|�� t�||� W d � n1 s\0 Y t� |t dd�� | � ||�S )an Upload an object currently located on a disk. :param file_path: Path to the object on disk. :type file_path: ``str`` :param container: Destination container. :type container: :class:`Container` :param object_name: Object name. :type object_name: ``str`` :param verify_hash: Verify hast :type verify_hash: ``bool`` :param extra: (optional) Extra attributes (driver specific). :type extra: ``dict`` :param headers: (optional) Headers (driver specific). :type headers: ``dict`` :rtype: ``object`` Tr^ N�664� ) rb r1 r rJ �dirnamer= r r| r} �chmod�intr[ ) r r� rT rQ rI Z verify_hash�headersr r� r0 r r r � upload_object� s *z LocalStorageDriver.upload_objectc C s� | j |dd�}tj�||�}tj�|�}| �|� t|��N t|d��$} |D ]} | �| � qLW d � n1 sp0 Y W d � n1 s�0 Y t� |t dd�� | � ||�S )a� Upload an object using an iterator. If a provider supports it, chunked transfer encoding is used and you don't need to know in advance the amount of data to be uploaded. Otherwise if a provider doesn't support it, iterator will be exhausted so a total size for data to be uploaded can be determined. Note: Exhausting the iterator means that the whole data must be buffered in memory which might result in memory exhausting when uploading a very large object. If a file is located on a disk you are advised to use upload_object function which uses fs.stat function to determine the file size and it doesn't need to buffer whole object in the memory. :type iterator: ``object`` :param iterator: An object which implements the iterator interface and yields binary chunks of data. :type container: :class:`Container` :param container: Destination container. :type object_name: ``str`` :param object_name: Object name. :type extra: ``dict`` :param extra: (optional) Extra attributes (driver specific). Note: This dictionary must contain a 'content_type' key which represents a content type of the stored object. :param headers: (optional) Headers (driver specific). :type headers: ``dict`` :rtype: ``object`` Tr^ r� Nr� r� ) rb r1 r rJ r� r= r rt r� r� r� r[ ) r r� rT rQ rI r� r r� r0 rv r� r r r �upload_object_via_stream� s ( Hz+LocalStorageDriver.upload_object_via_streamc C s� | � |�}t|��@ zt�|� W n tyB Y W d � dS 0 W d � n1 sX0 Y tj�|�}|j�� }||kr�zt� |� W n@ t y� } z(|j t j kr�W Y d}~q�|�W Y d}~n d}~0 0 tj�|�}qxdS )z� Delete an object. :type obj: :class:`Object` :param obj: Object instance. :return: ``bool`` True on success. :rtype: ``bool`` NFT) ro r r1 r rV r r� rT Z get_cdn_url�rmdirr8 r9 � ENOTEMPTY)r rn r Z container_urlr< r r r � delete_object s" 2 z LocalStorageDriver.delete_objectc C s� | � |� tj�| j|�}z| j|dd� W np ty| } z8|jtjkrXt d|| d��nt d| | d��W Y d}~n*d}~0 t y� t d| | d��Y n0 | � |�S )z� Create a new container. :type container_name: ``str`` :param container_name: Container name. :return: :class:`Container` instance on success. :rtype: :class:`Container` F)r; zgContainer with this name already exists. The name must be unique among all the containers in the system�r" rB rA zError creating container %s)rA N) rD r1 r rJ r0 r= r8 r9 r: r r rV rP )r rB r r< r r r �create_container? s& �� � z#LocalStorageDriver.create_containerc C s� | � |�D ]}td|j| d��q | j|dd�}t|��@ zt�|� W n tyf Y W d � dS 0 W d � n1 s|0 Y dS )z� Delete a container. :type container: :class:`Container` :param container: Container instance :return: True on success, False otherwise. :rtype: ``bool`` zContainer is not emptyr� Tr^ NF)rh r rH rb r r| �rmtreerV )r rT rn r r r r �delete_containera s � 2z#LocalStorageDriver.delete_containerc C sn t j�|�}|s,t j�|�s,td| | d��|sBt j�||j�}n|}t j�|�rj|sjtd| d | d��|S )NzPath %s does not exist)r" rA z File %s already exists, but zoverwrite_existing=False)r1 r �basenamers r rJ rH )r rn ry rz � base_namer� r r r r{ | s" ���z%LocalStorageDriver._get_obj_file_path)NTNN)T)NN)F)FT)N)NFT)NN)NTN)NN)F)"r% r& r' r( r Z connectionClsrH ZwebsiteZ hash_typer r= rD rP r[ r] rh rk rl rb rm ro rq rw r� r� r� r� r� r� r� r� r� r{ � __classcell__r r r5 r r) H sR ) � � + � � � ) � 3$" �r) )#r( � __future__r r9 r1 r| rp r r � ImportErrorZlibcloud.utils.filesr r Zlibcloud.utils.py3r r Zlibcloud.common.baser Zlibcloud.storage.baser r r Zlibcloud.common.typesr Zlibcloud.storage.typesr r r r r r rd �objectr r) r r r r �<module> s2
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка