Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/__pycache__/resource.cpython-39.pyc
Ðазад
a t�h8O � @ sV d Z ddlZddlZddlZddlZddlZddlZddlm Z ddlm Z ddl Z ddl m Z ddlmZ ddlmZ ddlmZ dd lmZ d Zd(d d �ZG d d� d�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� dej�ZG dd� d�Z G dd � d �Z G d d � d e �Z G d d � d �Z d!d"� Z!d)d$d%�Z"d&d'� Z#dS )*a� The :class:`~openstack.resource.Resource` class is a base class that represent a remote resource. The attributes that comprise a request or response for this resource are specified as class members on the Resource subclass where their values are of a component type, including :class:`~openstack.resource.Body`, :class:`~openstack.resource.Header`, and :class:`~openstack.resource.URI`. For update management, :class:`~openstack.resource.Resource` employs a series of :class:`~openstack.resource._ComponentManager` instances to look after the attributes of that particular component type. This is particularly useful for Body and Header types, so that only the values necessary are sent in requests to the server. When making requests, each of the managers are looked at to gather the necessary URI, body, and header data to build a request to be sent via keystoneauth's sessions. Responses from keystoneauth are then converted into this Resource class' appropriate components and types and then returned to the caller. � N)�adapter)�discover)� structures)�_log)� exceptions)�format)�utilsz {name}_seenc C s� |s| S t |t�rbt| tttf�rL|s*| S g }| D ]}|�t||�� q2|S |r\t| |�gS | gS t| |�rp| S t| |�s�t |tj�r�|� | �S t| t �r�|f i | ��S || �S d S �N) � issubclass�list� isinstance�tuple�set�append� _convert_typer � FormatterZ deserialize�dict)�valueZ data_type� list_type�ret�raw� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/resource.pyr 6 s* r c @ s6 e Zd ZdZeZd dd�Zdd� Zdd� Zd d � Z dS ) �_BaseComponentNFc K sN || _ || _|dur&|r&|s&|� | _n|| _|| _|| _|| _|| _|| _dS )aT A typed descriptor for a component that makes up a Resource :param name: The name this component exists as on the server :param type: The type this component is expected to be by the server. By default this is None, meaning any value you specify will work. If you specify type=dict and then set a component to a string, __set__ will fail, for example. :param default: Typically None, but any other default can be set. :param alias: If set, alternative attribute on object to return. :param aka: If set, additional name attribute would be available under. :param alternate_id: When `True`, this property is known internally as a value that can be sent with requests that require an ID but when `id` is not a name the Resource has. This is a relatively uncommon case, and this setting should only be used once per Resource. :param list_type: If type is `list`, list_type designates what the type of the elements of the list should be. :param coerce_to_default: If the Component is None or not present, force the given default to be used. If a default is not given but a type is given, construct an empty version of the type in question. N)�name�type�default�alias�aka� alternate_idr �coerce_to_default) �selfr r r r r r r r �kwargsr r r �__init__\ s z_BaseComponent.__init__c C s� |d u r | S t || j�}z|| j }W np ty� | jr�tj| jd�}t ||d�s�tj| jd�}t||d� t || j�}t||� | Y S | j Y S 0 |d u r�d S t || j | j �S )N)r FT) �getattr�keyr �KeyErrorr � _SEEN_FORMATr �setattr�delattrr r r r )r! �instance�owner� attributesr Z alias_flagZ seen_flagr r r �__get__� s$ z_BaseComponent.__get__c C sH | j r|d u r| j}|| jkr.t|| j| j�}t|| j�}||| j< d S r )r r r r r r$ r% r )r! r* r r, r r r �__set__� s z_BaseComponent.__set__c C s0 zt || j�}|| j= W n ty* Y n0 d S r )r$ r% r r& )r! r* r, r r r � __delete__� s z_BaseComponent.__delete__)NNNNFNF) �__name__� __module__� __qualname__r% r �_map_clsr# r- r. r/ r r r r r U s � '% r c @ s e Zd ZdZdZdS )�BodyzBody attributes�_bodyN�r0 r1 r2 �__doc__r% r r r r r4 � s r4 c @ s e Zd ZdZdZejZdS )�HeaderzHeader attributes�_headerN)r0 r1 r2 r7 r% r �CaseInsensitiveDictr3 r r r r r8 � s r8 c @ s e Zd ZdZdZdS )�URIzURI attributes�_uriNr6 r r r r r; � s r; c @ s e Zd ZdZdZdS )�ComputedzComputed attributes� _computedNr6 r r r r r= � s r= c @ sX e Zd ZdZddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z e dd� �Z ddd�Z dS )�_ComponentManagerzStorage of a component typeNFc C s6 |d u rt � n|�� | _|r"t� n t| j�� �| _d S r )r �copyr, r �keys�_dirty)r! r, � synchronizedr r r r# � s z_ComponentManager.__init__c C s | j | S r )r, �r! r% r r r � __getitem__� s z _ComponentManager.__getitem__c C sL z| j | }W n ty$ d}Y n 0 ||k}|rH|| j |< | j�|� d S )NT)r, r& rB �add)r! r% r �orig�changedr r r � __setitem__� s z _ComponentManager.__setitem__c C s | j |= | j�|� d S r )r, rB rF rD r r r � __delitem__� s z _ComponentManager.__delitem__c C s t | j�S r )�iterr, �r! r r r �__iter__� s z_ComponentManager.__iter__c C s t | j�S r )�lenr, rL r r r �__len__� s z_ComponentManager.__len__c s t � fdd�� jD ��S )z$Return a dict of modified attributesc 3 s | ]}|� j �|d �fV qd S r )r, �get)�.0r% rL r r � <genexpr>� s �z*_ComponentManager.dirty.<locals>.<genexpr>)r rB rL r rL r �dirty� s �z_ComponentManager.dirtyc C s" |r| j t|� | _ nt� | _ dS )z�Signal that the resource no longer has modified attributes. :param only: an optional set of attributes to no longer consider changed N)rB r )r! �onlyr r r �clean� s z_ComponentManager.clean)NF)N) r0 r1 r2 r7 r# rE rI rJ rM rO �propertyrS rU r r r r r? � s r? c @ s e Zd ZdZdd� ZdS )�_Requestz.Prepared components that go into a KSA requestc C s || _ || _|| _d S r )�url�body�headers)r! rX rY rZ r r r r# s z_Request.__init__N)r0 r1 r2 r7 r# r r r r rW s rW c @ s& e Zd Zdd� Zd dd�Zdd� ZdS ) �QueryParametersc O s2 ddd�| _ | j �dd� |D �� | j �|� dS )at Create a dict of accepted query parameters :param names: List of strings containing client-side query parameter names. Each name in the list maps directly to the name expected by the server. :param mappings: Key-value pairs where the key is the client-side name we'll accept here and the value is the name the server expects, e.g, changes_since=changes-since. Additionally, a value can be a dict with optional keys name - server-side name, type - callable to convert from client to server representation. By default, both limit and marker are included in the initial mapping as they're the most common query parameters used for listing resources. �limit�marker)r\ r] c S s i | ] }||�qS r r )rQ r r r r � <dictcomp>" � z,QueryParameters.__init__.<locals>.<dictcomp>N)�_mapping�update)r! �namesZmappingsr r r r# s zQueryParameters.__init__NFc s� t | j�� �}|�dd� | j�� D �� |r:|t�|�7 }t� �� �t|� }|sV� S |sttj dd� |� |d��n(t� �� �� t|��}� fdd�|D �S dS ) a� Check that supplied query keys match known query mappings :param dict query: Collection of key-value pairs where each key is the client-side parameter name or server side name. :param base_path: Formatted python string of the base url path for the resource. : param allow_unknown_params: Exclude query params not known by the resource. :returns: Filtered collection of the supported QueryParameters c s s, | ]$\}}t |t�r |�d |�n|V qdS )r N)r r rP )rQ r% r r r r rR 2 s �z,QueryParameters._validate.<locals>.<genexpr>zInvalid query params: %s�,)�message� extra_datac s i | ]}|� | �qS r r )rQ �k��queryr r r^ E r_ z-QueryParameters._validate.<locals>.<dictcomp>N) r r` rA �extend�itemsr Zget_string_format_keysr r ZInvalidResourceQuery�join� intersection)r! rh � base_path�allow_unknown_paramsZexpected_paramsZ invalid_keysZ known_keysr rg r � _validate% s( ��� �zQueryParameters._validatec C s� i }| j �� D ]�\}}t|t�r8|�d|�}|�d�}n|}d}ztt�|�j�dk}W n t yn d}Y n0 ||v r�|| } n||v r|| } nq|dur�|r�|| |�||< q�|| �||< q| ||< q|S )a� Transpose the keys in query based on the mapping If a query is supplied with its server side name, we will still use it, but take preference to the client-side name when both are supplied. :param dict query: Collection of key-value pairs where each key is the client-side parameter name to be transposed to its server side name. :param resource_type: Class of a resource. r r N� F) r` rj r r rP rN �inspect� getargspec�args� TypeError) r! rh Z resource_type�resultZ client_side� server_sider �type_Zprovide_resource_typer r r r � _transposeG s. � zQueryParameters._transpose)NF)r0 r1 r2 r# ro rx r r r r r[ s "r[ c @ s e Zd ZdZdZdZed�Zed�Ze d�Z e � Z dZ dZdZdZdZdZdZdZdZdZdZdZd ZdZdZdZ dZ dZ dZ dZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)i Z*d�d d �Z+e,e-ee.g�fd d ��Z/dd� Z0dd� Z1dd� Z2dd� Z3dd� Z4dd� Z5d�dd�Z6d d � Z7d d � Z8d d!� Z9d"d#� Z:d$d%� Z;d&d'� Z<d(d)� Z=d*d+� Z>d,d-� Z?d.d/� Z@d0d1� ZAd2d3� ZBd4d5� ZCd6d7� ZDd8d9� ZEe,d:d;� �ZFe,d<d=� �ZGe,d>d?� �ZHe,d@dA� �ZIe,dBdC� �ZJe,dDdE� �ZKeLdFdG� �ZMe,dHdI� �ZNe,d�dJdK��ZOe,d�dLdM��ZPd�dNdO�ZQeQZReQZSd�dPdQ�ZTdRdS� ZUdTdU� ZVdVdW� ZWd�dXdY�ZXd�dZd[�ZYe,d\d]� �ZZe,d^d_� �Z[d`da� Z\d�dbdc�Z]d�ddde�Z^e,d�dfdg��Z_d�dhdi�Z`d�djdk�Zaebdldm� �Zcd�dndo�Zdd�dpdq�Zedrds� Zfd�dtdu�Zgd�dvdw�Zhdxdy� Zie,d�dzd{��Zje,d|d}� �Zke,d~d� �Zle,d�d�d���ZmdS )��ResourceN�idr �location� FT�PUT�POSTc K s || _ |�dd�| _| �|�\}}}}t||d�| _t||d�| _t||d�| _t||d�| _| j sj| j r�|r~| jj � � | _ n"| jr�| �� p�d| ji| _ ni | _ | jr�t| jd�o�| jjjdu | _| �� | �� D ]\}} | jr�|| j| j< q�t�| | �� � dS )aD The base resource :param bool _synchronized: This is not intended to be used directly. See :meth:`~openstack.resource.Resource.new` and :meth:`~openstack.resource.Resource.existing`. :param openstack.connection.Connection connection: Reference to the Connection being used. Defaults to None to allow Resource objects to be used without an active Connection, such as in unit tests. Use of ``self._connection`` in Resource code should protect itself with a check for None. � microversionN)r, rC rz � properties) � _connection�popr �_collect_attrsr? r5 r9 r< r> �commit_jsonpatch� allow_patchr, r@ �_original_bodyrz � _alternate_id�"_store_unknown_attrs_as_properties�hasattr� __class__r� r �_update_location�_attributes_iteratorr � _attr_aliasesr ra �to_dict) r! � _synchronized� connection�attrsrY �header�uri�computed�attr� componentr r r r# � sF ���� � �zResource.__init__c c s8 | j D ],}|j�� D ] \}}t||�r||fV qqdS )z.Iterator over all Resource attributes N)�__mro__�__dict__rj r )�cls� components�klassr� r� r r r r� s z Resource._attributes_iteratorc C s` dd� t t�| jj�� | jj�� | jj�� | jj�� ���� D �}d� |�}d| j | j j |f S )Nc S s( g | ] \}}d ||dur |ndf �qS )z%s=%sN�Noner �rQ rf �vr r r � <listcomp> s �z%Resource.__repr__.<locals>.<listcomp>�, z %s.%s(%s)) r � itertools�chainr5 r, rj r9 r< r> rk r1 r� r0 )r! �pairsrs r r r �__repr__ s �� �zResource.__repr__c C sN t |t�sdS t| jj|jjk| jj|jjk| jj|jjk| jj|jjkg�S )z5Return True if another resource has the same contentsF)r ry �allr5 r, r9 r< r> )r! Z comparandr r r �__eq__* s �zResource.__eq__c C s� |dkrD|| j v r | j | S z| j | �� W S ty@ Y dS 0 n`zt�| |�W S ty� } z8|| jv r�t�| | j| �W Y d}~S |�W Y d}~n d}~0 0 dS )z�Return an attribute on this instance This is mostly a pass-through except for a specialization on the 'id' name, as this can exist under a different name via the `alternate_id` argument to resource.Body. rz N)r5 r� r& �object�__getattribute__�AttributeErrorr� )r! r �er r r r� 5 s �zResource.__getattribute__c C sT t | j|d�}|s4|| jv r4| j| }t | j|d�}t|t�rHt | |�S t|��dS )z9Provide dictionary access for elements of the data model.N)r$ r� r� r r r& )r! r � real_itemr r r rE N s zResource.__getitem__c C s t | |� d S r )r) )r! r r r r rJ \ s zResource.__delitem__c C sD t | j|d �}t|t�r&| �||� ntdj| j| jj|d���d S )Nzm{name} is not found. {module}.{cls} objects do not support setting arbitrary keys through the dict interface.)�moduler� r ) r$ r� r r � __setattr__r& r r1 r0 )r! r r r� r r r rI _ s ��zResource.__setitem__c C s^ g }|st ttttg�}| �|�D ]6\}}|s2|n|j}|�|� |r"|jr"|�|j� q"|S )z.Generate list of supported attributes ) r r4 r8 r= r; r� r r r )r! Z remote_namesr� Zinclude_aliasesr, r� r� r% r r r � _attributesl s zResource._attributesc C s | � � S r )r� rL r r r rA } s z Resource.keysc C s( g }| � � D ]}|�|| | f� q |S r )r� r )r! �resr� r r r rj � s zResource.itemsc K sl |� dd�| _| �|�\}}}}| j�|� | j�|� | j�|� | j�|� | �� t �| | � � � dS )z�Given attributes, update them on this instance This is intended to be used from within the proxy layer when updating instances that may have already been created. r N) r� r r� r5 ra r9 r< r> r� r r� �r! r� rY r� r� r� r r r �_update� s zResource._updatec C s� | � |�}| �|�}| �|�}|r4| jr4| �||�}t|||g�r�| �|||�}|�| �| � � |�� |�| �| � � |�� |�| �| � � |�� | �| � � |�}| j r�|�d| j j� ||||fS )z�Given attributes, return a dict per type of attribute This method splits up **attrs into separate dictionaries that correspond to the relevant body, header, and uri attributes that exist on this class. r{ )�_consume_body_attrs�_consume_header_attrs�_consume_uri_attrsr� � _pack_attrs_under_properties�any�_compute_attributesra �_consume_attrs� _body_mapping�_header_mapping� _uri_mapping�_computed_mappingr� � setdefaultZcurrent_locationr� r r r r� � s zResource._collect_attrsc C sR | j s dS i }t| d�r"| j|d< t| d�r6| j|d< |rN| j jf i |��| _dS )a� Update location to include resource project/zone information. Location should describe the location of the resource. For some resources, where the resource doesn't have any such baked-in notion we assume the resource exists in the same project as the logged-in user's token. However, if a resource contains a project_id, then that project is where the resource lives, and the location should reflect that. N� project_id�availability_zone�zone)r� r� r� r� Z_get_current_locationr{ )r! r" r r r r� � s zResource._update_locationc C s i S )z7Compute additional attributes from the remote resource.r )r! rY r� r� r r r r� � s z Resource._compute_attributesc C s | � t|�S r )�_consume_mapped_attrsr4 �r! r� r r r r� � s z Resource._consume_body_attrsc C s | � t|�S r )r� r8 r� r r r r� � s z Resource._consume_header_attrsc C s | � t|�S r )r� r; r� r r r r� � s zResource._consume_uri_attrsc C s& | � |�}| jj�|� | j�� d S r )r� r5 r, ra rU )r! r� rY r r r �_update_from_body_attrs� s z Resource._update_from_body_attrsc C s& | � |�}| jj�|� | j�� d S r )r� r9 r, ra rU )r! r� rZ r r r �_update_from_header_attrs� s z"Resource._update_from_header_attrsc C s& | � |�}| jj�|� | j�� d S r )r� r< r, ra rU )r! r� r� r r r �_update_uri_from_attrs� s z Resource._update_uri_from_attrsc C s | � |�}| �||�S r )� _get_mappingr� )r! Z mapping_clsr� �mappingr r r r� � s z Resource._consume_mapped_attrsc C s� i }g }|� � D ]\\}}||�� v s.|�|�r|� � D ]2\}}|�� |�� |�� fv r6|||< |�|� q6qq|D ]}|�|� qr|S )a� Given a mapping and attributes, return relevant matches This method finds keys in attrs that exist in the mapping, then both transposes them to their server-side equivalent key name to be returned, and finally pops them out of attrs. This allows us to only calculate their place and existence in a particular type of Resource component one time, rather than looking at the same source dict several times. )rj �valuesrP �lowerr r� ) r! r� r� Zrelevant_attrsZ consumed_keysr% r Zmap_keyZ map_valuer r r r� s zResource._consume_attrsc C sB | j j|d� | js| jr>|D ] }|| j v r | j | | j|< q dS )z"Mark the attributes as up-to-date.)rT N)r5 rU r� r� r� )r! r� r� r r r �_clean_body_attrs! s zResource._clean_body_attrsc C sT |� � }|� � }| �|�D ]\}}||vr|j||< q|�� D ]\}}|||< q>|S )z=Return a dict of attributes of a given component on the class)r3 r� r rj )r� r� r� r r% r rf r� r r r r� ) s zResource._get_mappingc C s | � t�S )z%Return all Body members of this class)r� r4 �r� r r r r� 8 s zResource._body_mappingc C s | � t�S )z'Return all Header members of this class)r� r8 r� r r r r� = s zResource._header_mappingc C s | � t�S �z$Return all URI members of this class)r� r; r� r r r r� B s zResource._uri_mappingc C s | � t�S r� )r� r= r� r r r r� G s zResource._computed_mappingc C s. | j �� D ] }t|t�r |jr |j S q dS )a1 Return the name of any value known as an alternate_id NOTE: This will only ever return the first such alternate_id. Only one alternate_id should be specified. Returns an empty string if no name exists, as this method is consumed by _get_id and passed to getattr. r| )r� r� r r4 r r )r� r r r r r� L s zResource._alternate_idc C s t | t�r| jS | S dS )a9 If a value is a Resource, return the canonical ID This will return either the value specified by `id` or `alternate_id` in that order if `value` is a Resource. If `value` is anything other than a Resource, likely to be a string already representing an ID, it is returned. N)r ry rz )r r r r �_get_id\ s zResource._get_idc K s | f ddi|��S )a) Create a new instance of this resource. When creating the instance set the ``_synchronized`` parameter of :class:`Resource` to ``False`` to indicate that the resource does not yet exist on the server side. This marks all attributes passed in ``**kwargs`` as "dirty" on the resource, and thusly tracked as necessary in subsequent calls such as :meth:`update`. :param dict kwargs: Each of the named arguments will be set as attributes on the resulting Resource object. r� Fr )r� r" r r r �newj s z Resource.newc K s | f d|d�|��S )ac Create an instance of an existing remote resource. When creating the instance set the ``_synchronized`` parameter of :class:`Resource` to ``True`` to indicate that it represents the state of an existing server-side resource. As such, all attributes passed in ``**kwargs`` are considered "clean", such that an immediate :meth:`update` call would not generate a body of attributes to be modified on the server. :param dict kwargs: Each of the named arguments will be set as attributes on the resulting Resource object. T�r� r� r )r� r� r" r r r �existingy s zResource.existingc C s | f ||d�|��S )a� Create an instance from a ``munch.Munch`` object. This is intended as a temporary measure to convert between shade-style Munch objects and original openstacksdk resources. :param obj: a ``munch.Munch`` object to convert from. :param bool synchronized: whether this object already exists on server Must be set to ``False`` for newly created objects. r� r )r� �objrC r� r r r � _from_munch� s zResource._from_munchc C sr |rt �� }ni }g }|r$|�t� |r2|�t� |r@|�t� |sLtd��t|�}| �|�D �] \} } |rt| j } n| } t d| | j f�D ]�} | |vr�t | | d�} |r�| du r�q�t | t�r�| j|d�|| < q�t | t�r�|r�t �| �|| < q�| �rbt | t��rbg } | D ]T}t |t��r&| �|j|d�� n.t |t��rJ|�rJ| �t �|�� n | �|� �q| || < q�| || < q�q^|S )aV Return a dictionary of this resource's contents :param bool body: Include the :class:`~openstack.resource.Body` attributes in the returned dictionary. :param bool headers: Include the :class:`~openstack.resource.Header` attributes in the returned dictionary. :param bool computed: Include the :class:`~openstack.resource.Computed` attributes in the returned dictionary. :param bool ignore_none: When True, exclude key/value pairs where the value is None. This will exclude attributes that the server hasn't returned. :param bool original_names: When True, use attribute names as they were received from the server. :param bool _to_munch: For internal use only. Converts to `munch.Munch` instead of dict. :return: A dictionary of key/value pairs where keys are named as they exist as attributes of this class. z<At least one of `body`, `headers` or `computed` must be TrueN)� _to_munch)�munchZMunchr r4 r8 r= � ValueErrorr r� r �filterr r$ r ry r� r r )r! rY rZ r� Z ignore_none�original_namesr� r� r� r� r� r% r � convertedr r r r r� � sR � � zResource.to_dictc C s | j dd|dd�S )z9Convert this resource into a Munch compatible with shade.TF)rY rZ r� r� )r� )r! r� r r r r� � s �zResource._to_munchc C sP |sd S |� � }|�di �}|r6t|t�r6|�|� n|rLt|t�rL||d< |S �Nr� )r@ r� r r ra �str)r! rY �propsr r r �#_unpack_properties_to_resource_root� s z,Resource._unpack_properties_to_resource_rootc C s4 |� di �}t|t�s d|i}|�|� ||d< |S r� )rP r r ra )r! rY r� r� r r r r� � s z%Resource._pack_attrs_under_propertiesc C s� |rV| j s| jj}| j}n| �| jj�}| �| j�}ttt�||�j �t � d�d�}n6| j sf| jj }n| �| jj �}|r�| j d ur�| j |i}|S )N�path�r% )r� r5 r, r� r� �sortedr � jsonpatchZ make_patch�patch�operator� itemgetterrS � resource_key)r! r� � prepend_keyr� Z original_bodyrY r r r �_prepare_request_body s2 ���� � z Resource._prepare_request_bodyc K s� |du r| j }| �||�}i }| jj�� D ].\} } t| t�rLd�| �|| < q*t| �|| < q*|du rh| j }|| j j } |r�| j du r�t �d��t�| | j �} |r�tj�|�} | d| 7 } t| ||�S )a� Prepare a request to be sent to the server Create operations don't require an ID, but all others do, so only try to append an ID when it's needed with requires_id. Create and update operations sometimes require their bodies to be contained within an dict -- if the instance contains a resource_key and prepend_key=True, the body will be wrapped in a dict with that key. If patch=True, a JSON patch is prepared instead of the full body. Return a _Request object that contains the constructed URI as well a body and headers that are ready to send. Only dirty body and header contents will be returned. Nr� z)Request requires an ID but none was found�?)� requires_idr� r9 rS rj r r rk r� rm r< r, rz r ZInvalidRequestr �urljoin�urllib�parse� urlencoderW ) r! r� r� r� rm �paramsr" rY rZ rf r� r� � query_paramsr r r �_prepare_request! s* � zResource._prepare_requestc C s� |du r| j }tj||d� |r�z||�� }| jrD| j|v rD|| j }|�dd� | �|�}| jrl| �||�}| j j � |� | j � � | j s�| jr�|�� | _W n ty� Y n0 | �|j�}| jj � |� | j� � | �� t� | | �� � dS )a0 Given a KSA response, inflate this instance with its data DELETE operations don't return a body, so only try to work with a body when has_body is True. This method updates attributes that correspond to headers and body on this instance and clears the dirty set. N�� error_messager! )�has_bodyr �raise_from_response�jsonr� r� r� r� r� r5 r, ra rU r� r� r@ r� r� r� rZ r9 r� r r� )r! �responser� r� rY Z body_attrsrZ r r r �_translate_responseN s2 � z Resource._translate_responsec C s< t |tj�r|S t|d�r0| jd }t|j|�S td��dS )a� Attempt to get an Adapter from a raw session. Some older code used conn.session has the session argument to Resource methods. That does not work anymore, as Resource methods expect an Adapter not a session. We've hidden an _sdk_connection on the Session stored on the connection. If we get something that isn't an Adapter, pull the connection from the Session and look up the adapter by service_type. �_sdk_connection� service_typez�The session argument to Resource methods requires either an instance of an openstack.proxy.Proxy object or at the very least a raw keystoneauth1.adapter.Adapter.N)r r ZAdapterr� �servicer$ r� r� )r� �sessionr� r r r � _get_session} s �zResource._get_sessionc C s |j r |j S t�|| j�S )aH Get microversion to use when listing resources. The base version uses the following logic: 1. If the session has a default microversion for the current service, just use it. 2. If ``self._max_microversion`` is not ``None``, use minimum between it and the maximum microversion supported by the server. 3. Otherwise use ``None``. Subclasses can override this method if more complex logic is needed. :param session: :class`keystoneauth1.adapter.Adapter` :return: microversion as string or ``None`` )Zdefault_microversionr Z maximum_supported_microversion�_max_microversion)r� r� r r r �_get_microversion_for_list� s �z#Resource._get_microversion_for_listc C s |dvrt d| ��| �|�S )a� Get microversion to use for the given action. The base version uses :meth:`_get_microversion_for_list`. Subclasses can override this method if more complex logic is needed. :param session: :class`keystoneauth1.adapter.Adapter` :param action: One of "fetch", "commit", "create", "delete", "patch". Unused in the base implementation. :return: microversion as string or ``None`` )�fetch�commit�create�deleter� zInvalid action: %s)r� r� )r! r� �actionr r r �_get_microversion_for� s z Resource._get_microversion_forc sr � fdd�}| � ||�}|du r$|S |du r<d| }||� t�|�}t�|�} || k rnd||d� }||� |S )a= Enforce that the microversion for action satisfies the requirement. :param session: :class`keystoneauth1.adapter.Adapter` :param action: One of "fetch", "commit", "create", "delete". :param expected: Expected microversion. :param error_message: Optional error message with details. Will be prepended to the message generated here. :return: resulting microversion as string. :raises: :exc:`~openstack.exceptions.NotSupported` if the version used for the action is lower than the expected one. c s( � r� � d� d� | f } t�| ��d S )N�.z%s. %s)�rstripr Z NotSupported)rd r� r r �_raise� s z1Resource._assert_microversion_for.<locals>._raiseNzAAPI version %s is required, but the default version will be used.zBAPI version %(expected)s is required, but %(actual)s will be used.)�expected�actual)r r Znormalize_version_number) r! r� r r r� r r rd Zactual_nZ expected_nr r� r �_assert_microversion_for� s& � ��z!Resource._assert_microversion_forc K s | j st�| d��| �|�}| �|d�}| jdur8| jn| jdk}| jrV| jj � d� | jdkr�| j |||d�}|j |j |j|j||d�}nH| jdkr�| j |||d�}|j|j |j|j||d�}ntjd| j d ��| jdu r�| jn| j} || _| j|| d � | j�r | jd u �r | �|�S | S ) aA Create a remote resource based on this instance. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param prepend_key: A boolean indicating whether the resource_key should be prepended in a resource creation request. Default to True. :param str base_path: Base part of the URI for creating resources, if different from :data:`~openstack.resource.Resource.base_path`. :param dict params: Additional params to pass. :return: This :class:`Resource` instance. :raises: :exc:`~openstack.exceptions.MethodNotSupported` if :data:`Resource.allow_create` is not set to ``True``. r Nr} rz )r� r� rm �r� rZ r r� r~ �Invalid create method: %s��msg�r� F)� allow_creater �MethodNotSupportedr� r �create_requires_id� create_method�create_exclude_id_from_bodyr5 rB �discardr� �putrX rY rZ �post�ResourceFailure�create_returns_bodyr� r r� r� ) r! r� r� rm r� r r� �requestr� r� r r r r � sN �� �� ���� zResource.createc s� � j st�� d��|r2t|t�r2tdd� |D ��s>td| ��� ����� �� �d��� j durf� j n� j dk}� j dkr��j }n$� j dkr��j }ntj d� j d ��g }g } |D ]@} � jf d ��� i| ��} | �| � | j||d �} |�| j� q�|�r� j|i}|| j|| j�|d �} t�| � | �� }� j�r>|� j }t|t��sP|g}� jdu �rb� jn� j}|�r�� jd u �r��fdd�| D �S � ��fdd�|D �S dS )a� Create multiple remote resources based on this class and data. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param data: list of dicts, which represent resources to create. :param prepend_key: A boolean indicating whether the resource_key should be prepended in a resource creation request. Default to True. :param str base_path: Base part of the URI for creating resources, if different from :data:`~openstack.resource.Resource.base_path`. :param dict params: Additional params to pass. :return: A generator of :class:`Resource` objects. :raises: :exc:`~openstack.exceptions.MethodNotSupported` if :data:`Resource.allow_create` is not set to ``True``. r c S s g | ]}t |t��qS r )r r )rQ �xr r r r� 1 r_ z(Resource.bulk_create.<locals>.<listcomp>zInvalid data passed: %sNr} r~ r r r� �r� rm r Fc 3 s | ]}|� � �V qd S r )r� )rQ �r)r� r r rR ` r_ z'Resource.bulk_create.<locals>.<genexpr>c 3 s( | ] }� j f ���� d �|��V qdS )�r r� N)r� �_get_connection)rQ Zres_dict�r� r r� r r rR b s ���)r r r r r r� r� r� r r r r r r r� r r r� rY � resources_keyrX rZ r� r� r r� )r� r� �datar� rm r� r� �methodrY � resourcesr� �resourcer r� r� r r r � bulk_create s^ � �� � � � ��zResource.bulk_createc K st | j st�| d��| j||d�}| �|�}| �|d�}|j|j||d�}i } |rX|| d< || _| j |fi | �� | S )a Get a remote resource based on this instance. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param boolean requires_id: A boolean indicating whether resource ID should be part of the requested URI. :param str base_path: Base part of the URI for fetching resources, if different from :data:`~openstack.resource.Resource.base_path`. :param str error_message: An Error message to be returned if requested object does not exist. :param dict params: Additional parameters that can be consumed. :return: This :class:`Resource` instance. :raises: :exc:`~openstack.exceptions.MethodNotSupported` if :data:`Resource.allow_fetch` is not set to ``True``. :raises: :exc:`~openstack.exceptions.ResourceNotFound` if the resource was not found. r� r )r r� r� ) � allow_fetchr r r� r� r rP rX r r� ) r! r� r� rm r� r� r r r� r" r r r r� f s � �zResource.fetchc C s\ | j st�| d��| j|d�}| �|�}| �|d�}|j|j|d�}|| _| j |dd� | S )a� Get headers from a remote resource based on this instance. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param str base_path: Base part of the URI for fetching resources, if different from :data:`~openstack.resource.Resource.base_path`. :return: This :class:`Resource` instance. :raises: :exc:`~openstack.exceptions.MethodNotSupported` if :data:`Resource.allow_head` is not set to ``True``. :raises: :exc:`~openstack.exceptions.ResourceNotFound` if the resource was not found. �head)rm r� )r Fr ) � allow_headr r r� r� r r' rX r r� )r! r� rm r r r� r r r r' � s �z Resource.headc C s | j jp| jjp| jS )z0Whether the next commit() call will do anything.)r5 rS r9 �allow_empty_commitrL r r r �requires_commit� s �zResource.requires_commitc K sr | j j�d� | js| S | js*t�| d��| jr8d|d< | jf ||d�|��}| � |d�}| j ||| j |||d�S )aW Commit the state of the instance to the remote resource. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param prepend_key: A boolean indicating whether the resource_key should be prepended in a resource update request. Default to True. :param bool retry_on_conflict: Whether to enable retries on HTTP CONFLICT (409). Value of ``None`` leaves the `Adapter` defaults. :param str base_path: Base part of the URI for modifying resources, if different from :data:`~openstack.resource.Resource.base_path`. :param dict kwargs: Parameters that will be passed to _prepare_request() :return: This :class:`Resource` instance. :raises: :exc:`~openstack.exceptions.MethodNotSupported` if :data:`Resource.allow_commit` is not set to ``True``. rz r� Tr� )r� rm �r� �retry_on_conflict) r5 rB r r* � allow_commitr r r� r� r �_commit� commit_method) r! r� r� r� r, rm r" r r r r r r� � s" �� �zResource.commitc C s� | � |�}i }t|jpd�}|r0|dhB |d< n|d urJ|rJ|dh |d< zt||�� �} W n" ty~ tjd| d��Y n0 | |jf|j |j |d�|��} || _ | j | |d� | S )Nr i� �retriable_status_codeszInvalid commit method: %sr )r� rZ r r ) r� r r0 r$ r� r� r r rX rY rZ r r� ) r! r� r r" r r� r, r" r0 �callr� r r r r. � s* � ��zResource._commitc C s� t |t�s|g}g }|D ]�}z&|d }|�d��dd�}|d }W n" ttfyd td| ��Y n0 zt| j|�}W n t y� |}Y n0 |j }t |�dkr�d||d f } nd| } |� t || d�� q|S ) Nr� �/rp r z Malformed or missing path in %sz/%s/%sz/%s)r� )r r �lstrip�splitr& � IndexErrorr� r$ r� r� r rN r r ) r! r� r� �itemr� �parts�fieldr� Z server_field�new_pathr r r �_convert_patch� s( zResource._convert_patchc C sx | j j�d� |s | js | S | js.t�| d��| j||dd�}| �|d�}|rb| j | � |�7 _ | j ||d|||d�S )a> Patch the remote resource. Allows modifying the resource by providing a list of JSON patches to apply to it. The patches can use both the original (server-side) and SDK field names. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param patch: Additional JSON patch as a list or one patch item. If provided, it is applied on top of any changes to the current resource. :param prepend_key: A boolean indicating whether the resource_key should be prepended in a resource update request. Default to True. :param bool retry_on_conflict: Whether to enable retries on HTTP CONFLICT (409). Value of ``None`` leaves the `Adapter` defaults. :param str base_path: Base part of the URI for modifying resources, if different from :data:`~openstack.resource.Resource.base_path`. :return: This :class:`Resource` instance. :raises: :exc:`~openstack.exceptions.MethodNotSupported` if :data:`Resource.allow_patch` is not set to ``True``. rz r� T)r� rm r� �PATCHr+ ) r5 rB r r* r� r r r� r rY r: r. ) r! r� r� r� r� r, rm r r r r r r� s � �zResource.patchc K s< | j |fi |��}i }|r"||d< | j|fddi|�� | S )aY Delete the remote resource based on this instance. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param dict kwargs: Parameters that will be passed to _prepare_request() :return: This :class:`Resource` instance. :raises: :exc:`~openstack.exceptions.MethodNotSupported` if :data:`Resource.allow_commit` is not set to ``True``. :raises: :exc:`~openstack.exceptions.ResourceNotFound` if the resource was not found. r� r� F)� _raw_deleter� )r! r� r� r" r� r r r r B s zResource.deletec K sL | j st�| d��| jf i |��}| �|�}| �|d�}|j|j|j|d�S )Nr )rZ r ) � allow_deleter r r� r� r r rX rZ )r! r� r" r r r r r r< Y s �zResource._raw_deletec k s\ | j st�| d��| �|�}| �|�}|du r4| j}| jj|||d�}| j�|| �}|| }|� d�} d} |�rX|j |ddi|� � |d�} t� | � | � � } |� d d� |� dd� | jr�| | j } n| } t| t�s�| g} d}| D ]>}|� d d� | jf ||�� d �|��}|j}|V | d 7 } q�| �rR|�rR| �|| | || | �\}}|�|� qjdS qjdS ) a� This method is a generator which yields resource objects. This resource object list generator handles pagination and takes query params for response filtering. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param bool paginated: ``True`` if a GET to this resource returns a paginated series of responses, or ``False`` if a GET returns only one page of data. **When paginated is False only one page of data will be returned regardless of the API's support of pagination.** :param str base_path: Base part of the URI for listing resources, if different from :data:`~openstack.resource.Resource.base_path`. :param bool allow_unknown_params: ``True`` to accept, but discard unknown query parameters. This allows getting list of 'filters' and passing everything known to the server. ``False`` will result in validation exception when unknown query parameters are passed. :param dict params: These keyword arguments are passed through the :meth:`~openstack.resource.QueryParamter._transpose` method to find if any of them match expected query parameters to be sent in the *params* argument to :meth:`~keystoneauth1.adapter.Adapter.get`. They are additionally checked against the :data:`~openstack.resource.Resource.base_path` format string to see if any path fragments need to be filled in by the contents of this argument. :return: A generator of :class:`Resource` objects. :raises: :exc:`~openstack.exceptions.MethodNotSupported` if :data:`Resource.allow_list` is not set to ``True``. :raises: :exc:`~openstack.exceptions.InvalidResourceQuery` if query contains invalid params. r N)rm rn r\ r �Acceptzapplication/json)rZ r� r r] r! r rp )� allow_listr r r� r� rm �_query_mappingro rx rP r@ r� r� r� r r r r� r rz �_get_next_linkra )r� r� Z paginatedrm rn r� r r� r� r\ � total_yieldedr� r! r# r] Z raw_resourcer Z next_paramsr r r r e s` & � � �� � z Resource.listc C s� d }i }t |t�r�| j} | s(d|v r(d} | s@| jr@dj| jd�} | r�|�| i �} t | t�rldd� | �� D �} | D ]&} | �d�dkrpd| v rp| d } q�qp|p�|�d�}|r�|�d �r�||�d d �d d � }|s�d|j v r�|j d d }|�s6| j�r6|j �| j�} | �r6t | �} | |k�r6||d < |�r2||d< |}|�rpt j �|�} t j �| j�}|�|� t j �|| j�}|�s�|�r�|}||d < ||d< ||fS )N�linksz {key}_linksr� c s s | ]\}}||iV qd S r r r� r r r rR � r_ z*Resource._get_next_link.<locals>.<genexpr>�rel�next�hrefz/vr2 rp r� r] r\ )r r �pagination_keyr r rP rj � startswith�findrC rZ �intr� r� �urlparse�parse_qsrh ra r� r� )r� r� r� r! r] r\ rB Z next_linkr� rG rC r6 Z total_countr7 r� r r r rA � sP zResource._get_next_linkc C s\ d}|D ]N}| � |�}|j}||ks,||kr|du r:|}qd}|| j|f }t�|��q|S )z)Given a list of results, return the matchNz+More than one %s exists with the name '%s'.)r� r r0 r ZDuplicateResource)r� � name_or_id�resultsZ the_resultZ maybe_resultZid_value� name_valuer r r r �_get_one_match s zResource._get_one_matchc K s� | � |�}z.| jf ||�� d�|��}|j|fi |��W S tjyL Y n0 d| jj�� v rnd|vrn||d< | j |fi |��}| � ||�}|dur�|S |r�dS t� d| j |f ��dS )a Find a resource by its name or id. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param name_or_id: This resource's identifier, if needed by the request. The default is ``None``. :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. :param dict params: Any additional parameters to be passed into underlying methods, such as to :meth:`~openstack.resource.Resource.existing` in order to pass on URI parameters. :return: The :class:`Resource` object matching the given name or id or None if nothing matches. :raises: :class:`openstack.exceptions.DuplicateResource` if more than one resource is found for this request. :raises: :class:`openstack.exceptions.ResourceNotFound` if nothing is found and ignore_missing is ``False``. )rz r� r NzNo %s found for %s) r� r� r r� r �NotFoundExceptionr@ r` rA r rP ZResourceNotFoundr0 )r� r� rM Zignore_missingr� �matchr! ru r r r rI s0 ��� �z Resource.find)FN)FNT)N)TN)TTTFFF)T)NFFNN)NN)N)TN)TN)TNN)N)TTNN)TN)NTTNN)N)TNF)T)nr0 r1 r2 r� r rG r4 rz r r= r{ r[ r@ rm r� r r& r- r= r? r( r� Z allow_getr) r/ r r� r� r r r� r r� r r� r5 r9 r< r> r� Z_delete_response_classr� r� r# � classmethodr r8 r� r� r� r� rE rJ rI r� rA rj r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� � staticmethodr� r� r� r� r� ZtoDictr@ r� r� r� r� r� r� r� r� r r r r% r� r' rV r* r� r. r: r� r r< r rA rP rI r r r r ry t s A � � L � - / � ' 8 L � % � . � � / � e < ry c @ s\ e Zd Zddddd�Zedeg d�Zdd� Zg fd d �Zd d � Z d d� Z dd� Z dd� Z dS )�TagMixin�tagsztags-anyznot-tagsz not-tags-any)rV Zany_tagsZnot_tagsZ not_any_tags)r r c C sZ t �| j| jd�}| �|�}|�|�}t�|� |�� }d|v rV| j j � d|d i� | S )z�Lists tags set on the entity. :param session: The session to use for making this request. :return: The list with tags attached to the entity rV ) r r� rm rz r� rP r r� r� r5 r, ra )r! r� rX r� r� r r r � fetch_tags] s zTagMixin.fetch_tagsc C sN t �| j| jd�}| �|�}|j|d|id�}t�|� | jj � d|i� | S )z�Sets/Replaces all tags on the resource. :param session: The session to use for making this request. :param list tags: List with tags to be set on the resource rV )r� ) r r� rm rz r� r r r� r5 r, ra )r! r� rV rX r� r r r �set_tagso s zTagMixin.set_tagsc C sF t �| j| jd�}| �|�}|�|�}t�|� | jj � dg i� | S )zmRemoves all tags on the entity. :param session: The session to use for making this request. rV ) r r� rm rz r� r r r� r5 r, ra )r! r� rX r� r r r �remove_all_tags| s zTagMixin.remove_all_tagsc C s: t �| j| jd|�}| �|�}|�|�}tj|dd� | S )z�Checks if tag exists on the entity. If the tag does not exist a 404 will be returned :param session: The session to use for making this request. :param tag: The tag as a string. rV zTag does not existr� )r r� rm rz r� rP r r� )r! r� �tagrX r� r r r � check_tag� s �zTagMixin.check_tagc C sX t �| j| jd|�}| �|�}|�|�}t�|� | j}|� |� | j j � d|i� | S )z�Adds a single tag to the resource. :param session: The session to use for making this request. :param tag: The tag as a string. rV ) r r� rm rz r� r r r� rV r r5 r, ra �r! r� rZ rX r� rV r r r �add_tag� s �zTagMixin.add_tagc C sp t �| j| jd|�}| �|�}|�|�}t�|� | j}z|� |� W n t yX Y n0 | j j � d|i� | S )z�Removes a single tag from the specified server. :param session: The session to use for making this request. :param tag: The tag as a string. rV )r r� rm rz r� r r r� rV �remover� r5 r, ra r\ r r r � remove_tag� s �zTagMixin.remove_tagN) r0 r1 r2 Z_tag_query_parametersr4 r rV rW rX rY r[ r] r_ r r r r rU P s � rU c C s | d ur| � � } | S r �r� )�statusr r r �_normalize_status� s rb ra c C s� t �t�}t||�}t|�|�� kr(|S |du r6dg}dd� |D �}dj|jj|jd�} dj| |d�} t j || |d �D ]x} |� | �}|s�t � d j| |d���t||�} t| �} | |�� kr�| S | |v r�t � d j| | d���|�d | || � qvdS ) a Wait for the resource to be in a particular status. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param resource: The resource to wait on to reach the status. The resource must have a status attribute specified via ``attribute``. :type resource: :class:`~openstack.resource.Resource` :param status: Desired status of the resource. :param list failures: Statuses that would indicate the transition failed such as 'ERROR'. Defaults to ['ERROR']. :param interval: Number of seconds to wait between checks. Set to ``None`` to use the default interval. :param wait: Maximum number of seconds to wait for transition. Set to ``None`` to wait forever. :param attribute: Name of the resource attribute that contains the status. :return: The updated resource. :raises: :class:`~openstack.exceptions.ResourceTimeout` transition to status failed to occur in wait seconds. :raises: :class:`~openstack.exceptions.ResourceFailure` resource transitioned to one of the failure states. :raises: :class:`~AttributeError` if the resource does not have a status attribute N�ERRORc S s g | ] }|� � �qS r r` )rQ �fr r r r� � r_ z#wait_for_status.<locals>.<listcomp>z {res}:{id}�r� rz z4Timeout waiting for {name} to transition to {status})r ra ��timeoutrd �waitz+{name} went away while waiting for {status}z-{name} transitioned to failure state {status}zDStill waiting for resource %s to reach state %s, current state is %s)r � setup_loggingr0 r$ rb r� r r� rz r �iterate_timeoutr� r r �debug)r� r$ ra Zfailures�intervalrh � attribute�logZcurrent_statusr r �countZ new_statusZnormalized_statusr r r �wait_for_status� sH �� �� ���rp c C s� |}t j|dj|jj|jd�|d�D ]V}z4|�| �}|sB|W S |j�� dkrZ|W S W q$ t j yx | Y S 0 q$dS )aJ Wait for the resource to be deleted. :param session: The session to use for making this request. :type session: :class:`~keystoneauth1.adapter.Adapter` :param resource: The resource to wait on to be deleted. :type resource: :class:`~openstack.resource.Resource` :param interval: Number of seconds to wait between checks. :param wait: Maximum number of seconds to wait for the delete. :return: Method returns self on success. :raises: :class:`~openstack.exceptions.ResourceTimeout` transition to status failed to occur in wait seconds. z(Timeout waiting for {res}:{id} to deletere rf ZdeletedN) r rj r r� r0 rz r� ra r� r rQ )r� r$ rl rh Z orig_resourcero r r r �wait_for_delete s" �� rq )N)NNra )$r7 � collectionsrq r� � urllib.parser� r� r� Z keystoneauth1r r r� �requestsr Z openstackr r r r r' r r r4 r8 r; r= �MutableMappingr? rW r[ r ry rU rb rp rq r r r r �<module> sT d2 g gq � @
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка