Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/cloud/__pycache__/_block_storage.cpython-39.pyc
Ðазад
a t�hh� � @ sj d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlmZ dd� Z G d d � d ej �Z dS ) � N)�exc)� _normalize)�_utils)�proxy)�utilsc C s | D ]}|d dvr dS qdS )z;If there are any volumes not in a steady state, don't cache�status)� available�errorzin-useFT� )�volumes�volumer r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/cloud/_block_storage.py�_no_pending_volumes s r c @ s~ e Zd Zejed�dQdd��Ze�� dRdd��ZdSdd �Zd d � Z dTd d �Z dUdd�Z dd� Z dVdd�Z dWdd�ZdXdd�ZdYdd�Zdd � Zd d � Zd d � ZdZd!d"�Zd[d#d$�Zd%d&� Ze�d'd(d)d*�d\d+d,��Zd-d.� Zd]d/d0�Zd^d1d2�Zd_d3d4�Z d`d5d6�Z dad7d8�Z dbd9d:�Z dcd;d<�Z ddd=d>�Z!ded?d@�Z"dfdAdB�Z#dgdCdD�Z$dEdF� Z%dGdH� Z&dIdJ� Z'dKdL� Z(dMdN� Z)dOdP� Z*dS )h�BlockStorageCloudMixin)Zshould_cache_fnTc s� � ��fdd�� |s t �d� d}t|�D ]`}g �t��j�d��}d|vrb��|�dg �� q�z� |� W q�W q* tj y� Y q*0 q*�j � dj |d �� �� �jd �d ��S ) zZList all available volumes. :returns: A list of volume ``munch.Munch``. c s� �� | �dg �� d }| �dg �D ]$}d|v r"d|d kr"|d } qHq"|r�z� t��j�|��� W n* tjy� �j�dj | d�� � Y n0 d S )Nr � volumes_links�rel�next�hrefz7While listing volumes, could not find next link {link}.)�link) �extend�getr �_json_response� block_storager �OpenStackCloudURINotFound�log�debug�format)�data�endpointr ��_list�selfr r r r + s$ � ��z2BlockStorageCloudMixin.list_volumes.<locals>._listzEcache argument to list_volumes is deprecated. Use invalidate instead.� z/volumes/detailr r z_List volumes failed to retrieve all volumes after {attempts} attempts. Returning what we found.)�attemptsN)�keyr )�warnings�warn�ranger r r r r r r r r r Z_normalize_volumes�_get_and_munchify)r! �cacher# �_r r r r � list_volumes$ s2 � �� �z#BlockStorageCloudMixin.list_volumesc C s6 | j jdtdd�d�}tj|dd�}| �| �d|��S )z_List all available volume types. :returns: A list of volume ``munch.Munch``. z/types�None)Z is_public��paramsz Error fetching volume_type list�� error_message� volume_types)r r �dictr r Z_normalize_volume_typesr( )r! � get_extra�respr r r r �list_volume_types^ s �� �z(BlockStorageCloudMixin.list_volume_typesNc C s t �| d||�S )a� Get a volume by name or ID. :param name_or_id: Name or ID of the volume. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :returns: A volume ``munch.Munch`` or None if no matching volume is found. r �r Z _get_entity�r! � name_or_id�filtersr r r � get_volumen s z!BlockStorageCloudMixin.get_volumec C s@ | j �dj|d��}tj|dj|d�d�}| �| �d|��}|S )zn Get a volume by ID :param id: ID of the volume. :returns: A volume ``munch.Munch``. z /volumes/{id}��idz!Error getting volume with ID {id}r/ r �r r r r r �_normalize_volumer( )r! r< r4 r r r r r �get_volume_by_id� s � �z'BlockStorageCloudMixin.get_volume_by_idc C s t �| d||�S )a� Get a volume type by name or ID. :param name_or_id: Name or ID of the volume. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :returns: A volume ``munch.Munch`` or None if no matching volume is found. � volume_typer6 r7 r r r �get_volume_type� s �z&BlockStorageCloudMixin.get_volume_typec K sF |dur d}|r<| � |�}|s0t�dj|d���|d |d< | �|�}||d< t|d�}d |v rp|�d d�|d < | jjd t|�d �} t j | d d�} | � d| �} | j � | � | d dkr�t�d ��|�r<| d } t�|d�D ]`} | �| �} | s�q�| d dk�r$|du�r | j| |d� || d< | S | d dkr�t�d��q�| �| �S )a2 Create a volume. :param size: Size, in GB of the volume to create. :param name: (optional) Name for the volume. :param description: (optional) Name for the volume. :param wait: If true, waits for volume to be created. :param timeout: Seconds to wait for volume creation. None is forever. :param image: (optional) Image name, ID or object from which to create the volume :param bootable: (optional) Make this volume bootable. If set, wait will also be set to true. :param kwargs: Keyword arguments as expected for cinder client. :returns: The created volume object. :raises: OpenStackCloudTimeout if wait time exceeded. :raises: OpenStackCloudException on operation error. NTzYImage {image} was requested as the basis for a new volume, but was not found on the cloud)�imager< ZimageRef�size�r Zscheduler_hintszOS-SCH-HNT:scheduler_hintsz/volumes��jsonzError in creating volumer/ r r r z/Timeout waiting for the volume to be available.r )�bootablerG zError creating volume)Z get_imager �OpenStackCloudExceptionr �_get_volume_kwargsr2 �popr �postr r r( r+ � invalidater �iterate_timeoutr: �set_volume_bootabler> )r! rC �wait�timeoutrB rG �kwargsZ image_obj�payloadr4 r r Zvol_id�countr r r � create_volume� s^ �� ��� � z$BlockStorageCloudMixin.create_volumec K st | � |�}| �|�}|s&t�d| ��| jjdj|jd�td|i�d�}t j |dd�}| j � | � | � | �d|��S )NzVolume %s not found.z/volumes/{volume_id}�� volume_idr rE zError updating volumer/ )rI r: r rH r �putr r< r2 r r r+ rL r> r( )r! r8 rQ r r4 r r r r � update_volume� s � �� z$BlockStorageCloudMixin.update_volumec C sb | � |�}|s t�dj|d���| jjdj|d d�dd|iid�}tj|d j|d d �d � d S ) ad Set a volume's bootable flag. :param name_or_id: Name, unique ID of the volume or a volume dict. :param bool bootable: Whether the volume should be bootable. (Defaults to True) :raises: OpenStackCloudTimeout if wait time exceeded. :raises: OpenStackCloudException on operation error. z"Volume {name_or_id} does not exist)r8 �volumes/{id}/actionr< r; zos-set_bootablerG rE z)Error setting bootable on volume {volume}rD r/ N)r: r rH r r rK r r )r! r8 rG r r4 r r r rN s" �� ���z*BlockStorageCloudMixin.set_volume_bootableFc C s( | j �| � | �|�}|s4| jjdd|idd� dS t�d��� zN|rnt�| j j dj |d d �d d id �� n t�| j � d j |d d ��� W n: t jy� | j�dj |d d �� Y W d � dS 0 W d � n1 s�0 Y | j �| � |�r$t�|d�D ] }| �|d ��s �q$�qdS )a� Delete a volume. :param name_or_id: Name or unique ID of the volume. :param wait: If true, waits for volume to be deleted. :param timeout: Seconds to wait for volume deletion. None is forever. :param force: Force delete volume even if the volume is in deleting or error_deleting state. :raises: OpenStackCloudTimeout if wait time exceeded. :raises: OpenStackCloudException on operation error. z$Volume %(name_or_id)s does not existr8 T��exc_infoFzError in deleting volumerY r< r; �os-force_deleteNrE z volumes/{id}z.Volume {id} not found when deleting. Ignoring.z-Timeout waiting for the volume to be deleted.)r+ rL r: r r r Zshade_exceptionsr r r rK r �deleter r r rM )r! r8 rO rP �forcer rS r r r � delete_volume' sF � � � ��2 � z$BlockStorageCloudMixin.delete_volumec C sB g }| j |d�D ],}|d D ] }|d |d kr |�|� q q|S )N)r) � attachments� server_idr< )r+ �append)r! �serverr) r r �attachr r r � get_volumesY s z"BlockStorageCloudMixin.get_volumesc C sj i }d}d}|rD| � |�}|s(t�d��|j}||d< dj||d�}t�| jjd|d��}| � d |�}|S ) a+ Get volume limits for a project :param name_or_id: (optional) project name or ID to get limits for if different from the current project :raises: OpenStackCloudException if it's not a valid project :returns: Munch object with the limits NzFailed to get limits�project does not exist� tenant_idz!{msg} for the project: {project} )�msg�projectz/limitsr- �limits) � get_projectr rH r< r r r r r r( )r! r8 r. � project_id� error_msg�projr rj r r r �get_volume_limitsa s" �� z(BlockStorageCloudMixin.get_volume_limitsc C s | � |�}|r|d S d S )Nr< �r: )r! r8 r r r r � get_volume_id| s z$BlockStorageCloudMixin.get_volume_idc C s | � |�d uS �Nrp )r! r8 r r r � volume_exists� s z$BlockStorageCloudMixin.volume_existsc C s* |d D ] }||d kr|d S qdS )aF Return the device name a volume is attached to for a server. This can also be used to verify if a volume is attached to a particular server. :param volume: Volume dict :param server_id: ID of server to check :returns: Device name if attached, None if volume is not attached. r` ra �deviceNr )r! r ra rd r r r �get_volume_attach_device� s z/BlockStorageCloudMixin.get_volume_attach_devicec C s� t j| j�dj|d |d d��dj|d |d d�d� |r�t�|d|d �D ]t}z| �|d �}W n, ty� | j j d|d d d � Y qRY n0 |d d kr� d S |d dkrRt � d|d ��qRd S )a� Detach a volume from a server. :param server: The server dict to detach from. :param volume: The volume dict to detach. :param wait: If true, waits for volume to be detached. :param timeout: Seconds to wait for volume detachment. None is forever. :raises: OpenStackCloudTimeout if wait time exceeded. :raises: OpenStackCloudException on operation error. z6/servers/{server_id}/os-volume_attachments/{volume_id}r< )ra rV z4Error detaching volume {volume} from server {server})r rc r/ z(Timeout waiting for volume %s to detach.� Error getting volume info %sTrZ r r Nr z Error in detaching volume %s) r r �computer] r r rM r: � Exceptionr r r rH )r! rc r rO rP rS �volr r r � detach_volume� s8 �� �� � � �z$BlockStorageCloudMixin.detach_volumec C sb | � ||d �}|r0t�d|d |d |f ��|d dkrVt�d|d |d f ��d|d i}|rn||d< tj| jjdj|d d �t|d �d �d j|d |d d �d�}|�rPt � |d|d �D ]�} z | j � | � | � |d �} W n. t�y | jjd|d dd� Y q�Y n0 | � | |d ��r0 �qP| d dkr�t�d|d ��q�| �| �d|��S )a� Attach a volume to a server. This will attach a volume, described by the passed in volume dict (as returned by get_volume()), to the server described by the passed in server dict (as returned by get_server()) on the named device on the server. If the volume is already attached to the server, or generally not available, then an exception is raised. To re-attach to a server, but under a different device, the user must detach it first. :param server: The server dict to attach to. :param volume: The volume dict to attach. :param device: The device name where the volume will attach. :param wait: If true, waits for volume to be attached. :param timeout: Seconds to wait for volume attachment. None is forever. :returns: a volume attachment object. :raises: OpenStackCloudTimeout if wait time exceeded. :raises: OpenStackCloudException on operation error. r< z4Volume %s already attached to server %s on device %sr r z*Volume %s is not available. Status is '%s'ZvolumeIdrt z*/servers/{server_id}/os-volume_attachments)ra )�volumeAttachmentrE z8Error attaching volume {volume_id} to server {server_id})rV ra r/ z(Timeout waiting for volume %s to attach.rv TrZ r z Error in attaching volume %sr{ )ru r rH r r rw rK r r2 r rM r+ rL r: rx r r Z _normalize_volume_attachmentr( ) r! rc r rt rO rP �devrR r rS ry r r r � attach_volume� sf �� �� ���� � � � �z$BlockStorageCloudMixin.attach_volumec C sp |� d|� dd ��}|� d|� dd ��}|rJ| j�d�rB||d< n||d< |rl| j�d�rd||d< n||d< |S )N�name� display_name� description�display_description� )rJ r Z_version_matches)r! rQ r~ r� r r r rI s � z)BlockStorageCloudMixin._get_volume_kwargsr~ r r� r� c K s� | � |�}||d�}|�|� | jjdt|d�d�}tj|dj|d�d�}| �d|�} |r�| d } t � |d �D ]4} | � | �} | d d kr� q�| d d krnt � d��qn| S )aA Create a volume. :param volume_id: the ID of the volume to snapshot. :param force: If set to True the snapshot will be created even if the volume is attached to an instance, if False it will not :param name: name of the snapshot, one will be generated if one is not provided :param description: description of the snapshot, one will be generated if one is not provided :param wait: If true, waits for volume snapshot to be created. :param timeout: Seconds to wait for volume snapshot creation. None is forever. :returns: The created volume object. :raises: OpenStackCloudTimeout if wait time exceeded. :raises: OpenStackCloudException on operation error. )rV r^ � /snapshots)�snapshotrE z-Error creating snapshot of volume {volume_id}rU r/ r� r< z8Timeout waiting for the volume snapshot to be available.r r r z!Error in creating volume snapshot)rI �updater rK r2 r r r r( r rM �get_volume_snapshot_by_idr rH ) r! rV r^ rO rP rQ rR r4 r r� � snapshot_idrS r r r �create_volume_snapshot s8 ��� � �z-BlockStorageCloudMixin.create_volume_snapshotc C s< | j �dj|d��}tj|dj|d�d�}| �| �d|��S )z�Takes a snapshot_id and gets a dict of the snapshot that maches that ID. Note: This is more efficient than get_volume_snapshot. param: snapshot_id: ID of the volume snapshot. �/snapshots/{snapshot_id}�r� z$Error getting snapshot {snapshot_id}r/ r� r= )r! r� r4 r r r r r� M s ��� �z0BlockStorageCloudMixin.get_volume_snapshot_by_idc C s t �| d||�S )a� Get a volume by name or ID. :param name_or_id: Name or ID of the volume snapshot. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :returns: A volume ``munch.Munch`` or None if no matching volume is found. Zvolume_snapshotr6 r7 r r r �get_volume_snapshot_ s �z*BlockStorageCloudMixin.get_volume_snapshotc C s� ||||||d�} | j jdt| d�d�} tj| dj|d�d�} | �d| �} |r�| d } d �| �}t�||�D ]<}| � | �} | d d kr� q�| d d krlt � dj| d���ql| S )a� Create a volume backup. :param volume_id: the ID of the volume to backup. :param name: name of the backup, one will be generated if one is not provided :param description: description of the backup, one will be generated if one is not provided :param force: If set to True the backup will be created even if the volume is attached to an instance, if False it will not :param wait: If true, waits for volume backup to be created. :param timeout: Seconds to wait for volume backup creation. None is forever. :param incremental: If set to true, the backup will be incremental. :param snapshot_id: The UUID of the source snapshot to back up. :returns: The created volume backup object. :raises: OpenStackCloudTimeout if wait time exceeded. :raises: OpenStackCloudException on operation error. )r~ rV r� r^ � incrementalr� �/backups)�backuprE z+Error creating backup of volume {volume_id}rU r/ r� r< z8Timeout waiting for the volume backup {} to be availabler r r z$Error in creating volume backup {id}r; ) r rK r2 r r r r( r rM �get_volume_backupr rH )r! rV r~ r� r^ rO rP r� r� rR r4 r r� � backup_idrh r* r r r �create_volume_backupx sB � ��� � ��z+BlockStorageCloudMixin.create_volume_backupc C s t �| d||�S )z�Get a volume backup by name or ID. :returns: A backup ``munch.Munch`` or None if no matching backup is found. � volume_backupr6 r7 r r r r� � s �z(BlockStorageCloudMixin.get_volume_backupc C s6 |rdnd}| j j||d�}tj|dd�}| �d|�S )zcList all volume snapshots. :returns: A list of volume snapshots ``munch.Munch``. z/snapshots/detailr� r- z!Error getting a list of snapshotsr/ Z snapshots�r r r r r( �r! ZdetailedZ search_optsr r4 r r r r �list_volume_snapshots� s ��z,BlockStorageCloudMixin.list_volume_snapshotsc C s6 |rdnd}| j j||d�}tj|dd�}| �d|�S )a List all volume backups. :param bool detailed: Also list details for each entry :param dict search_opts: Search options A dictionary of meta data to use for further filtering. Example:: { 'name': 'my-volume-backup', 'status': 'available', 'volume_id': 'e126044c-7b4c-43be-a32a-c9cbbc9ddb56', 'all_tenants': 1 } :returns: A list of volume backups ``munch.Munch``. z/backups/detailr� r- z Error getting a list of backupsr/ Zbackupsr� r� r r r �list_volume_backups� s ��z*BlockStorageCloudMixin.list_volume_backupsc C s� | � |�}|sdS d}|r<| jjdj|d d�ddid�}n| j�d j|d d��}tj||d � |r�d }t�||�D ]}| � |d �sv q�qvd S ) a� Delete a volume backup. :param name_or_id: Name or unique ID of the volume backup. :param force: Allow delete in state other than error or available. :param wait: If true, waits for volume backup to be deleted. :param timeout: Seconds to wait for volume backup deletion. None is forever. :raises: OpenStackCloudTimeout if wait time exceeded. :raises: OpenStackCloudException on operation error. Fz Error in deleting volume backupz/backups/{backup_id}/actionr< )r� r\ NrE z/backups/{backup_id}r/ z4Timeout waiting for the volume backup to be deleted.T) r� r rK r r] r r r rM ) r! r8 r^ rO rP r� rh r4 rS r r r �delete_volume_backup� s. ����z+BlockStorageCloudMixin.delete_volume_backupc C sd | � |�}|sdS | j�dj|d d��}tj|dd� |r`t�|d�D ]}| � |d �sH q`qHdS ) a� Delete a volume snapshot. :param name_or_id: Name or unique ID of the volume snapshot. :param wait: If true, waits for volume snapshot to be deleted. :param timeout: Seconds to wait for volume snapshot deletion. None is forever. :raises: OpenStackCloudTimeout if wait time exceeded. :raises: OpenStackCloudException on operation error. Fr� r< r� z!Error in deleting volume snapshotr/ z6Timeout waiting for the volume snapshot to be deleted.T)r� r r] r r r r rM )r! r8 rO rP Zvolumesnapshotr4 rS r r r �delete_volume_snapshot s( ����z-BlockStorageCloudMixin.delete_volume_snapshotc C s | � � }t�|||�S rr )r+ r � _filter_list)r! r8 r9 r r r r �search_volumes+ s �z%BlockStorageCloudMixin.search_volumesc C s | � � }t�|||�S rr )r� r r� )r! r8 r9 Zvolumesnapshotsr r r �search_volume_snapshots0 s �z.BlockStorageCloudMixin.search_volume_snapshotsc C s | � � }t�|||�S rr )r� r r� )r! r8 r9 Zvolume_backupsr r r �search_volume_backups5 s �z,BlockStorageCloudMixin.search_volume_backupsc C s | j |d�}t�|||�S )N)r3 )r5 r r� )r! r8 r9 r3 r1 r r r �search_volume_types: s z*BlockStorageCloudMixin.search_volume_typesc C sZ | � |�}|s t�d| ��| j�dj|jd��}tj|dj|d�d�}| � | � d|��S )z�Return a list of volume_type_access. :param name_or_id: Name or ID of the volume type. :raises: OpenStackCloudException on operation error. �VolumeType not found: %sz!/types/{id}/os-volume-type-accessr; z'Unable to get volume type access {name})r~ r/ Zvolume_type_access) rA r rH r r r r< r r Z _normalize_volume_type_accessesr( )r! r8 r@ r4 r r r r �get_volume_type_access? s" � ��� �z-BlockStorageCloudMixin.get_volume_type_accessc C s` | � |�}|s t�d| ��d|i}| jjdj|jd�t|d�d�}tj |dj||d�d � d S ) a Grant access on a volume_type to a project. :param name_or_id: ID or name of a volume_type :param project_id: A project id NOTE: the call works even if the project does not exist. :raises: OpenStackCloudException on operation error. r� ri �/types/{id}/actionr; )ZaddProjectAccessrE z7Unable to authorize {project} to use volume type {name}�r~ ri r/ N� rA r rH r rK r r< r2 r r �r! r8 rl r@ rR r4 r r r �add_volume_type_accessT s � ���z-BlockStorageCloudMixin.add_volume_type_accessc C s` | � |�}|s t�d| ��d|i}| jjdj|jd�t|d�d�}tj |dj||d�d � d S ) z�Revoke access on a volume_type to a project. :param name_or_id: ID or name of a volume_type :param project_id: A project id :raises: OpenStackCloudException on operation error. r� ri r� r; )ZremoveProjectAccessrE z4Unable to revoke {project} to use volume type {name}r� r/ Nr� r� r r r �remove_volume_type_accessl s � ���z0BlockStorageCloudMixin.remove_volume_type_accessc K sR | � |�}|st�d��|j|d< | jjdj|jd�d|id�}tj|dd� d S ) a Set a volume quota in a project :param name_or_id: project name or id :param kwargs: key/value pairs of quota name and quota value :raises: OpenStackCloudException if the resource to set the quota does not exist. rf rg �/os-quota-sets/{tenant_id}�rg � quota_setrE zNo valid quota or resourcer/ N) rk r rH r< r rW r r r )r! r8 rQ rn r4 r r r �set_volume_quotas� s ��z(BlockStorageCloudMixin.set_volume_quotasc C sH | � |�}|st�d��| j�dj|jd��}tj|dd�}| � d|�S )z� Get volume quotas for a project :param name_or_id: project name or id :raises: OpenStackCloudException if it's not a valid project :returns: Munch object with the quotas rf r� r� �cinder client call failedr/ r� ) rk r rH r r r r< r r r( )r! r8 rn r4 r r r r �get_volume_quotas� s ��z(BlockStorageCloudMixin.get_volume_quotasc C s< | � |�}|st�d��| j�dj|jd��}tj|dd�S )z� Delete volume quotas for a project :param name_or_id: project name or id :raises: OpenStackCloudException if it's not a valid project or the cinder client call failed :returns: dict with the quotas rf r� r� r� r/ ) rk r rH r r] r r< r r )r! r8 rn r4 r r r �delete_volume_quotas� s ��z+BlockStorageCloudMixin.delete_volume_quotas)T)T)N)N)TNNN)T)NTNF)T)N)TN)NTN)FTN)N)NNFTNFN)N)TN)TN)NFFN)NFN)NN)NN)NN)NNT)+�__name__� __module__� __qualname__r Zcache_on_argumentsr r+ r5 r: r? rA rT rX rN r_ re ro rq rs ru rz r} rI Z valid_kwargsr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r " sp 9 � H � 2 ' � K� � 4 � : � & � " � r ) �typesr% Zopenstack.cloudr r r Z openstackr r r Z Normalizerr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка