Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/config/__pycache__/cloud_region.cpython-39.pyc
Ðазад
a u�h� � @ s` d dl Z d dlZd dlZd dlmZ d dlZd dlmZ d dlm Z d dl Z d dl Z z d dl Z W n eyv dZ Y n0 z d dlZW n ey� dZY n0 z d dlZW n ey� dZY n0 d dlmZ d dlmZ d dlmZ d dlmZ d d lmZ d d lmZ e�d �Z h d �Z e � Z d d� Z ddd�Z!dd� Z"ddd�Z#d dd�Z$G dd� d�Z%dS ) � N)�discover)�adapter)�session��version)�_log)�_util)�defaults)� exceptions)�proxy� openstack> � project_name� project_idZ domain_nameZ domain_idZ system_scopec C s* |s| S |� � �dd�}d�|| g�S d S )N�-�_)�lower�replace�join)�key� service_type� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/config/cloud_region.py� _make_key< s r c C s> |� � �dd�}dj|d�}d| |< |r:td|�}|| |< d S )Nr r �has_{service_type}�r F�disabled_reason)r r �formatr )�configr �reasonr �d_keyr r r �_disable_serviceD s r c C s* | sd S d| v r&| � d�d dkr&| S d S )N�.� �0)�splitr r r r �_get_implied_microversionM s r% Fc K s. t �� }|jf i |�� t|| |||||d�S )a� Construct a CloudRegion from an existing `keystoneauth1.session.Session` When a Session already exists, we don't actually even need to go through the OpenStackConfig.get_one_cloud dance. We have a Session with Auth info. The only parameters that are really needed are adapter/catalog related. :param keystoneauth1.session.session session: An existing authenticated Session to use. :param str name: A name to use for this cloud region in logging. If left empty, the hostname of the auth_url found in the Session will be used. :param str region_name: The region name to connect to. :param bool force_ipv4: Whether or not to disable IPv6 support. Defaults to False. :param str app_name: Name of the application to be added to User Agent. :param str app_version: Version of the application to be added to User Agent. :param kwargs: Config settings for this cloud region. )�namer r � region_name� force_ipv4�app_name� app_version)�config_defaults� get_defaults�update� CloudRegion)r r& r' r( r) r* �kwargs� config_dictr r r � from_sessionY s �r1 c K sT |st �d��|�dt�� �}t�� }|jD �]}|durR||vrRt||dd� q,|� |�}|| vr�d|v rx|� dd�}|| vr�t||dj ||d �d� q,i }zt � | | |� W nd t�y } zJd j ||| d �} t�d j || d �� t||| d� W Y d} ~ q,W Y d} ~ n d} ~ 0 0 |�� D ] \} } t| |�} | || < �q q,tf ||d�|��S )a� Create a CloudRegion from oslo.config ConfigOpts. :param oslo_config.cfg.ConfigOpts conf: An oslo.config ConfigOpts containing keystoneauth1.Adapter options in sections named according to project (e.g. [nova], not [compute]). TODO: Current behavior is to use defaults if no such section exists, which may not be what we want long term. :param keystoneauth1.session.Session session: An existing authenticated Session to use. This is currently required. TODO: Load this (and auth) from the conf. :param service_types: A list/set of service types for which to look for and process config opts. If None, all known service types are processed. Note that we will not error if a supplied service type can not be processed successfully (unless you try to use the proxy, of course). This tolerates uses where the consuming code has paths for a given service, but those paths are not exercised for given end user setups, and we do not want to generate errors for e.g. missing/invalid conf sections in those cases. We also don't check to make sure your service types are spelled correctly - caveat implementor. :param kwargs: Additional keyword arguments to be passed directly to the CloudRegion constructor. :raise openstack.exceptions.ConfigException: If session is not specified. :return: An openstack.config.cloud_region.CloudRegion. zA Session must be supplied.r Nz+Not in the list of requested service_types.�r r r z]No section for project '{project}' (service type '{service_type}') was present in the config.)�projectr zzEncountered an exception attempting to process config for project '{project}' (service type '{service_type}'): {exception})r3 r � exceptionz,Disabling service '{service_type}': {reason})r r )r r )r �ConfigException�popr+ r, �os_service_types� ServiceTypesZall_types_by_service_typer Zget_project_namer r � ks_load_adapZprocess_conf_options� Exception�_logger�warning�itemsr r. )Zconfr Z service_typesr/ r0 Zstm�str �opt_dict�er �raw_nameZopt_valZ config_namer r r � from_confz sV � �� ��" ��rB c @ s` e Zd ZdZd�dd�Zdd � Zd d � Zd d � Zdd� Ze dd� �Z e dd� �Z dd� Z dd� Z dd� Zdd� Zd d � Zd d � Zd�d d!�Zd"d#� Zd�d$d%�Zd�d&d'�Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd�d2d3�Zd4d5� Z d6d7� Z e d8d9� �Z e d:d;� �Z d<d=� Z d>d?� Z!d@dA� Z"dBdC� Z#dDdE� Z$dFdG� Z%dHdI� Z&dJdK� Z'de(j)fdLdM�Z*d�dNdO�Z+dPdQ� Z,dRdS� Z-dTdU� Z.dVdW� Z/dXdY� Z0d�dZd[�Z1d\d]� Z2d^d_� Z3d`da� Z4dbdc� Z5ddde� Z6dfdg� Z7dhdi� Z8djdk� Z9dldm� Z:dndo� Z;d�dpdq�Z<d�drds�Z=dtdu� Z>d�dvdw�Z?d�dxdy�Z@dzd{� ZAd|d}� ZBd~d� ZCd�d�� ZDd�d�� ZEd�d�� ZFd�d�d��ZGd�d�� ZHd�d�� ZId�d�� ZJdS )�r. aY The configuration for a Region of an OpenStack Cloud. A CloudRegion encapsulates the config information needed for connections to all of the services in a Region of a Cloud. :param str region_name: The default region name for all services in this CloudRegion. If both ``region_name`` and ``config['region_name'] are specified, the kwarg takes precedence. May be overridden for a given ${service} via a ${service}_region_name key in the ``config`` dict. :param dict config: A dict of configuration values for the CloudRegion and its services. The key for a ${config_option} for a specific ${service} should be ${service}_${config_option}. For example, to configure the endpoint_override for the block_storage service, the ``config`` dict should contain:: 'block_storage_endpoint_override': 'http://...' To provide a default to be used if no service-specific override is present, just use the unprefixed ${config_option} as the service key, e.g.:: 'interface': 'public' NFr �dogpile.cache.nullc C s� || _ t�|�| _|d ur$|| jd< | p*i | _t�d�| _|| _|| _ || _ | | _ |pZt j | _|| _| | _| ppd | _| | _|p�i | _|| _|| _|| _|| _|| _|| _|| _d | _|| _ d | _ || _ t � � | _!d S )Nr' zopenstack.config)"�_namer �normalize_keysr � _extra_configr � setup_logging�log� _force_ipv4�_authZ_openstack_config�_keystone_session� ks_session�Session�_session_constructor� _app_name� _app_version�_discovery_cache�_cache_expiration_time�_cache_expirations� _cache_path� _cache_class�_cache_arguments�_password_callback� _statsd_host� _statsd_port�_statsd_prefixZ_statsd_client�_influxdb_configZ_influxdb_client�_collector_registryr7 r8 �_service_type_manager)�selfr& r' r r( Z auth_pluginZopenstack_config�session_constructorr) r* r �discovery_cacheZ extra_configZcache_expiration_timeZcache_expirations� cache_pathZ cache_classZcache_argumentsZpassword_callbackZ statsd_hostZ statsd_port� statsd_prefix�influxdb_configZcollector_registryr r r �__init__� s8 zCloudRegion.__init__c C s< |� d�r|dd� }|dd� | jD �v r4| j| S dS dS )z Return arbitrary attributes.Zos_� Nc S s g | ]}|� d d��qS )r r )r )�.0�attrr r r � <listcomp> � z+CloudRegion.__getattr__.<locals>.<listcomp>)� startswithr )r^ r r r r � __getattr__ s zCloudRegion.__getattr__c C s | j �� S �N)r �__iter__�r^ r r r rm s zCloudRegion.__iter__c C s | j |j ko| j|jkS rl )r& r �r^ �otherr r r �__eq__! s �zCloudRegion.__eq__c C s | |k S rl r ro r r r �__ne__& s zCloudRegion.__ne__c C sL | j d u rFz tj�| �� jj�j| _ W n tyD | j p<d| _ Y n0 | j S )N� ) rD �urllib�parse�urlparse� get_session�auth�auth_url�hostnamer: rO rn r r r r& ) s � zCloudRegion.namec C sH | � � }| jr"|r"d�| j|g�S | jr2|s2| jS | js@|r@|S dS dS )z�Return a string that can be used as an identifier. Always returns a valid string. It will have name and region_name or just one of the two if only one is set, or else 'unknown'. �:�unknownN)�get_region_namer& r )r^ r' r r r � full_name3 s zCloudRegion.full_namec C s t ||�}|| j|< d S rl )r r )r^ r r �valuer r r �set_service_valueD s z CloudRegion.set_service_valuec C s || _ dS )z Sets the Session constructor.N)rN )r^ r_ r r r �set_session_constructorH s z#CloudRegion.set_session_constructorc C s� | j �dd�}| j �dd�}| j �d�}|r0d}|r>|r>|}n|rVt�dj| jd�� | j �d�}|r�| j �d �r�|| j �d �f}||fS ) z;Return the verify and cert values for the requests library.�insecureF�verifyT�cacertz�You are specifying a cacert for the cloud {full_name} but also to ignore the host verification. The host SSL cert will not be verified.�r~ �certr )r �get�warnings�warnr r~ )r^ r� r� r� r� r r r �get_requests_verify_argsL s$ �� z$CloudRegion.get_requests_verify_argsc C s` g }| j �� D ]D\}}|�d�s4|�d�s4|�d�r|�d�|�d�dd� �� qtt|��S )z7Return a list of service types we know something about.� api_versionr � service_namer N���)r r= �endswith�appendr r$ �list�set)r^ �servicesr �valr r r � get_servicesd s �� zCloudRegion.get_servicesc C s` t � }dd� | jjD �}|�dd� | j�� D �� |D ]$}| �|�}|r6|�|�dd�� q6|S )Nc S s g | ] }|d �qS r r �rf �kr r r rh q ri z4CloudRegion.get_enabled_services.<locals>.<listcomp>c s s$ | ] }|� d �r|dd� V qdS )Zhas_� N)rj r� r r r � <genexpr>s s �z3CloudRegion.get_enabled_services.<locals>.<genexpr>r r ) r� r] r� �extendr �keys�get_endpoint_from_catalog�addr )r^ r� Z all_servicesZsrv�epr r r �get_enabled_servicesn s � � z CloudRegion.get_enabled_servicesc C s | j �di �S )Nrx �r r� rn r r r � get_auth_args} s zCloudRegion.get_auth_argsc C sx |du r| j �|�S | j�|�D ]"}| j �t||��}|dur qTq |rT| j �|�}|du r`|S |durp||�}|S dS )a� Get a config value for a service_type. Finds the config value for a key, looking first for it prefixed by the given service_type, then by any known aliases of that service_type. Finally, if fallback_to_unprefixed is True, a value will be looked for without a prefix to support the config values where a global default makes sense. For instance, ``_get_config('example', 'block-storage', True)`` would first look for ``block_storage_example``, then ``volumev3_example``, ``volumev2_example`` and ``volume_example``. If no value was found, it would look for ``example``. If none of that works, it returns the value in ``default``. N)r r� r] � get_all_typesr )r^ r r �default�fallback_to_unprefixed� converterr> r r r r � _get_config� s zCloudRegion._get_configc C sL | j �|�}|sd S t|t�s"|S | j�|�D ]}||v r.|| S q.d S rl )r r� � isinstance�dictr] r� )r^ r r r0 r> r r r �_get_service_config� s z CloudRegion._get_service_configc C s | j d|dd�S )Nr' T�r� �r� �r^ r r r r r} � s �zCloudRegion.get_region_namec C s | j d|dd�S )N� interfaceTr� r� r� r r r � get_interface� s �zCloudRegion.get_interfacec C sH | � d|�}|rDz t|� W n& tyB d|v r<t�d� Y d S 0 |S )Nr� �latestzrYou have a configured API_VERSION with 'latest' in it. In the context of openstacksdk this doesn't make any sense.)r� �float� ValueErrorr� r� )r^ r r r r r �get_api_version� s �zCloudRegion.get_api_versionc C s | � d|�S )N�default_microversionr� r� r r r �get_default_microversion� s z$CloudRegion.get_default_microversionc C s( | j �|�r| j �|�}| jd||d�S )Nr )r� )r] Zis_known�get_service_typer� r� r r r r� � s ��z CloudRegion.get_service_typec C s | � d|�S )Nr� r� r� r r r �get_service_name� s z CloudRegion.get_service_namec C s� | j �di �}| �d|�}|s*| �d|�}|sH| j �d�dkrH|�d�}|sp|dkrpt�t|�� ��rp|�d�}| j�|�}|r�| j �d�d kr�|d kr�||�d � }|S ) Nrx �endpoint_override�endpointZ auth_type�none�identityry ZprofileZ rackspacez block-storager ) r r� r� � SCOPE_KEYS� isdisjointr� r� r] r� )r^ r rx r r r r � get_endpoint� s* � ����zCloudRegion.get_endpointc C sd |p | � |�}|p| �|�}| �� }|j�|�j}z|j|||d�W S tjj j y^ Y dS 0 dS )a� Return the endpoint for a given service as found in the catalog. For values respecting endpoint overrides, see :meth:`~openstack.connection.Connection.endpoint_for` :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' N) r� r} rw rx � get_access�service_catalogZurl_for� keystoneauth1r �catalog�EndpointNotFound)r^ r r� r' r r� r r r r� � s �z%CloudRegion.get_endpoint_from_catalogc C s | j d|dtd�S )N�connect_retriesT�r� r� �r� �intr� r r r �get_connect_retries s �z CloudRegion.get_connect_retriesc C s | j d|dtd�S )N�status_code_retriesTr� r� r� r r r �get_status_code_retries s �z#CloudRegion.get_status_code_retriesc C s | j S rl �rI rn r r r � prefer_ipv6" s zCloudRegion.prefer_ipv6c C s | j S rl r� rn r r r r( & s zCloudRegion.force_ipv4c C s | j S )z7Return a keystoneauth plugin from the auth credentials.)rJ rn r r r �get_auth* s zCloudRegion.get_authc C s | j j�dtjf� dS )a1 Set sdk information into the user agent of the Session. .. warning:: This method is here to be used by os-client-config. It exists as a hook point so that os-client-config can provice backwards compatibility and still be in the User Agent for people using os-client-config directly. Normal consumers of SDK should use app_name and app_version. However, if someone else writes a subclass of :class:`~openstack.config.cloud_region.CloudRegion` it may be desirable. Z openstacksdkN)rK Zadditional_user_agentr� �openstack_version� __version__rn r r r �insert_user_agent. s �z CloudRegion.insert_user_agentc C s� | j du r�| jst�d��| �� \}}|s@| j�dj| jd�� t j | d� | j | j||| j � d�| j � d�| jd�| _ | �� t| j d �r�| j| j _t| j d �r�| j| j _| j S ) z<Return a keystoneauth session based on the auth credentials.Nz Problem with auth parametersz;Turning off SSL warnings for {full_name} since verify=Falser� )Zinsecure_requestsZ api_timeoutZtiming)rx r� r� �timeoutZcollect_timingr` r) r* )rK rJ r r5 r� rH �debugr r~ �requestsexceptionsZsquelch_warningsrN r r� rQ r� �hasattrrO r) rP r* )r^ r� r� r r r rw ? s6 � �� � zCloudRegion.get_sessionc C s | j �| �� �jS )z*Helper method to grab the service catalog.)rJ r� rw r� rn r r r �get_service_catalog` s z CloudRegion.get_service_catalogc C s� t �� }|dkrd|_|S |s(| �|�}|s<|dvr<d|_n||_| �|�}t|�}|rx|rx||krxt�dj ||d���|r�|}|d |_||_ |S )a Translate OCC version args to those needed by ksa adapter. If no version is requested explicitly and we have a configured version, set the version parameter and let ksa deal with expanding that to min=ver.0, max=ver.latest. If version is set, pass it through. If version is not set and we don't have a configured version, default to latest. If version is set, contains a '.', and default_microversion is not set, also pass it as a default microversion. r� )� load-balancerz�default_microversion of {default_microversion} was given for {service_type}, but api_version looks like a microversion as well. Please set api_version to just the desired major version, or omit default_microversion)r� r r ) r ZVersionRequest�max_api_versionr� r r� r% r r5 r r� )r^ r r �version_requestr� Zimplied_microversionr r r �_get_version_requestd s2 ��� z CloudRegion._get_version_requestc C sX | � |�}| �|�}| �� j|| �|�|d�}|�|i �}|�| �|�i �}|�|g �S )Nr� )r� r} rw �get_all_version_datar� r� )r^ r r' �versionsZregion_versionsZinterface_versionsr r r r� � s � �z CloudRegion.get_all_version_datac C s6 || � � | �|�| �|�| �|�| �|�d�}|�� S )N)r r r� r� r' )rw r� r� r� r} r� )r^ r � constructorr r r r �_get_endpoint_from_catalog� s �z&CloudRegion._get_endpoint_from_catalogc C sF | � ||�}|�� �d�d dksB|�d�s4|d7 }tj�|d�}|S )N�/���zv2.0)r� �rstrip�rsplitr� rt ru �urljoin)r^ r r� r� r r r �_get_hardcoded_endpoint� s � z#CloudRegion._get_hardcoded_endpointc K s� | � ||�}|�d| �|�� |�d| �|�� |�d| �|�� |�d| �� � |�d| �� � |�d| �� � |�d| �� � |�d| j � |�d | � � � | � |�}|j }|� d d �p�|j}|� d d �p�|j}|d v r�d }d }d }|d u r�| �||�}|f | �� | �|�| �|�| �|�|||||j| �|�| �|�d� |��} |j�r�|j} | �� } t�| j| j | ��s�| � |��r�t � dj || t�!| j�t�!| j �d���n0t � dj || �"|�| t�!| j�t�!| j �d���| S )aN Return a prepped keystoneauth Adapter for a given service. This is useful for making direct requests calls against a 'mounted' endpoint. That is, if you do: client = get_session_client('compute') then you can do: client.get('/flavors') and it will work like you think. r' r� r� rb Z statsd_clientZprometheus_counterZprometheus_histogramrc Zinfluxdb_client� min_versionN� max_version)�networkr� ) r r r� r� r r� r� r� r� � rate_limit� concurrencyz�A default microversion for service {service_type} of {default_microversion} was requested, but the cloud only supports a minimum of {min_microversion} and a maximum of {max_microversion}.)r r� �min_microversion�max_microversiona A default microversion for service {service_type} of {default_microversion} was requested, but the cloud only supports a maximum of only supports a minimum of {min_microversion} and a maximum of {max_microversion}. The default microversion was set because a microversion formatted version string, '{api_version}', was passed for the api_version of the service. If it was not intended to set a default microversion please remove anything other than an integer major version from the version setting for the service.)r r� r� r� r� )#r� � setdefaultr} r� r� �get_statsd_prefix�get_statsd_client�get_prometheus_counter�get_prometheus_histogramr[ �get_influxdb_clientr� r r6 �min_api_versionr� r� rw r� r� r� r� �get_rate_limit�get_concurrencyZget_endpoint_datar Zversion_betweenr� r� r� r r5 r Zversion_to_stringr� ) r^ r r r� r/ r� r� r� r� �clientr� �infor r r �get_session_client� s� ��� ���� � � ���� ����z CloudRegion.get_session_clientc C s� | � |�}|r|S | �|�}| �|�}| �|�}| �� }i } |rH|| d< |rT|| d< z |j f ||||d�| ��} W n tjjjy� d} Y n0 | s�| j � d||||� | S )a> Return the endpoint from config or the catalog. If a configuration lists an explicit endpoint for a service, return that. Otherwise, fetch the service catalog from the keystone session and return the appropriate endpoint. :param service_type: Official service type of service r� r� )r r' r� r� Nz^Keystone catalog entry not found (service_type=%s,service_name=%s,interface=%s,region_name=%s)) r� r} r� r� rw r� r r� r� rH r< ) r^ r r� r� Zoverride_endpointr' r� r� r Zversion_kwargsr� r r r �get_session_endpoint# s@ �� � z CloudRegion.get_session_endpointc C s t | j�S rl )r� rR rn r r r �get_cache_expiration_timeT s z%CloudRegion.get_cache_expiration_timec C s | j S rl )rT rn r r r �get_cache_pathX s zCloudRegion.get_cache_pathc C s | j S rl )rU rn r r r �get_cache_class[ s zCloudRegion.get_cache_classc C s t �| j�S rl )�copy�deepcopyrV rn r r r �get_cache_arguments^ s z CloudRegion.get_cache_argumentsc C s t �| j�S rl )r� r� rS rn r r r �get_cache_expirationsa s z!CloudRegion.get_cache_expirationsc C s || j vr|S t| j | �S )a Get expiration time for a resource :param resource: Name of the resource type :param default: Default value to return if not found (optional, defaults to None) :returns: Expiration time for the resource type as float or default )rS r� )r^ �resourcer� r r r � get_cache_resource_expirationd s z)CloudRegion.get_cache_resource_expirationc C s | j d dkrdS | j �d�S )a Return whether or not this cloud requires floating ips. :returns: True of False if know, None if discovery is needed. If requires_floating_ip is not configured but the cloud is known to not provide floating ips, will return False. Zfloating_ip_source�NoneF�requires_floating_ipr� rn r r r r q s z CloudRegion.requires_floating_ipc C s dd� | j �dg �D �S )z0Get list of network names for external networks.c S s g | ]}|d r|d �qS �Zroutes_externallyr& r �rf �netr r r rh s �z5CloudRegion.get_external_networks.<locals>.<listcomp>�networksr� rn r r r �get_external_networks} s �z!CloudRegion.get_external_networksc C s dd� | j �dg �D �S )z5Get list of network names for external IPv4 networks.c S s g | ]}|d r|d �qS �Zroutes_ipv4_externallyr& r r r r r rh � s �z:CloudRegion.get_external_ipv4_networks.<locals>.<listcomp>r r� rn r r r �get_external_ipv4_networks� s �z&CloudRegion.get_external_ipv4_networksc C s dd� | j �dg �D �S )z5Get list of network names for external IPv6 networks.c S s g | ]}|d r|d �qS �Zroutes_ipv6_externallyr& r r r r r rh � s �z:CloudRegion.get_external_ipv6_networks.<locals>.<listcomp>r r� rn r r r �get_external_ipv6_networks� s �z&CloudRegion.get_external_ipv6_networksc C s dd� | j �dg �D �S )z0Get list of network names for internal networks.c S s g | ]}|d s|d �qS r r r r r r rh � s �z5CloudRegion.get_internal_networks.<locals>.<listcomp>r r� rn r r r �get_internal_networks� s �z!CloudRegion.get_internal_networksc C s dd� | j �dg �D �S )z5Get list of network names for internal IPv4 networks.c S s g | ]}|d s|d �qS r r r r r r rh � s �z:CloudRegion.get_internal_ipv4_networks.<locals>.<listcomp>r r� rn r r r �get_internal_ipv4_networks� s �z&CloudRegion.get_internal_ipv4_networksc C s dd� | j �dg �D �S )z5Get list of network names for internal IPv6 networks.c S s g | ]}|d s|d �qS r r r r r r rh � s �z:CloudRegion.get_internal_ipv6_networks.<locals>.<listcomp>r r� rn r r r �get_internal_ipv6_networks� s �z&CloudRegion.get_internal_ipv6_networksc C s, | j �dg �D ]}|d r|d S qdS )z*Get network used for default interactions.r Zdefault_interfacer& Nr� �r^ r r r r �get_default_network� s z CloudRegion.get_default_networkc C s, | j �dg �D ]}|d r|d S qdS )z%Get network used for NAT destination.r Znat_destinationr& Nr� r r r r �get_nat_destination� s z CloudRegion.get_nat_destinationc C s. | j �dg �D ]}|�d�r|d S qdS )z Get network used for NAT source.r Z nat_sourcer& Nr� r r r r �get_nat_source� s zCloudRegion.get_nat_sourcec C s2 t �|p i �}|s|S t �|t �| j�|i ���S )a Fetch an arbitrary extra chunk of config, laying in defaults. :param string key: name of the config section to fetch :param dict defaults: (optional) default values to merge under the found config )r rE Z merge_cloudsrF r� )r^ r r r r r �_get_extra_config� s �z CloudRegion._get_extra_configc C s | � || � d|��S )ab Get config settings for a named client. Settings will also be looked for in a section called 'client'. If settings are found in both, they will be merged with the settings from the named section winning over the settings from client section, and both winning over provided defaults. :param string name: Name of the config section to look for. :param dict defaults: Default settings to use. :returns: A dict containing merged settings from the named section, the client section and the defaults. r� )r )r^ r& r r r r �get_client_config� s �z CloudRegion.get_client_configc C s | j S rl )rW rn r r r �get_password_callback� s z!CloudRegion.get_password_callbackc C s | j d|d�S )Nr� r �r� r� r r r r� � s �zCloudRegion.get_rate_limitc C s | j d|d�S )Nr� r r r� r r r r� � s �zCloudRegion.get_concurrencyc C sn t sd S i }| jr | j|d< | jr,| j|d< |rfzt jf i |��W S tyb | j�d� Y d S 0 nd S d S )N�host�portz%Cannot establish connection to statsd)�statsdrX rY Z StatsClientr: rH r< )r^ Z statsd_argsr r r r� � s z CloudRegion.get_statsd_clientc C s | j pdS )Nz openstack.api)rZ rn r r r r� � s z CloudRegion.get_statsd_prefixc C s | j strtj| _ | j S rl )r\ �prometheus_clientZREGISTRYrn r r r �get_prometheus_registry� s z#CloudRegion.get_prometheus_registryc C sD | � � }|rtsd S t|dd �}|s@tjddg d�|d�}||_|S )N�_openstacksdk_histogramZ openstack_http_response_timez7Time taken for an http response to an OpenStack service��methodr� r � status_code�Z labelnames�registry)r r �getattrZ Histogramr )r^ r �histr r r r� � s �z$CloudRegion.get_prometheus_histogramc C sD | � � }|rtsd S t|dd �}|s@tjddg d�|d�}||_|S )N�_openstacksdk_counterZopenstack_http_requestsz4Number of HTTP requests made to an OpenStack servicer r )r r r! �Counterr# )r^ r �counterr r r r� s �z"CloudRegion.get_prometheus_counterc C s2 |� � �dd�}dj|d�}| j�|| j�|��S )Nr r r r )r r r r r� r] Z is_official�r^ r r r r r � has_service! s �zCloudRegion.has_servicec C s t | j||d� d S )Nr2 )r r )r^ r r r r r �disable_service' s zCloudRegion.disable_servicec C s* |� � �dd�}dj|d�}d| j|< d S )Nr r r r T)r r r r r& r r r �enable_service* s zCloudRegion.enable_servicec C s& |� � �dd�}td|�}| j�|�S )Nr r r )r r r r r� )r^ r r r r r �get_disabled_reason/ s z CloudRegion.get_disabled_reasonc C s� i }| j sd S t| j �dd��}| j �d�}|r8d|d< d| j v rX|rP||d< n||d< dD ] }|| j v r\| j | ||< q\tr�|r�ztjf i |��W S ty� | j�d� Y q�0 n | j�d� d S ) N�use_udpFr TZudp_port)r �username�passwordZdatabaser� z'Cannot establish connection to InfluxDBzBInfluxDB configuration is present, but no client library is found.)r[ �boolr� �influxdbZInfluxDBClientr: rH r< )r^ Z influx_argsr+ r r r r r r� 4 s* z CloudRegion.get_influxdb_client)NNNFNNNNNNNNr NNrC NNNNNNN)NFN)N)N)NN)NN)N)N)NN)N)N)N)K�__name__� __module__� __qualname__�__doc__rd rk rm rq rr �propertyr& r~ r� r� r� r� r� r� r� r� r} r� r� r� r� r� r� r� r� r� r� r( r� r� rw r� r� r� r� r� r ZProxyr� r� r� r� r� r� r� r� r r r r r r r r r r r r r r� r� r� r� r r� r� r' r( r) r* r� r r r r r. � s� � , � & � !4 � j � 1 r. )N)NNFNN)NN)&r� r� rt r� r Z keystoneauth1.exceptions.catalogZkeystoneauth1.loadingr r9 r rL r7 r� r � ImportErrorr r/ r r r� r Zopenstack.configr r r+ r r rG r; r� �objectZ_ENOENTr r r% r1 rB r. r r r r �<module> sL � ! R
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка