Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/cloud/__pycache__/openstackcloud.cpython-39.pyc
Ðазад
a t�h � � @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZ d dl Z d dl Z d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlZd dlmZ d d lmZ d d lmZ d Zd Z d Z ej Z ej Z ej Z ej!Z!G d d � d �Z"dd� Z#dS )� N)�_log)�exc)� _floating_ip)� _object_store)�meta)�_utils)� cloud_region)�proxy)�utils� c s� e Zd ZdZdZdZdZdZdZdZ dZ � fd d �Z d d � Z d d� Z dd� Zdd� Zdd� Zdd� Zdd� ZdTdd�ZdUd d �Zd d � Zed d!� �Zed"d#� �Zed$d%� �Zd&d'� Zd(d)� Zed*d+� �Z ed,d-� �Z dVd.d/�Z ed0d1� �Z ed2d3� �Z ed4d5� �Z!ed6d7� �Z"dWd8d9�Z#ed:d;� �Z$dXd<d=�Z%d>d?� Z&d@dA� Z'dBdC� Z(dYdDdE�Z)dFdG� Z*dHdI� Z+dJdK� Z,dLdM� Z-dNdO� Z.dZdRdS�Z/� Z0S )[�_OpenStackCloudMixina� Represent a connection to an OpenStack Cloud. OpenStackCloud is the entry point for all cloud operations, regardless of which OpenStack service those operations may ultimately come from. The operations on an OpenStackCloud are resource oriented rather than REST API operation oriented. For instance, one will request a Floating IP and that Floating IP will be actualized either via neutron or via nova depending on how this particular cloud has decided to arrange itself. :param bool strict: Only return documented attributes for each resource as per the Data Model contract. (Default False) zx-object-meta-x-sdk-md5zx-object-meta-x-sdk-sha256z x-object-meta-x-sdk-autocreatedZimageszx-object-meta-x-shade-md5z x-object-meta-x-shade-sha256z!x-object-meta-x-shade-autocreatedc s t t| ��� t�d�| _| jj| _| j�� | _ | j� � | _ | jj | _ | j� � \| _| _| js�| j�d� tj}|r�tjd|d� i | _t| j�� �}| j�� }| j�� }i | _|dk�r&d| _| � |||�| _ | j� � }|� � D ].}t | d�!|�d �r�| � ||| |�| j|< q�t"| _#t$| _%t&| _'n�d| _d d � }G d d � d �}d | _#d | _%d | _'|� | _ t(j)D ]T} t | | d �} | �s|�qbt*| d��rbt*| d��rbt+�,| j-| �} || _.t/| | | � �qb| j�0d| j#�| _#| j�0d| j%�| _%| j�0d| j'�| _'t1� | _2t1� | _3i | _4| j �st(�5� nd| _6d S )N� openstackz4Turning off Insecure SSL warnings since verify=False�ignore)�categoryzdogpile.cache.nullTzlist_{0}Fc S s d S �N� )Zunusedr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/cloud/openstackcloud.py�_fake_invalidate~ s z7_OpenStackCloudMixin.__init__.<locals>._fake_invalidatec @ s e Zd Zdd� ZdS )z1_OpenStackCloudMixin.__init__.<locals>._FakeCachec S s d S r r ��selfr r r � invalidate� s z<_OpenStackCloudMixin.__init__.<locals>._FakeCache.invalidateN)�__name__� __module__� __qualname__r r r r r � _FakeCache� s r r r �func�server�portZ floating_ip)7�superr �__init__r � setup_logging�log�config�nameZ get_auth_args�auth� get_interfaceZdefault_interfaceZ force_ipv4Zget_requests_verify_args�verify�cert�debug�requestsexceptions�InsecureRequestWarning�warnings�filterwarnings�_disable_warnings�intZget_cache_expiration_timeZget_cache_classZget_cache_arguments�_resource_cachesZ cache_enabled� _make_cache�_cacheZget_cache_expirations�keys�getattr�format�DEFAULT_SERVER_AGEZ _SERVER_AGE�DEFAULT_PORT_AGEZ _PORT_AGE�DEFAULT_FLOAT_AGEZ _FLOAT_AGEr Z_decorated_methods�hasattr� functools�partialr r �setattrZ get_cache_resource_expiration�dictZ_container_cacheZ_file_hash_cache� _raw_clientsZlocalhost_supports_ipv6Z _local_ipv6) r r Zcache_expiration_time� cache_classZcache_argumentsZ expirationsZ expire_keyr r �methodZmeth_obj�new_func�� __class__r r r L s� � � � � �����z _OpenStackCloudMixin.__init__c K s | j jr| j j}ntj j| j j| j jdd�}t�| j j �}|�dd� dd� }dD ]V}|dkrdd }nd }d j |d �}|||||� d j |d �}dj |d �}|||||� qR|� � D ]\}} | |d |< q�|j f i |��} | j j | _ | j| _| j| j d< | j| d�S )a� Make a new OpenStackCloud object with new auth context. Take the existing settings from the current cloud and construct a new OpenStackCloud object with some of the auth settings overridden. This is useful for getting an object to perform tasks with as another user, or in the context of a different project. .. code-block:: python conn = openstack.connect(cloud='example') # Work normally servers = conn.list_servers() conn2 = conn.connect_as(username='different-user', password='') # Work as different-user servers = conn2.list_servers() :param kwargs: keyword arguments can contain anything that would normally go in an auth dict. They will override the same settings from the parent cloud as appropriate. Entries that do not want to be overridden can be ommitted. F)�app_name� app_versionZload_yaml_config�profileNc S s4 ||v s||v r0| d � |d � | d � |d � d S )Nr$ )�pop)�paramsr$ �name_key�id_keyr r r �pop_keys� s z1_OpenStackCloudMixin.connect_as.<locals>.pop_keys)�user�projectrK �username� project_namez {prefix}_id)�prefixz{prefix}_domain_idz{prefix}_domain_namer$ �r" )r" Z_openstack_configr ZOpenStackConfig� _app_name� _app_version�copy�deepcopyrF r4 �itemsZget_one�session�_discovery_cacher# �_namerB ) r �kwargsr" rG rJ rO rH rI �key�valuer r r r � connect_as� s4 � z _OpenStackCloudMixin.connect_asc C sZ i }t |t�rB|�d�|d< |�d�|d< |�d�rJ|d |d< n||d< | jf i |��S )a� Make a new OpenStackCloud object with a new project. Take the existing settings from the current cloud and construct a new OpenStackCloud object with the project settings overridden. This is useful for getting an object to perform tasks with as another user, or in the context of a different project. .. code-block:: python cloud = openstack.connect(cloud='example') # Work normally servers = cloud.list_servers() cloud2 = cloud.connect_as_project('different-project') # Work in different-project servers = cloud2.list_servers() :param project: Either a project name or a project dict as returned by `list_projects`. �id� project_idr# rN � domain_id�project_domain_id)� isinstancer< �getr\ )r rL r$ r r r �connect_as_project� s z'_OpenStackCloudMixin.connect_as_projectc C sd t �| jj�}tjf | j| jj| jj| jjd�|��}| j |_ | j |jd< | j |d�}|� |� |S )a= Make a new Connection object with a global request id set. Take the existing settings from the current Connection and construct a new Connection object with the global_request_id overridden. .. code-block:: python from oslo_context import context cloud = openstack.connect(cloud='example') # Work normally servers = cloud.list_servers() cloud2 = cloud.global_request(context.generate_request_id()) # cloud2 sends all requests with global_request_id set servers = cloud2.list_servers() Additionally, this can be used as a context manager: .. code-block:: python from oslo_context import context c = openstack.connect(cloud='example') # Work normally servers = c.list_servers() with c.global_request(context.generate_request_id()) as c2: # c2 sends all requests with global_request_id set servers = c2.list_servers() :param global_request_id: The `global_request_id` to send. )rV rC rD Zdiscovery_cacherE rP ) rS rT r" �cloud_region_modZ from_sessionrV rQ rR rW r# rX rB Zset_global_request_id)r Zglobal_request_idrG r Znew_connr r r �global_request s �� z#_OpenStackCloudMixin.global_requestc C s t jj| jd�j|||d�S )N)Zfunction_key_generator)�expiration_time� arguments)�dogpile�cacheZ make_region�_make_cache_key� configure)r r> rf rg r r r r0 ? s ��z _OpenStackCloudMixin._make_cachec s6 |j � |d u r| j�nd| j|f �� �fdd�}|S )N�%s:%sc sH d� | �}t� �� �}d� � fdd�|D ��}d� t���||g�}|S )N�,c s$ g | ] }|d krd|� | f �qS )ri rl r )�.0�k�rY r r � <listcomp>R � zN_OpenStackCloudMixin._make_cache_key.<locals>.generate_key.<locals>.<listcomp>�_)�join�sortedr2 �str)�argsrY Zarg_keyZkw_keysZ kwargs_keyZans��fnamerH rp r � generate_keyN s ��z:_OpenStackCloudMixin._make_cache_key.<locals>.generate_key)r r# )r � namespace�fnrz r rx r rj G s z$_OpenStackCloudMixin._make_cache_keyc C s" |r|| j v r| j | S | jS d S r )r/ r1 )r � resource_namer r r � _get_cacheX s z _OpenStackCloudMixin._get_cachec C s, t |t�r|S t |ttf�r(t|d �S |S )Nr )ra r. rv �tuple)r �versionr r r �_get_major_version_id^ s z*_OpenStackCloudMixin._get_major_version_idNc C s� | j �|�}| �|�}| �|�}| �|�}|r�|rR||k rRt�dj|||d���n"|rt||krtt�dj|||d���|}dj|d�} tj| j| j � |�| j � |�| j � |�| j � |�| j � |�| j �� | j �� | j �� | j �� | j �� || d� } | � � r�| S tj| j| j � |�| j � |�| j � |�| j � |�| j � |�||d�} | j| j � |�d �} | �| �} | �r�|�r�| |k�r�d j||d �d d � | D ��d�} | j�| � t�| � | S )NzfVersion {config_version} requested for {service_type} but shade understands a minimum of {min_version})�config_version� service_type� min_versionzpVersion {config_version} requested for {service_type} but openstack.cloud understands a maximum of {max_version})r� r� � max_versionz{version}.latest)r� ) rV r� � service_name� interface�endpoint_override� region_nameZ statsd_prefixZ statsd_clientZprometheus_counterZprometheus_histogramZinfluxdb_clientr� r� )rV r� r� r� r� r� r� r� )r� a {service_type} is configured for {config_version} but only {api_version} is available. shade is happy with this version, but if you were trying to force an override, that did not happen. You may want to check your cloud, or remove the version specification from your config.�.c S s g | ] }t |��qS r )rv )rn �fr r r rq � rr z>_OpenStackCloudMixin._get_versioned_client.<locals>.<listcomp>)r� r� � api_version)r" Zget_api_versionr� r �OpenStackCloudExceptionr4 r � _ShadeAdapterrV �get_service_type�get_service_namer% � get_endpoint�get_region_nameZget_statsd_prefixZget_statsd_clientZget_prometheus_counterZget_prometheus_histogramZget_influxdb_clientZget_api_major_versionrt r! r( r+ �warn)r r� r� r� r� Z config_majorZ max_majorZ min_majorZrequest_min_versionZrequest_max_version�adapterr� Z api_majorZ warning_msgr r r �_get_versioned_cliente s� �� ��� � � � �� z*_OpenStackCloudMixin._get_versioned_clientc C sD t j| j| j�|�| j�|�| j�|�| j�|�p4|| j�|�d�S )N)rV r� r� r� r� r� ) r r� rV r" r� r� r% r� r� )r r� r� r� r r r �_get_raw_client� s � �z$_OpenStackCloudMixin._get_raw_clientc C s( dj |�dd�d�}t| |�}|�|�S )Nz_{client}_client�-rs )�client)r4 �replacer3 Z_version_matches)r r� r� Z client_namer r r �_is_client_version� s � z'_OpenStackCloudMixin._is_client_versionc C s$ d| j vr| �d�| j d< | j d S )Nzapplication-catalog�r= r� r r r r �_application_catalog_client� s � z0_OpenStackCloudMixin._application_catalog_clientc C s$ d| j vr| �d�| j d< | j d S )NZdatabaser� r r r r �_database_client� s z%_OpenStackCloudMixin._database_clientc C s( d| j vr | �d�}|| j d< | j d S )Nz raw-image�imager� )r Z image_clientr r r �_raw_image_client� s z&_OpenStackCloudMixin._raw_image_clientc C s ddl }t�|�}|� |� dS )z.Wrapper around pprint that groks munch objectsr N)�pprintr �_dictify_resource�r �resourcer� Z new_resourcer r r r� � s z_OpenStackCloudMixin.pprintc C s ddl }t�|�}|�|�S )z/Wrapper around pformat that groks munch objectsr N)r� r r� �pformatr� r r r r� � s z _OpenStackCloudMixin.pformatc C s | j j�| j �jS r )rV r$ � get_access�service_catalogr r r r �_keystone_catalog� s z&_OpenStackCloudMixin._keystone_catalogc C s | j jS r )r� �catalogr r r r r� � s z$_OpenStackCloudMixin.service_catalogc C s& | j �|�}|r|S | j j|||d�S )a Return the endpoint for a given service. Respects config values for Connection, including ``*_endpoint_override``. For direct values from the catalog regardless of overrides, see :meth:`~openstack.config.cloud_region.CloudRegion.get_endpoint_from_catalog` :param service_type: Service Type of the endpoint to search for. :param interface: Interface of the endpoint to search for. Optional, defaults to the configured value for interface for this Connection. :param region_name: Region Name of the endpoint to search for. Optional, defaults to the configured value for region_name for this Connection. :returns: The endpoint of the service, or None if not found. )r� r� r� )r" r� Zget_endpoint_from_catalog)r r� r� r� r� r r r � endpoint_for� s �z!_OpenStackCloudMixin.endpoint_forc C s | j �� S r )rV � get_tokenr r r r � auth_token s z _OpenStackCloudMixin.auth_tokenc C s | j j�| j �jS )z:Get the id of the currently logged-in user from the token.)rV r$ r� Zuser_idr r r r �current_user_id s z$_OpenStackCloudMixin.current_user_idc C s | j �� S )a� Get the current project ID. Returns the project_id of the current token scope. None means that the token is domain scoped or unscoped. :raises keystoneauth1.exceptions.auth.AuthorizationFailure: if a new token fetch fails. :raises keystoneauth1.exceptions.auth_plugins.MissingAuthPlugin: if a plugin is not available. )rV Zget_project_idr r r r �current_project_id s z'_OpenStackCloudMixin.current_project_idc C s | � � S )z7Return a ``munch.Munch`` describing the current project)�_get_project_infor r r r �current_project- s z$_OpenStackCloudMixin.current_projectc C sh t j|d d d d�}|r || jkrd| jj�di �}| j|d< |�d�|d< |�d�|d< |�d�|d < |S ) N�r] r# r_ � domain_namer$ r] rN r# r` r_ Zproject_domain_namer� )�munch�Munchr� r" rb )r r^ Z project_infoZ auth_argsr r r r� 2 s � z&_OpenStackCloudMixin._get_project_infoc C s | � � S )z?Return a ``munch.Munch`` explaining the current cloud location.)�_get_current_locationr r r r �current_locationK s z%_OpenStackCloudMixin.current_locationc C s t j| j| j�� || �|�d�S )N��cloudr� �zonerL )r� r� r# r" r� r� )r r^ r� r r r r� P s �z*_OpenStackCloudMixin._get_current_locationc C s" t j| jddt jddddd�d�S )z3Identity resources do not exist inside of projects.Nr� r� )r� r� r# r r r r �_get_identity_locationZ s ��z+_OpenStackCloudMixin._get_identity_locationc C sD |r<| � |�}|si S | �dd�r.d|d iS d|d iS ni S d S )N�identity� Zdefault_project_idr] Z tenant_id)Z get_projectr� )r Z name_or_idrL r r r �_get_project_id_param_dictf s z/_OpenStackCloudMixin._get_project_id_param_dictc C s. | � dd�r&|s t�d��q*d|iS ni S dS )zGet a useable domain.r� r� zAUser or project creation requires an explicit domain_id argument.r_ N)r� r r� )r r_ r r r �_get_domain_id_param_dictr s � z._OpenStackCloudMixin._get_domain_id_param_dictc C s( i }|� | �|�� |� | �|�� |S )z�Get the domain and project/tenant parameters if needed. keystone v2 and v3 are divergent enough that we need to pass or not pass project or tenant_id or domain or nothing in a sane manner. )�updater� r� )r r_ rL �retr r r �_get_identity_params� s z)_OpenStackCloudMixin._get_identity_paramsc sD g � |� � D ]2\}}t�|||�}� s,|� q � fdd�|D �� q � S )aP Perform integer range searches across a list of dictionaries. Given a list of dictionaries, search across the list using the given dictionary keys and a range of integer values for each key. Only dictionaries that match ALL search filters across the entire original data set will be returned. It is not a requirement that each dictionary contain the key used for searching. Those without the key will be considered non-matching. The range values must be string values and is either a set of digits representing an integer for matching, or a range operator followed by a set of digits representing an integer for matching. If a range operator is not given, exact value matching will be used. Valid operators are one of: <,>,<=,>= :param data: List of dictionaries to be searched. :param filters: Dict describing the one or more range searches to perform. If more than one search is given, the result will be the members of the original data set that match ALL searches. An example of filtering by multiple ranges:: {"vcpus": "<=5", "ram": "<=2048", "disk": "1"} :returns: A list subset of the original data set. :raises: OpenStackCloudException on invalid range expressions. c s" g | ]}� D ]}||kr |�q qS r r )rn �rr� ��filteredr r rq � rr z5_OpenStackCloudMixin.range_search.<locals>.<listcomp>)rU r Z range_filter)r �data�filtersrZ Z range_value�resultsr r� r � range_search� s z!_OpenStackCloudMixin.range_searchc C s$ t |tjj�rt�|�}t�||�S )a Wrapper around meta.get_and_munchify. Some of the methods expect a `meta` attribute to be passed in as part of the method signature. In those methods the meta param is overriding the meta module making the call to meta.get_and_munchify to fail. )ra �requests�models�Responser Z_json_responser Zget_and_munchify)r rZ r� r r r �_get_and_munchify� s z&_OpenStackCloudMixin._get_and_munchifyc C s | j S r )r# r r r r �get_name� s z _OpenStackCloudMixin.get_namec C s� z| j �|�W S tjjjyR } z&| j�d| jt |�� d }W Y d }~nfd }~0 t j yf � Y nJ t y� } z2t � dj || j| j �|�t |�d���W Y d }~n d }~0 0 |S )Nz"Endpoint not found in %s cloud: %sz=Error getting {service} endpoint on {cloud}:{region}: {error})�servicer� �region�error)r" �get_session_endpoint� keystoneauth1� exceptionsr� ZEndpointNotFoundr! r( r# rv r r� � Exceptionr4 r� )r � service_key�e�endpointr r r r� � s& � ��z)_OpenStackCloudMixin.get_session_endpointc C sv | j �|�s@|| jv r | j| s<| j�dd|i� d| j|< dS z| �|�}W n tjyd Y dS 0 |rndS dS d S )Nz5Disabling %(service_key)s entry in catalog per configr� TF)r" � has_servicer- r! r( r� r r� )r r� r� r r r r� � s" �� z _OpenStackCloudMixin.has_serviceT�x c C s~ i }d}d}|st �� }| j�� D ]J} t| | �r"t| | �} | r"t| |�r"t| |�r"t| |�� } | r"|�| � q"t�� } |� � D ]T\} }| � | � |d D ]}| � |� | � | |� q�|� dg �D ]}| � || � q�q~t � }| j|d�D ]j} d}t| | ��r,t| | �} t| |d�}|�r,tj||||||d�}|�rF| j�t| | |� q�| �| � q�tj|dd d �D ]}| �� �rb dS �qbdS ) aF Cleanup the project resources. Cleanup all resources in all services, which provide cleanup methods. :param bool dry_run: Cleanup or only list identified resources. :param int wait_timeout: Maximum amount of time given to each service to comlete the cleanup. :param queue status_queue: a threading queue object used to get current process status. The queue contain processed resources. :param dict filters: Additional filters for the cleanup (only resources matching all filters will be deleted, if there are no other dependencies). :param resource_evaluation_fn: A callback function, which will be invoked for each resurce and must return True/False depending on whether resource need to be deleted or not. Z_get_cleanup_dependenciesZ_service_cleanup�before�after)�timeoutN)�dry_runZclient_status_queueZidentified_resourcesr� �resource_evaluation_fnz%Timeout waiting for cleanup to finish� )r� �message�wait)�queue�Queuer" Zget_enabled_servicesr8 r3 r� r ZTinyDAGrU �add_nodeZadd_edgerb r< �walkr9 r: Z_pool_executorZsubmit� cleanup_task� node_doneZiterate_timeoutZ is_complete)r r� Z wait_timeoutZ status_queuer� r� � dependenciesZget_dep_fn_nameZcleanup_fn_namer� r �depsZ dep_graphro �v�dep�cleanup_resourcesr| Z cleanup_fn�countr r r �project_cleanup� sh ��� �� � z$_OpenStackCloudMixin.project_cleanup)NN)NN)NN)N)NN)NN)Tr� NNN)1r r r �__doc__Z_OBJECT_MD5_KEYZ_OBJECT_SHA256_KEYZ_OBJECT_AUTOCREATE_KEYZ _OBJECT_AUTOCREATE_CONTAINERZ_SHADE_OBJECT_MD5_KEYZ_SHADE_OBJECT_SHA256_KEYZ _SHADE_OBJECT_AUTOCREATE_KEYr r\ rc re r0 rj r~ r� r� r� r� �propertyr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� � __classcell__r r rA r r 3 sz _G / � Z � / �r c C sV zDz |� W n* t y6 t�d�}|�d| � Y n0 W | �|� n | �|� 0 d S )Nzopenstack.project_cleanupz Error in the %s cleanup function)r� r r � exceptionr� )�graphr� r| r! r r r r� B s r� )$rS r9 r� �typesr+ Z dogpile.cacherh r� Zrequests.modelsr� r) Zkeystoneauth1.exceptionsr� Zkeystoneauth1.sessionr r Zopenstack.cloudr r r r r Zopenstack.configr rd r r r5 r6 r7 Z_CONFIG_DOC_URLZDEFAULT_OBJECT_SEGMENT_SIZEZDEFAULT_MAX_FILE_SIZEZOBJECT_CONTAINER_ACLSr r� r r r r �<module> sF
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка