Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/__pycache__/connection.cpython-39.pyc
Ðазад
a t�h�S � @ s� d Z ddlZddlZzddlmZ W n ey> ddlZY n0 ddlZddl Z ddl Z ddl m Z ddl mZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z ddlm Z ddlm Z ddl m!Z" ddl#m$Z$ ddl m%Z% ddl m&Z& ddgZ'e j(�r�ej)de j(d � e �*d �Z+d d d�Z,G d d� dej-ej.ej/ej0ej1ej2ej3ej4ej5ej6ej7ej8e j9e j:e j;e j<e j=�Z>dS )!a� The :class:`~openstack.connection.Connection` class is the primary interface to the Python SDK. It maintains a context for a connection to a region of a cloud provider. The :class:`~openstack.connection.Connection` has an attribute to access each OpenStack service. At a minimum, the :class:`~openstack.connection.Connection` class needs to be created with a config or the parameters to build one. While the overall system is very flexible, there are four main use cases for different ways to create a :class:`~openstack.connection.Connection`. * Using config settings and keyword arguments as described in :ref:`openstack-config` * Using only keyword arguments passed to the constructor ignoring config files and environment variables. * Using an existing authenticated `keystoneauth1.session.Session`, such as might exist inside of an OpenStack service operational context. * Using an existing :class:`~openstack.config.cloud_region.CloudRegion`. Using config settings --------------------- For users who want to create a :class:`~openstack.connection.Connection` making use of named clouds in ``clouds.yaml`` files, ``OS_`` environment variables and python keyword arguments, the :func:`openstack.connect` factory function is the recommended way to go: .. code-block:: python import openstack conn = openstack.connect(cloud='example', region_name='earth1') If the application in question is a command line application that should also accept command line arguments, an `argparse.Namespace` can be passed to :func:`openstack.connect` that will have relevant arguments added to it and then subsequently consumed by the constructor: .. code-block:: python import argparse import openstack options = argparse.ArgumentParser(description='Awesome OpenStack App') conn = openstack.connect(options=options) Using Only Keyword Arguments ---------------------------- If the application wants to avoid loading any settings from ``clouds.yaml`` or environment variables, use the :class:`~openstack.connection.Connection` constructor directly. As long as the ``cloud`` argument is omitted or ``None``, the :class:`~openstack.connection.Connection` constructor will not load settings from files or the environment. .. note:: This is a different default behavior than the :func:`~openstack.connect` factory function. In :func:`~openstack.connect` if ``cloud`` is omitted or ``None``, a default cloud will be loaded, defaulting to the ``envvars`` cloud if it exists. .. code-block:: python from openstack import connection conn = connection.Connection( region_name='example-region', auth=dict( auth_url='https://auth.example.com', username='amazing-user', password='super-secret-password', project_id='33aa1afc-03fe-43b8-8201-4e0d3b4b8ab5', user_domain_id='054abd68-9ad9-418b-96d3-3437bb376703'), compute_api_version='2', identity_interface='internal') Per-service settings as needed by `keystoneauth1.adapter.Adapter` such as ``api_version``, ``service_name``, and ``interface`` can be set, as seen above, by prefixing them with the official ``service-type`` name of the service. ``region_name`` is a setting for the entire :class:`~openstack.config.cloud_region.CloudRegion` and cannot be set per service. From existing authenticated Session ----------------------------------- For applications that already have an authenticated Session, simply passing it to the :class:`~openstack.connection.Connection` constructor is all that is needed: .. code-block:: python from openstack import connection conn = connection.Connection( session=session, region_name='example-region', compute_api_version='2', identity_interface='internal') From oslo.conf CONF object -------------------------- For applications that have an oslo.config ``CONF`` object that has been populated with ``keystoneauth1.loading.register_adapter_conf_options`` in groups named by the OpenStack service's project name, it is possible to construct a Connection with the ``CONF`` object and an authenticated Session. .. note:: This is primarily intended for use by OpenStack services to talk amongst themselves. .. code-block:: python from openstack import connection conn = connection.Connection( session=session, oslo_conf=CONF) From existing CloudRegion ------------------------- If you already have an :class:`~openstack.config.cloud_region.CloudRegion` you can pass it in instead: .. code-block:: python from openstack import connection import openstack.config config = openstack.config.get_cloud_region( cloud='example', region_name='earth') conn = connection.Connection(config=config) Using the Connection -------------------- Services are accessed through an attribute named after the service's official service-type. List ~~~~ An iterator containing a list of all the projects is retrieved in this manner: .. code-block:: python projects = conn.identity.projects() Find or create ~~~~~~~~~~~~~~ If you wanted to make sure you had a network named 'zuul', you would first try to find it and if that fails, you would create it:: network = conn.network.find_network("zuul") if network is None: network = conn.network.create_network(name="zuul") Additional information about the services can be found in the :ref:`service-proxies` documentation. � N)�_log)�_services_mixin)�openstackcloud)� _accelerator)� _baremetal)�_block_storage)�_compute)� _clustering)�_coe)�_dns)� _floating_ip)� _identity)�_image)�_network)�_network_common)� _object_store)�_orchestration)�_security_group��config)� cloud_region)� exceptions)�service_description� from_config� Connection�ignore)�category� openstackc K sD |� d| �} |� d|�}|du r:t�� jf | |d�|��}t|d�S )an Create a Connection using openstack.config :param str cloud: Use the `cloud` configuration details when creating the Connection. :param openstack.config.cloud_region.CloudRegion config: An existing CloudRegion configuration. If no `config` is provided, `openstack.config.OpenStackConfig` will be called, and the provided `name` will be used in determining which cloud's configuration details will be used in creation of the `Connection` instance. :param argparse.Namespace options: Allows direct passing in of options to be added to the cloud config. This does not have to be an actual instance of argparse.Namespace, despite the naming of the `openstack.config.loader.OpenStackConfig.get_one` argument to which it is passed. :rtype: :class:`~openstack.connection.Connection` Z cloud_nameZ cloud_configN)�cloud�argparser )�pop�_configZOpenStackConfigZget_oner )r r �options�kwargs� r$ ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/connection.pyr � s ��c @ s^ e Zd Zddd�Zedd� �Zdd� Zd d � Zed d � �Zd d� Z dd� Z dd� Z dd� Z dS )r NFc K s� || _ i | _|| _|r,|D ]}|| j|j< q| j s�| rNtj| |||| d�| _ nN|rttjf |||dd| d�|��| _ n(tjf ||||du|du| d�|��| _ d| _ i | _ || _ | | _ || _ || _tj�| � tj�| � tj�| � tj�| � tj�| � tj�| � t j �| � t j �| � t j!�| � t"j#�| � t$j%�| � t&j'�| � t(j)�| � t*j+�| � t,j-�| � t.j/�| � |�0d�}|�s�d| j j v �r�| j j �0d�}|�rTzdz>|�1d�\}}|�r�|�r�t2j3d|dd�}|�4� }|| � W n t5�y | j6�7d � Y n0 W n< t8t9t:f�yR } z | j6�7d ||� W Y d}~n d}~0 0 | j j;�r�d | j j v �r�| j j d | j j;d < dS ) a' Create a connection to a cloud. A connection needs information about how to connect, how to authenticate and how to select the appropriate services to use. The recommended way to provide this information is by referencing a named cloud config from an existing `clouds.yaml` file. The cloud name ``envvars`` may be used to consume a cloud configured via ``OS_`` environment variables. A pre-existing :class:`~openstack.config.cloud_region.CloudRegion` object can be passed in lieu of a cloud name, for cases where the user already has a fully formed CloudRegion and just wants to use it. Similarly, if for some reason the user already has a :class:`~keystoneauth1.session.Session` and wants to use it, it may be passed in. :param str cloud: Name of the cloud from config to use. :param config: CloudRegion object representing the config for the region of the cloud in question. :type config: :class:`~openstack.config.cloud_region.CloudRegion` :param session: A session object compatible with :class:`~keystoneauth1.session.Session`. :type session: :class:`~keystoneauth1.session.Session` :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 extra_services: List of :class:`~openstack.service_description.ServiceDescription` objects describing services that openstacksdk otherwise does not know about. :param bool use_direct_get: For get methods, make specific REST calls for server-side filtering instead of making list calls and filtering client-side. Default false. :param task_manager: Ignored. Exists for backwards compat during transition. Rate limit parameters should be passed directly to the `rate_limit` parameter. :param rate_limit: Client-side rate limit, expressed in calls per second. The parameter can either be a single float, or it can be a dict with keys as service-type and values as floats expressing the calls per second for that service. Defaults to None, which means no rate-limiting is performed. :param oslo_conf: An oslo.config CONF object. :type oslo_conf: :class:`~oslo_config.cfg.ConfigOpts` An oslo.config ``CONF`` object that has been populated with ``keystoneauth1.loading.register_adapter_conf_options`` in groups named by the OpenStack service's project name. :param service_types: A list/set of service types this Connection should support. All other service types will be disabled (will error if used). **Currently only supported in conjunction with the ``oslo_conf`` kwarg.** :param global_request_id: A Request-id to send with all interactions. :param strict_proxies: If True, check proxies on creation and raise ServiceDiscoveryException if the service is unavailable. :type strict_proxies: bool Throw an ``openstack.exceptions.ServiceDiscoveryException`` if the endpoint for a given service doesn't work. This is useful for OpenStack services using sdk to talk to other OpenStack services where it can be expected that the deployer config is correct and errors should be reported immediately. Default false. :param pool_executor: :type pool_executor: :class:`~futurist.Executor` A futurist ``Executor`` object to be used for concurrent background activities. Defaults to None in which case a ThreadPoolExecutor will be created if needed. :param kwargs: If a config is not provided, the rest of the parameters provided are assumed to be arguments to be passed to the CloudRegion constructor. )�session�app_name� app_version� service_typesF)r& r' r( �load_yaml_config� load_envvars� rate_limitN)r r' r( r* r+ r, � vendor_hook�:)�name�value�groupz8Hook should be in the entrypoint module:attribute formatz)Configured hook %s cannot be executed: %sZadditional_metric_tags)<r Z_extra_servicesZ_strict_proxies� service_typer Z from_confZ from_sessionr! Zget_cloud_region�_session�_proxies�_Connection__pool_executor�_global_request_id�use_direct_getZ strict_mode�_cloud�_OpenStackCloudMixin�__init__r �AcceleratorCloudMixinr �BaremetalCloudMixinr �BlockStorageCloudMixinr �ClusteringCloudMixinr � CoeCloudMixinr �ComputeCloudMixinr � DnsCloudMixinr �FloatingIPCloudMixinr �IdentityCloudMixinr �ImageCloudMixinr �NetworkCommonCloudMixinr �NetworkCloudMixinr �ObjectStoreCloudMixinr �OrchestrationCloudMixinr �SecurityGroupCloudMixin�get�rsplit�importlib_metadata� EntryPoint�load� ValueError�log�warning� ImportError� TypeError�AttributeErrorZ_influxdb_config)�selfr r r& r' r( Zextra_services�strictr7 Z task_managerr, Z oslo_confr) �global_request_idZstrict_proxiesZ pool_executorr# �servicer- � package_name�function�ep�hook�er$ r$ r% r: s� X� �� �� � � � �zConnection.__init__c C s& | j s | j�� | _ t�| �| j_| j S �N)r3 r Z get_session�weakref�proxyr& Z_sdk_connection�rU r$ r$ r% r& � s zConnection.sessionc sZ t � t�rt�� �� � fdd�}� jD ] }t| j|�dd�t|d�� q&| j � � j � dS )a� Add a service to the Connection. Attaches an instance of the :class:`~openstack.proxy.Proxy` class contained in :class:`~openstack.service_description.ServiceDescription`. The :class:`~openstack.proxy.Proxy` will be attached to the `Connection` by its ``service_type`` and by any ``aliases`` that may be specified. :param openstack.service_description.ServiceDescription service: Object describing the service to be attached. As a convenience, if ``service`` is a string it will be treated as a ``service_type`` and a basic :class:`~openstack.service_description.ServiceDescription` will be created. c s � � | � �S r^ )�__get__ra �rX r$ r% �getter� s z&Connection.add_service.<locals>.getter�-�_)�fgetN) � isinstance�strr ZServiceDescriptionZ all_types�setattr� __class__�replace�propertyr Zenable_servicer2 )rU rX rd � attr_namer$ rc r% � add_service� s �zConnection.add_servicec C sD z | j �� W S tjjy> } zt�|��W Y d}~n d}~0 0 dS )a- Authorize this Connection .. note:: This method is optional. When an application makes a call to any OpenStack service, this method allows you to request a token manually before attempting to do anything else. :returns: A string token. :raises: :class:`~openstack.exceptions.HttpException` if the authorization fails due to reasons like the credentials provided are unable to be authorized or the `auth_type` argument is missing, etc. N)r& � get_token� keystoneauth1r ZClientExceptionZ SDKException)rU r] r$ r$ r% � authorize� s zConnection.authorizec C s | j stjjdd�| _ | j S )N� )� max_workers)r5 � concurrentZfuturesZThreadPoolExecutorra r$ r$ r% �_pool_executor s �zConnection._pool_executorc C s | j r| j �� dS )z Release any resources held open.N)r5 �shutdownra r$ r$ r% �close s zConnection.closec C s || _ d S r^ )r6 )rU rW r$ r$ r% �set_global_request_id s z Connection.set_global_request_idc C s | S r^ r$ ra r$ r$ r% � __enter__ s zConnection.__enter__c C s | � � d S r^ )rx )rU �exc_type� exc_value� tracebackr$ r$ r% �__exit__ s zConnection.__exit__)NNNNNNFFNNNNNFN) �__name__� __module__� __qualname__r: rm r& ro rr rv rx ry rz r~ r$ r$ r$ r% r s0 � 3 $ )NNN)?�__doc__�warningsr_ �importlib.metadata�metadatarL rR �concurrent.futuresru Zkeystoneauth1.exceptionsrq Zrequestsexceptionsr r r Zopenstack.cloudr r8 r r r r r r r r r r r r r r r r r! Zopenstack.configr r r �__all__�SubjectAltNameWarning�filterwarnings� setup_loggingZ_loggerr Z ServicesMixinr9 r; r< r= r@ r> r? rA rB rC rD rF rE rG rH rI r r$ r$ r$ r% �<module> sx ' �� �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка