Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/image/v2/__pycache__/_proxy.cpython-39.pyc
Ðазад
a u�h#� � @ s� d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlm Z d dlm Z d dlm Z d dlmZ d d lmZ d d lmZ d Zd Zd ZG dd� dej�ZdS )� N)� exceptions)� _base_proxy)�image)�member)�schema)�task)� service_info)�resource)�utilsz+Image cannot be imported. Error code: '396')Zmin_diskZmin_ram�sizeZ virtual_size)Z protected�tagsc @ sR e Zd Zdd� ZdUdd�ZdVdd�ZdWd d �ZdXd d�Zdd� ZdYdd�Z dd� Z dd� Z dd� Z dZdd�Z d[d d �Zd\d d �Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd]d0d1�Zd^d2d3�Zd4d5� Zd6d7� Zd8d9� Z d:d;� Z d<d=� Z d>d?� Z d@dA� Z dBdC� Z!dDdE� Z"dFdG� Z#d_dKdL�Z$dMdN� Z%dOdP� Z&dQdR� Z'dSdT� Z(dS )`�Proxyc K s | j tjfi |��S )z.Create image resource from attributes )�_create�_image�Image��self�kwargs� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/image/v2/_proxy.py� _create_image" s zProxy._create_image� glance-directNc C s� | � tj|�}|r$|s|r$t�d��|durH|r:t�d��| � tj|�}|pNg }g }|D ]} |�| � tj| �� qX|}t|j |j g�s�t�d��|j | ||||||d� dS )u� Import data to an existing image Interoperable image import process are introduced in the Image API v2.6. It mainly allow image importing from an external url and let Image Service download it by itself without sending binary data at image creation. :param image: The value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance. :param method: Method to use for importing the image. A valid value is glance-direct or web-download. :param uri: Required only if using the web-download import method. This url is where the data is made available to the Image service. :param store: Used when enabled_backends is activated in glance. The value can be the id of a store or a :class:`~openstack.image.v2.service_info.Store` instance. :param stores: List of stores to be used when enabled_backends is activated in glance. List values can be the id of a store or a :class:`~openstack.image.v2.service_info.Store` instance. :param all_stores: Upload to all available stores. Mutually exclusive with ``store`` and ``stores``. :param all_stores_must_succeed: When set to True, if an error occurs during the upload in at least one store, the worfklow fails, the data is deleted from stores where copying is done (not staging), and the state of the image is unchanged. When set to False, the workflow will fail (data deleted from stores, …) only if the import fails on all stores specified by the user. In case of a partial success, the locations added to the image will be the stores where the data has been correctly uploaded. Default is True. :returns: None z6all_stores is mutually exclusive with store and storesNz'store and stores are mutually exclusivezIBoth container_format and disk_format are required for importing an image)�method�uri�store�stores� all_stores�all_stores_must_succeed) � _get_resourcer r r �InvalidRequest�_si�Store�append�all�container_format� disk_format� import_image) r r r r r r r r Z new_stores�sr r r r& ' s6 0 ����zProxy.import_imagec C s` | � tj|�}d|jkr,t�dj|jd���|r>t|d�|_n |rH||_|� | � |� | � |S )a� Stage binary image data :param image: The value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance. :param filename: Optional name of the file to read data from. :param data: Optional data to be uploaded as an image. :returns: The results of image creation :rtype: :class:`~openstack.image.v2.image.Image` ZqueuedzVImage stage is only possible for images in the queued state. Current state is {status})�status�rb) r r r r( r � SDKException�format�open�data�stage�fetch)r r �filenamer- r r r � stage_imagew s � zProxy.stage_imagec K sN t �d� t||g�s t�d��| jtjf||d�|��}||_|� | � |S )aM Create and upload a new image from attributes .. warning: This method is deprecated - and also doesn't work very well. Please stop using it immediately and switch to `create_image`. :param container_format: Format of the container. A valid value is ami, ari, aki, bare, ovf, ova, or docker. :param disk_format: The format of the disk. A valid value is ami, ari, aki, vhd, vmdk, raw, qcow2, vdi, or iso. :param data: The data to be uploaded as an image. :param dict attrs: Keyword arguments which will be used to create a :class:`~openstack.image.v2.image.Image`, comprised of the properties on the Image class. :returns: The results of image creation :rtype: :class:`~openstack.image.v2.image.Image` z5upload_image is deprecated. Use create_image instead.z2Both container_format and disk_format are required)r% r$ ) �warnings�warnr# r r r r r r- �upload)r r$ r% r- �attrsZimgr r r � upload_image� s � �� zProxy.upload_imageFTc K s� d| d v r0| d � d�} | r(d| d< nd| d< z`| jjrh|rHt�d��| j||f||||d�| ��W S | j||f||||| | | d�| ��W S W n^ tjy� | jjd d d � � Y n: t y� } z"t�d j t |�d ���W Y d }~n d }~0 0 d S )N� is_public� properties�publicZ visibility�privatez�The Glance Task API and Import API are mutually exclusive. Either disable image_api_use_tasks in config, or do not request using import)r- �meta�wait�timeout)r- r; �validate_checksum� use_importr r r zImage creation failedT)�exc_info� Image creation failed: {message}��message) �pop� _connectionZimage_api_use_tasksr r* �_upload_image_task�_upload_image_put�log�debug� Exceptionr+ �str)r �namer0 r- r; r< r= r> r? r r r r r7 �er r r � _upload_image� sL ������� �zProxy._upload_imagec C sn i }t |�� �D ]N\}}|tv r.t|�||< q|tv r@|||< q|d u rRd ||< qt|�||< q|�|� |S )N)�iter�items�_INT_PROPERTIES�int�_RAW_PROPERTIESrK �update)r r; r8 �ret�k�vr r r �_make_v2_image_params� s zProxy._make_v2_image_paramsc K sV |r|st |d�} n|} | �di �} | �| �|| �� || d< | jtjfi | ��} | | _| jofd| jv }|st|st| rxd}|r�|s�t � d��z�|s�| � | �}t � |� |r�| � | � | �| � | �| j�}| �| j�}|�r |s�|�r | �| �}|�d�}|�r ||k�p||k}|�s td��W n0 t�yP | j�d |� | �| j� � Y n0 | S ) Nr) r8 rL r TzUImporting image was requested but the cloud does not support the image import method.�checksumz"Image checksum verification failedz"Deleting failed upload of image %s)r, rD rT rX r r r r- Zimage_import_methodsr r* r4 Zraise_from_responser. r& �get�_IMAGE_MD5_KEY�_IMAGE_SHA256_KEYr/ rJ rH rI � delete_image�id)r rL r0 r- r; r> r? r r r � image_kwargsZ image_datar8 r Zsupports_import�response�md5�sha256rY Zvalidr r r rG sP � � � zProxy._upload_image_putc K s | j �d�s$t�dj| j jjd���|�di �}|| j } || j } || j � dd�d } |� dd � |� d d � | j � | � | j j| ||f| | || j jd id �d td �d��� tdtdj| |d�t|d�d�d�} | jf i | ��} | j j�| � |�r t�� }z�zz| j| d|d�} | jd }| �|�}|j�� }|�|� di �� ||d< | j |fi |��}| j � d| j |t�� | � W nJ tj �y� } z.| �!| �} tjdj|j"d�| d��W Y d }~n d }~0 0 W | j �#| |� | j j�| � n | j �#| |� | j j�| � 0 |S | S d S ) Nz object-storezrThe cloud {cloud} is configured to use tasks for image upload, but no object-store service is available. Aborting.)�cloudr8 �/� r r% r$ �true)ra rb r- �metadatazapplication/octet-streami�Q )z content-typezx-delete-after�importz{container}/{name})� containerrL )rL )Z import_fromZimage_properties)�type�input�success)r r( r< �image_idz Image Task %s imported %s in %srA rB )� extra_data)$rE Z has_servicer r* r+ �configrL rZ r[ r\ Z_IMAGE_OBJECT_KEY�splitrD Zcreate_containerZ create_objectZ_OBJECT_AUTOCREATE_KEYrK �dict� create_task� list_images� invalidate�time� wait_for_task�result� get_imager8 �copyrT � update_imagerH rI r^ �ResourceFailure�get_taskrC Z delete_object)r rL r0 r- r< r= r; r_ r8 ra rb ri � task_argsZ glance_task�startrm r �propsrM r r r rF > s� �� � ��� ���� � �� �zProxy._upload_image_taskc C s� t |tj�s tjjf i |��}|j�� }t| �||��� �D ] \}}|� |d �|kr<|||< q<|sfdS | j |fi |�� | j j � | j � dS )NFT)� isinstancer r �existingr8 ry rO rX rP rZ rz rE rs rt )r r r; r8 Z img_propsrV rW r r r �_update_image_properties� s z Proxy._update_image_propertiesc K s t jjf d| ji|��S )N� connection)r r r� rE r r r r �_existing_image� s zProxy._existing_image� c C s | � tj|�}|j| |||d�S )a� Download an image This will download an image to memory when ``stream=False``, or allow streaming downloads using an iterator when ``stream=True``. For examples of working with streamed responses, see :ref:`download_image-stream-true`. :param image: The value can be either the ID of an image or a :class:`~openstack.image.v2.image.Image` instance. :param bool stream: When ``True``, return a :class:`requests.Response` instance allowing you to iterate over the response data stream instead of storing its entire contents in memory. See :meth:`requests.Response.iter_content` for more details. *NOTE*: If you do not consume the entirety of the response you must explicitly call :meth:`requests.Response.close` or otherwise risk inefficiencies with the ``requests`` library's handling of connections. When ``False``, return the entire contents of the response. :param output: Either a file object or a path to store data into. :param int chunk_size: size in bytes to read from the wire and buffer at one time. Defaults to 1024 :returns: When output is not given - the bytes comprising the given Image when stream is False, otherwise a :class:`requests.Response` instance. When output is given - a :class:`~openstack.image.v2.image.Image` instance. )�stream�output� chunk_size)r r r �download)r r r� r� r� r r r �download_image� s $�zProxy.download_imagec C s | j tj||d� dS )a Delete an image :param image: The value can be either the ID of an image or a :class:`~openstack.image.v2.image.Image` instance. :param bool ignore_missing: When set to ``False`` :class:`~openstack.exceptions.ResourceNotFound` will be raised when the image does not exist. When set to ``True``, no exception will be set when attempting to delete a nonexistent image. :returns: ``None`` ��ignore_missingN)�_deleter r )r r r� r r r r] � s zProxy.delete_imagec C s | j tj||d�S )a� Find a single image :param name_or_id: The name or ID of a image. :param bool ignore_missing: When set to ``False`` :class:`~openstack.exceptions.ResourceNotFound` will be raised when the resource does not exist. When set to ``True``, None will be returned when attempting to find a nonexistent resource. :returns: One :class:`~openstack.image.v2.image.Image` or None r� )�_findr r )r � name_or_idr� r r r � find_image� s �zProxy.find_imagec C s | � tj|�S )aT Get a single image :param image: The value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance. :returns: One :class:`~openstack.image.v2.image.Image` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. )�_getr r �r r r r r rx � s zProxy.get_imagec K s | j tjfi |��S )a Return a generator of images :param kwargs query: Optional query parameters to be sent to limit the resources being returned. :returns: A generator of image objects :rtype: :class:`~openstack.image.v2.image.Image` )�_listr r �r �queryr r r �images� s z Proxy.imagesc K s | j tj|fi |��S )aa Update a image :param image: Either the ID of a image or a :class:`~openstack.image.v2.image.Image` instance. :attrs kwargs: The attributes to update on the image represented by ``value``. :returns: The updated image :rtype: :class:`~openstack.image.v2.image.Image` )�_updater r )r r r5 r r r rz � s zProxy.update_imagec C s | � tj|�}|�| � dS �z�Deactivate an image :param image: Either the ID of a image or a :class:`~openstack.image.v2.image.Image` instance. :returns: None N)r r r Z deactivater� r r r �deactivate_image s zProxy.deactivate_imagec C s | � tj|�}|�| � dS r� )r r r Z reactivater� r r r �reactivate_image s zProxy.reactivate_imagec C s | � tj|�}|�| |� dS )a$ Add a tag to an image :param image: The value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance that the member will be created for. :param str tag: The tag to be added :returns: None N)r r r �add_tag�r r �tagr r r r� s z Proxy.add_tagc C s | � tj|�}|�| |� dS )a) Remove a tag to an image :param image: The value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance that the member will be created for. :param str tag: The tag to be removed :returns: None N)r r r � remove_tagr� r r r r� ) s zProxy.remove_tagc K s$ t j�|�}| jtjfd|i|��S )a: Create a new member from attributes :param image: The value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance that the member will be created for. :param dict attrs: Keyword arguments which will be used to create a :class:`~openstack.image.v2.member.Member`, comprised of the properties on the Member class. :returns: The results of member creation :rtype: :class:`~openstack.image.v2.member.Member` rm )r �Resource�_get_idr �_member�Member)r r r5 rm r r r � add_member6 s zProxy.add_memberc C s0 t j�|�}t j�|�}| jtj|||d� dS )a Delete a member :param member: The value can be either the ID of a member or a :class:`~openstack.image.v2.member.Member` instance. :param bool ignore_missing: When set to ``False`` :class:`~openstack.exceptions.ResourceNotFound` will be raised when the member does not exist. When set to ``True``, no exception will be set when attempting to delete a nonexistent member. :returns: ``None`` )� member_idrm r� N)r r� r� r� r� r� )r r r r� rm r� r r r � remove_memberF s �zProxy.remove_memberc C s t j�|�}| jtj|||d�S )a� Find a single member :param name_or_id: The name or ID of a member. :param image: This is the image that the member belongs to, the value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance. :param bool ignore_missing: When set to ``False`` :class:`~openstack.exceptions.ResourceNotFound` will be raised when the resource does not exist. When set to ``True``, None will be returned when attempting to find a nonexistent resource. :returns: One :class:`~openstack.image.v2.member.Member` or None )rm r� )r r� r� r� r� r� )r r� r r� rm r r r � find_memberX s �zProxy.find_memberc C s* t j�|�}t j�|�}| jtj||d�S )a2 Get a single member on an image :param member: The value can be the ID of a member or a :class:`~openstack.image.v2.member.Member` instance. :param image: This is the image that the member belongs to. The value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance. :returns: One :class:`~openstack.image.v2.member.Member` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. �r� rm )r r� r� r� r� r� )r r r r� rm r r r � get_memberj s �zProxy.get_memberc C s t j�|�}| jtj|d�S )a^ Return a generator of members :param image: This is the image that the member belongs to, the value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance. :returns: A generator of member objects :rtype: :class:`~openstack.image.v2.member.Member` )rm )r r� r� r� r� r� )r r rm r r r �members{ s z Proxy.membersc K s2 t j�|�}t j�|�}| jtjf||d�|��S )aD Update the member of an image :param member: Either the ID of a member or a :class:`~openstack.image.v2.member.Member` instance. :param image: This is the image that the member belongs to. The value can be the ID of a image or a :class:`~openstack.image.v2.image.Image` instance. :attrs kwargs: The attributes to update on the member represented by ``value``. :returns: The updated member :rtype: :class:`~openstack.image.v2.member.Member` r� )r r� r� r� r� r� )r r r r5 r� rm r r r � update_member� s ��zProxy.update_memberc C s | j tjddd�S )z�Get images schema :returns: One :class:`~openstack.image.v2.schema.Schema` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. Fz/schemas/images�Z requires_id� base_path�r� �_schemaZSchema�r r r r �get_images_schema� s �zProxy.get_images_schemac C s | j tjddd�S )z�Get single image schema :returns: One :class:`~openstack.image.v2.schema.Schema` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. Fz/schemas/imager� r� r� r r r �get_image_schema� s �zProxy.get_image_schemac C s | j tjddd�S )z�Get image members schema :returns: One :class:`~openstack.image.v2.schema.Schema` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. Fz/schemas/membersr� r� r� r r r �get_members_schema� s �zProxy.get_members_schemac C s | j tjddd�S )z�Get image member schema :returns: One :class:`~openstack.image.v2.schema.Schema` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. Fz/schemas/memberr� r� r� r r r �get_member_schema� s �zProxy.get_member_schemac K s | j tjfi |��S )a Return a generator of tasks :param kwargs query: Optional query parameters to be sent to limit the resources being returned. :returns: A generator of task objects :rtype: :class:`~openstack.image.v2.task.Task` )r� �_task�Taskr� r r r �tasks� s z Proxy.tasksc C s | � tj|�S )aK Get task details :param task: The value can be the ID of a task or a :class:`~openstack.image.v2.task.Task` instance. :returns: One :class:`~openstack.image.v2.task.Task` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. )r� r� r� )r r r r r r| � s zProxy.get_taskc K s | j tjfi |��S )aM Create a new task from attributes :param dict attrs: Keyword arguments which will be used to create a :class:`~openstack.image.v2.task.Task`, comprised of the properties on the Task class. :returns: The results of task creation :rtype: :class:`~openstack.image.v2.task.Task` )r r� r� )r r5 r r r rr � s zProxy.create_taskrl � �x c C s |du rdg}ndd� |D �}|j �� |�� kr4|S dj|jj|jd�}dj||d�}tj|||d �D ]�}|�| �}|s�t � d j||d���|j } | �� } | |�� kr�| S | |v �r|j t kr�t |j|jd �} | jf i | ��}| j�d | � nt � d j|| d���| j�d||| � qfdS )a_ Wait for a task to be in a particular status. :param task: The resource to wait on to reach the specified status. The resource must have a ``status`` attribute. :type resource: A :class:`~openstack.resource.Resource` object. :param status: Desired status. :param failures: Statuses that would be interpreted as failures. :type failures: :py:class:`list` :param interval: Number of seconds to wait before to consecutive checks. Default to 2. :param wait: Maximum number of seconds to wait before the change. Default to 120. :returns: The resource is returned on success. :raises: :class:`~openstack.exceptions.ResourceTimeout` if transition to the desired status failed to occur in specified seconds. :raises: :class:`~openstack.exceptions.ResourceFailure` if the resource has transited to one of the failure statuses. :raises: :class:`~AttributeError` if the resource does not have a ``status`` attribute. NZfailurec S s g | ] }|� � �qS r )�lower)�.0�fr r r � <listcomp>� � z'Proxy.wait_for_task.<locals>.<listcomp>z {res}:{id})�resr^ z4Timeout waiting for {name} to transition to {status})rL r( )r= rC r< z+{name} went away while waiting for {status})rk rj z!Got error 396. Recreating task %sz-{name} transitioned to failure state {status}zDStill waiting for resource %s to reach state %s, current state is %s)r( r� r+ � __class__�__name__r^ r Ziterate_timeoutr/ r r{ rC �_IMAGE_ERROR_396rq rk rj rr rH rI ) r r r( Zfailures�intervalr< rL �msg�countZ new_statusZnormalized_statusr} r r r rv � sL �� �� ���zProxy.wait_for_taskc C s | j tjddd�S )z�Get image tasks schema :returns: One :class:`~openstack.image.v2.schema.Schema` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. Fz/schemas/tasksr� r� r� r r r �get_tasks_schema$ s �zProxy.get_tasks_schemac C s | j tjddd�S )z�Get image task schema :returns: One :class:`~openstack.image.v2.schema.Schema` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. Fz /schemas/taskr� r� r� r r r �get_task_schema. s �zProxy.get_task_schemac K s | j tjfi |��S )z�Return a generator of supported image stores :returns: A generator of store objects :rtype: :class:`~openstack.image.v2.service_info.Store` )r� r r! r� r r r r 8 s z Proxy.storesc C s | j tjdd�S )z�Get a info about image constraints :returns: One :class:`~openstack.image.v2.service_info.Import` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no resource can be found. F)Z require_id)r� r �Importr� r r r �get_import_info@ s zProxy.get_import_info)r NNNNN)NN)NNN) NNNFNTFNNN)FNNN)FNr� )T)T)T)T)rl Nr� r� ))r� � __module__� __qualname__r r& r1 r6 rN rX rG rF r� r� r� r] r� rx r� rz r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r| rr rv r� r� r r� r r r r r sv � P � / � 0 � <H � ) � > r )ru r2 Z openstackr Zopenstack.imager Zopenstack.image.v2r r r r� r r� r r� r r r r r� rQ rS ZBaseImageProxyr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка