Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/__pycache__/proxy.cpython-39.pyc
Ðазад
a t�h)s � @ s� zd dl Z e jjZW n ey* eZY n0 d dlZd dlZd dlmZ d dl m Z d dl m Z d dl m Z ddd�Z G d d � d ej�Zdd d �ZG d d� de�ZdS )� N)�adapter)�_log)� exceptions)�resourceFc s � fdd�}|S )Nc s d� �fdd� }|S )Nc sn �r(|d ur(t |tj�s(td|j ��n,t |tj�rTt ||�sTtd|j|jjf ��� | ||g|�R i |��S )NzA %s must be passedzExpected %s but received %s)� isinstancer �Resource� ValueError�__name__� __class__)�self�expected�actual�args�kwargs)�method�strict� �/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/proxy.py�check& s � � �z,_check_resource.<locals>.wrap.<locals>.check)Nr )r r �r )r r �wrap% s z _check_resource.<locals>.wrapr )r r r r r �_check_resource$ s r c s" e Zd ZdZdZd7� fdd� Zd8� fdd� Zd9d d �Zd d � Zd:d d�Z d;dd�Z d<dd�Z d=dd�Z dd� Z dd� Zdd� Zdd � Zd>d d �Zedd �d?d!d"��Zedd �d@d#d$��ZdAd%d&�ZdBd'd(�Zedd �dCd)d*��ZdDd+d,�ZdEd-d.�Zd/d0� ZdFd1d2�ZdGd3d4�Z dHd5d6�Z � Z S )I�ProxyzRepresents a service.Nc st | � d| j� tt| �j|d|i| �� || _|| _|| _|| _|| _ || _ | j r`d� | j �} nd} t �| �| _d S )N�retriable_status_codes�sessionz openstack.{0}� openstack)� setdefaultr �superr �__init__�_statsd_client�_statsd_prefix�_prometheus_counter�_prometheus_histogram�_influxdb_client�_influxdb_config� service_type�formatr � setup_logging�log) r r Z statsd_clientZ statsd_prefixZprometheus_counterZprometheus_histogramZinfluxdb_configZinfluxdb_clientr r Zlog_name�r r r r > s �zProxy.__init__F� c s� |s| � � } | r| j}zHtt| �j||f|||d�|��} | jD ]} | �| � q@| �| � | W S ty� } z | �d ||| � � W Y d } ~ n d } ~ 0 0 d S )N)�connect_retries� raise_exc�global_request_id)�_get_connectionZ_global_request_idr r �request�history� _report_stats� Exception) r �urlr � error_messager, r+ r- r r �conn�response�h�er) r r r/ V s( ��� z Proxy.requestc s� t j�|�j�� }|�d�r(|dd� }|�d�rD|dtd� � }� fdd�|�d�D �}|d dkrv|d d� }nJ|d r�|d d d kr�|d d r�|d d � � r�|dd� }| � |�}|�d �r�d g}|s�d g}dd� |D �S )aH Produce a key name to use in logging/metrics from the URL path. We want to be able to logic/metric sane general things, so we pull the url apart to generate names. The function returns a list because there are two different ways in which the elements want to be combined below (one for logging, one for statsd) Some examples are likely useful: /servers -> ['servers'] /servers/{id} -> ['server'] /servers/{id}/os-security-groups -> ['server', 'os-security-groups'] /v2.0/networks.json -> ['networks'] �/r* Nz.jsonc s, g | ]$}|� kr� r$� r|d � kr|�qS )ZAUTH_r )�.0�x�� project_idr r � <listcomp>� s �z'Proxy._extract_name.<locals>.<listcomp>����detail���r �v�tokensZ discoveryc S s g | ] }|r|�qS r r )r: �partr r r r> � � ) �urllib�parse�urlparse�path�strip� startswith�endswith�len�split�isdigit� _extract_name_consume_url_parts)r r3 r% r= Zurl_path� url_parts� name_partsr r< r � _extract_nameq s0 � � �� zProxy._extract_namec C s� g }t dt|��D ]n}|d s|| rt|�|d krr|| d dkrr|| dd� dkrr|�|| dd� � q|�|| � q|S ) z�Pull out every other URL portion - so that GET /servers/{id}/os-security-groups returns ['server', 'os-security-groups'] r � r* r? �srA N�is)�rangerM �append)r rQ rR �idxr r r rP � s ��z%Proxy._extract_name_consume_url_partsc C sL | j r| �||||� | jr2| jr2| �||||� | jrH| �||||� d S �N)r �_report_stats_statsdr! r" �_report_stats_prometheusr# �_report_stats_influxdb)r r6 r3 r �excr r r r1 � s zProxy._report_statsc C s� |d ur|s|j j}|d ur(|s(|j j}| �|| j| j�� �}d�| j| j|g| �}|d ur�t |j j d �}| j � ||� | j �|� n|d ur�| j �d| � d S )N�.�� z %s.failed)r/ r3 r rS r% r �get_project_id�joinr �int�elapsed� microsecondsr Ztiming�incr)r r6 r3 r r^ rR �key�durationr r r r[ � s& � ��zProxy._report_stats_statsdc C s~ |d ur|s|j j}|d ur(|s(|j j}|d urzt||| j|jd�}| jjf i |���� | j jf i |��� |j j d � d S )N)r Zendpointr% � status_coder` ) r/ r3 r �dictr% ri r! �labels�incr" Zobserverd re )r r6 r3 r r^ rk r r r r\ � s � �z Proxy._report_stats_prometheusc C s> |d ur|s|j j}|d ur(|s(|j j}t|d�| �|| j| j�� ��d�}tdd�}|d ur�t |j j d �|d< t |j �|d< d|t |j �< d|d||j f < |j |d < n |r�d|d < d | jv r�|�| jd � | jr�| j�d d �nd }d|| jf }t|||d�g}z| j�|� W n t�y8 | j�d� Y n0 d S )N�_)r �namer* )Z attemptedr` rh ri z%s.%sZstatus_code_valZfailedZadditional_metric_tags� measurementZ openstack_api)ro �tags�fieldsz$Error writing statistics to InfluxDB)r/ r3 r rj rb rS r% r ra rc rd re �strri r$ �update�getr# Z write_pointsr2 r( � exception) r r6 r3 r r^ rp rq ro �datar r r r] � sP ��� ����z Proxy._report_stats_influxdbc C s | � � }|r|d |kS dS )Nr F)Zget_api_major_version)r �version� api_versionr r r �_version_matches s zProxy._version_matchesc C s t | dt | jdd��S )a Get the Connection object associated with this Proxy. When the Session is created, a reference to the Connection is attached to the ``_sdk_connection`` attribute. We also add a reference to it directly on ourselves. Use one of them. � _connectionZ_sdk_connectionN)�getattrr �r r r r r. & s ��zProxy._get_connectionc K s� | � � }|du r&|jf d|i|��}nlt|t�r\t|tj�s\|j||d�}|jf i |�� n6t||�s~|jf ||d�|��}n|}|jf i |�� |S )ap Get a resource object to work on :param resource_type: The type of resource to operate on. This should be a subclass of :class:`~openstack.resource.Resource` with a ``from_id`` method. :param value: The ID of a resource or an object of ``resource_type`` class if using an existing instance, or ``munch.Munch``, or None to create a new instance. :param path_args: A dict containing arguments for forming the request URL, if needed. N� connection)r} )�idr} )r. �newr rj r r Z _from_munch�_update)r � resource_type�value�attrsr5 �resr r r � _get_resource1 s& �� ��zProxy._get_resourcec C s$ |du rt ||�}n tj�|�}|S )a� Get a value to be associated with a URI attribute `child` will not be None here as it's a required argument on the proxy method. `parent` is allowed to be None if `child` is an actual resource, but when an ID is given for the child one must also be provided for the parent. An example of this is that a parent is a Server and a child is a ServerInterface. N)r{ r r Z_get_id)r �child�parentrn r� r r r �_get_uri_attributeR s zProxy._get_uri_attributeTc K s |j | |fd|i|��S )a� Find a resource :param name_or_id: The name or ID of a resource to find. :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 attrs: Attributes to be passed onto the :meth:`~openstack.resource.Resource.find` method, such as query parameters. :returns: An instance of ``resource_type`` or None �ignore_missing)�find)r r� Z name_or_idr� r� r r r �_finda s ��z Proxy._findr c K sH | j ||fi |��}z|�| �}W n tjyB |r<Y dS � Y n0 |S )aF Delete a resource :param resource_type: The type of resource to delete. This should be a :class:`~openstack.resource.Resource` subclass with a ``from_id`` method. :param value: The value to delete. Can be either the ID of a resource or a :class:`~openstack.resource.Resource` subclass. :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``, no exception will be set when attempting to delete a nonexistent resource. :param dict attrs: Attributes to be passed onto the :meth:`~openstack.resource.Resource.delete` method, such as the ID of a parent resource. :returns: The result of the ``delete`` :raises: ``ValueError`` if ``value`` is a :class:`~openstack.resource.Resource` that doesn't match the ``resource_type``. :class:`~openstack.exceptions.ResourceNotFound` when ignore_missing if ``False`` and a nonexistent resource is attempted to be deleted. N)r� �deleter ZResourceNotFound)r r� r� r� r� r� �rvr r r �_deleteu s z Proxy._deletec K s" | j ||fi |��}|j| |d�S )a Update a resource :param resource_type: The type of resource to update. :type resource_type: :class:`~openstack.resource.Resource` :param value: The resource to update. This must either be a :class:`~openstack.resource.Resource` or an id that corresponds to a resource. :param str base_path: Base part of the URI for updating resources, if different from :data:`~openstack.resource.Resource.base_path`. :param dict attrs: Attributes to be passed onto the :meth:`~openstack.resource.Resource.update` method to be updated. These should correspond to either :class:`~openstack.resource.Body` or :class:`~openstack.resource.Header` values on this resource. :returns: The result of the ``update`` :rtype: :class:`~openstack.resource.Resource` �� base_path)r� �commit�r r� r� r� r� r� r r r r� � s z Proxy._updatec K s* | � � }|jf d|i|��}|j| |d�S )a� Create a resource from attributes :param resource_type: The type of resource to create. :type resource_type: :class:`~openstack.resource.Resource` :param str base_path: Base part of the URI for creating resources, if different from :data:`~openstack.resource.Resource.base_path`. :param path_args: A dict containing arguments for forming the request URL, if needed. :param dict attrs: Attributes to be passed onto the :meth:`~openstack.resource.Resource.create` method to be created. These should correspond to either :class:`~openstack.resource.Body` or :class:`~openstack.resource.Header` values on this resource. :returns: The result of the ``create`` :rtype: :class:`~openstack.resource.Resource` r} r� )r. r �create)r r� r� r� r5 r� r r r �_create� s z Proxy._createc C s |j | ||d�S )ap Create a resource from attributes :param resource_type: The type of resource to create. :type resource_type: :class:`~openstack.resource.Resource` :param list data: List of attributes dicts to be passed onto the :meth:`~openstack.resource.Resource.create` method to be created. These should correspond to either :class:`~openstack.resource.Body` or :class:`~openstack.resource.Header` values on this resource. :param str base_path: Base part of the URI for creating resources, if different from :data:`~openstack.resource.Resource.base_path`. :returns: A generator of Resource objects. :rtype: :class:`~openstack.resource.Resource` r� )Z bulk_create)r r� rv r� r r r � _bulk_create� s zProxy._bulk_createc K s2 | j ||fi |��}|j| ||dj|j|d�d�S )a� Fetch a resource :param resource_type: The type of resource to get. :type resource_type: :class:`~openstack.resource.Resource` :param value: The value to get. Can be either the ID of a resource or a :class:`~openstack.resource.Resource` subclass. :param str base_path: Base part of the URI for fetching resources, if different from :data:`~openstack.resource.Resource.base_path`. :param dict attrs: Attributes to be passed onto the :meth:`~openstack.resource.Resource.get` method. These should correspond to either :class:`~openstack.resource.Body` or :class:`~openstack.resource.Header` values on this resource. :returns: The result of the ``fetch`` :rtype: :class:`~openstack.resource.Resource` z$No {resource_type} found for {value})r� r� )� requires_idr� r4 )r� �fetchr& r )r r� r� r� r� r� r� r r r �_get� s ��z Proxy._getc K s |j | f||d�|��S )a� List a resource :param resource_type: The type of resource to delete. This should be a :class:`~openstack.resource.Resource` subclass with a ``from_id`` method. :param value: The resource to list. It can be the ID of a resource, or a :class:`~openstack.resource.Resource` object. When set to None, a new bare resource is created. :param bool paginated: When set to ``False``, expect all of the data to be returned in one response. When set to ``True``, the resource supports data being returned across multiple pages. :param str base_path: Base part of the URI for listing resources, if different from :data:`~openstack.resource.Resource.base_path`. :param dict attrs: Attributes to be passed onto the :meth:`~openstack.resource.Resource.list` method. These should correspond to either :class:`~openstack.resource.URI` values or appear in :data:`~openstack.resource.Resource._query_mapping`. :returns: A generator of Resource objects. :raises: ``ValueError`` if ``value`` is a :class:`~openstack.resource.Resource` that doesn't match the ``resource_type``. )� paginatedr� )�list)r r� r� r� r� r� r r r �_list� s ���z Proxy._listc K s" | j ||fi |��}|j| |d�S )a� Retrieve a resource's header :param resource_type: The type of resource to retrieve. :type resource_type: :class:`~openstack.resource.Resource` :param value: The value of a specific resource to retreive headers for. Can be either the ID of a resource, a :class:`~openstack.resource.Resource` subclass, or ``None``. :param str base_path: Base part of the URI for heading resources, if different from :data:`~openstack.resource.Resource.base_path`. :param dict attrs: Attributes to be passed onto the :meth:`~openstack.resource.Resource.head` method. These should correspond to :class:`~openstack.resource.URI` values. :returns: The result of the ``head`` call :rtype: :class:`~openstack.resource.Resource` r� )r� �headr� r r r �_head s z Proxy._headc C s d S rZ r r| r r r �_get_cleanup_dependencies6 s z Proxy._get_cleanup_dependenciesc C s d S rZ r )r �dry_run�client_status_queue�identified_resources�filters�resource_evaluation_fnr r r �_service_cleanup9 s zProxy._service_cleanupc C s� d}zj|r.t |�r.||||�} t| t�r<| }n| j||d�}|rl|rN|�|� |d ur`|||j< |sl||� W n8 ty� } z | j�d|t | �� W Y d } ~ n d } ~ 0 0 |S )NF)r� z Cannot delete resource %s: %s) �callabler �bool�,_service_cleanup_resource_filters_evaluation�putr~ r2 r( ru rr ) r Zdel_fn�objr� r� r� r� r� Z need_deleteZneed_delr8 r r r �_service_cleanup_del_res> s4 ��� �� *z Proxy._service_cleanup_del_resc C s� g }|d ur�t |t�r�|�� D ]�\}}z�d }|dkrHt|d�rHt|d�}|dkrdt|d�rdt|d�}|r�t�|�}t�|�}|r�|r�||kr�|�d� q�|�d� n| j� d| � |�d� W q t y� | j� d� Y q 0 q t |�r�dS dS d S )NZ created_atZ updated_atTFz?Requested cleanup attribute %s is not available on the resourcez!Error during condition evaluation) r rj �items�hasattrr{ �iso8601Z parse_daterX r( �debugr2 ru �all) r r� r� Z part_cond�krB Zres_valZres_dateZcmp_dater r r r� e s0 � z2Proxy._service_cleanup_resource_filters_evaluation)NNNNNN)NFr* N)NN)NNN)NNN)NNN)NNN)T)T)N)N)N)NTN)NTN)NN)TNNNN)TNNNN)N) r � __module__� __qualname__�__doc__r r r/ rS rP r1 r[ r\ r] ry r. r� r� r� r r� r� r� r� r� r� r� r� r� r� r� � __classcell__r r r) r r 4 sf � � @ � � 0 ! & � � � � 'r c C sT t j| |d� | js| S d| j�d�vr,| S z | �� }W n tyN | Y S 0 |S )zATemporary method to use to bridge from ShadeAdapter to SDK calls.�r4 zapplication/jsonz Content-Type)r Zraise_from_response�content�headersrt �json�JSONDecodeError)r6 Z result_keyr4 Z result_jsonr r r �_json_response� s r� c s" e Zd ZdZd� fdd� Z� ZS )� _ShadeAdapterz5Wrapper for shade methods that expect json unpacking.Nc s& t t| �j||fi |��}t||d�S )Nr� )r r� r/ r� )r r3 r r4 r r6 r) r r r/ � s z_ShadeAdapter.request)N)r r� r� r� r/ r� r r r) r r� � s r� )F)NN)Z simplejson�scannerr� � ImportErrorr r� rF Z keystoneauth1r r r r r r ZAdapterr r� r� r r r r �<module> s$ T
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка