Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/cloud/__pycache__/_compute.cpython-39.pyc
Ðазад
a t�h�% � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dlm Z d dlm Z d dlm Z d dl mZ d dl mZ d dl mZ G d d � d e j�ZdS ) � N)�exc)�meta)� _normalize)�_utils)� exceptions)�proxy)�utilsc @ s e Zd Zdd� Zedd� �Zdd� Zd�d d �Ze� � d d � �Z d d� Z d�dd�Z d�dd�Z d�dd�Zd�dd�Zd�dd�Ze� � d�dd��Ze� � d�d d ��Zd d � Zd d!� Zd"d#� Zd$d%� Zd�d&d'�Zd�d(d)�Zd*d+� Zd�d,d-�Zd�d.d/�Zd�d0d1�Z d�d2d3�Z d�d4d5�Z d�d6d7�Z d�d8d9�Z d:d;� Z!d<d=� Z"d�d>d?�Z#d�d@dA�Z$dBdC� Z%d�dEdF�Z&dGdH� Z'dIdJ� Z(dKdL� Z)dMdN� Z*e�+dOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_�d�dbdc��Z,ddde� Z-d�dfdg�Z.d�dhdi�Z/d�djdk�Z0dldm� Z1dndo� Z2d�dqdr�Z3dsdt� Z4d�dudv�Z5e�+dwdx�d�dydz��Z6g dfd{d|�Z7d}d~� Z8d�d�d��Z9d�d�� Z:d�d�� Z;d�d�� Z<d�d�� Z=d�d�� Z>d�d�� Z?d�d�� Z@i fd�d��ZAd�d�d��ZBi fd�d��ZCd�d�d��ZDd�d�d��ZEe�+dwdX�d�d�� �ZFd�d�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�d�d��ZNd�d�� ZOd�d�� ZPd�d�� ZQdS )��ComputeCloudMixinc C s d | _ d| _t�� | _d S )Nr )�_servers� _servers_time� threading�Lock� _servers_lock��self� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/cloud/_compute.py�__init__$ s zComputeCloudMixin.__init__c C s | j �d�S )N�compute)�configZget_region_namer r r r �_compute_region) s z!ComputeCloudMixin._compute_regionc C s | j |dd�}|r|d S d S )NF�� get_extra�name)� get_flavor)r � flavor_id�flavorr r r �get_flavor_name. s z!ComputeCloudMixin.get_flavor_nameNTc C s` | j |d�}t|t�d�d�D ](}|d |kr |r>||d v r | S q t�dj||d���dS )a� Get a flavor based on amount of RAM available. Finds the flavor with the least amount of RAM that is at least as much as the specified amount. If `include` is given, further filter based on matching flavor name. :param int ram: Minimum amount of RAM. :param string include: If given, will return a flavor whose name contains this string as a substring. r �ram)�keyr z2Could not find a flavor with {ram} and '{include}')r �includeN)� list_flavors�sorted�operator� itemgetterr �OpenStackCloudException�format)r r r r �flavorsr r r r �get_flavor_by_ram4 s � � ��z#ComputeCloudMixin.get_flavor_by_ramc C s@ t � }tj| j�d�dd�}| �d|�D ]}|�|d � q(|S )Nz /extensionsz&Error fetching extension list for nova�� error_message� extensions�alias)�setr �_json_responser �get�_get_and_munchify�add)r r+ �data� extensionr r r �_nova_extensionsH s �z"ComputeCloudMixin._nova_extensionsc C s || � � v S �N)r4 )r Zextension_namer r r �_has_nova_extensionS s z%ComputeCloudMixin._has_nova_extensionc C s( | j t|t�r|nd d�}t�|||�S )N)�filters)� list_keypairs� isinstance�dictr � _filter_list)r � name_or_idr7 �keypairsr r r �search_keypairsV s �z!ComputeCloudMixin.search_keypairsc C s | j |d�}t�|||�S )Nr )r! r r; )r r< r7 r r' r r r �search_flavors\ s z ComputeCloudMixin.search_flavorsFc C s | j |||d�}t�|||�S )N��detailed� all_projects�bare)� list_serversr r; )r r< r7 rA rB rC �serversr r r �search_servers` s �z ComputeCloudMixin.search_serversc C s | � � }t�|||�S )aC Seach server groups. :param name: server group name or ID. :param filters: a dict containing additional filters to use. :returns: a list of dicts containing the server groups :raises: ``OpenStackCloudException``: if something goes wrong during the OpenStack API call. )�list_server_groupsr r; )r r< r7 � server_groupsr r r �search_server_groupsg s z&ComputeCloudMixin.search_server_groupsc C s" |si }t | jjf ddi|���S )zlList all available keypairs. :returns: A list of ``munch.Munch`` containing keypair info. �allow_unknown_paramsT)�listr r= �r r7 r r r r8 u s �z ComputeCloudMixin.list_keypairsc C sf z8| j �� }g }|D ] }|jd s&|r|�|j� q|W S tjy` | jjddd� g Y S 0 dS )a6 List names of availability zones. :param bool unavailable: Whether or not to include unavailable zones in the output. Defaults to False. :returns: A list of availability zone names, or an empty list if the list could not be fetched. � availablez+Availability zone list could not be fetchedT)�exc_infoN) r Zavailability_zones�state�appendr r Z SDKException�log�debug)r � unavailableZzones�ret�zoner r r � list_availability_zone_names� s �z.ComputeCloudMixin.list_availability_zone_namesc C s� t j| jjdtdd�d�dd�}| �| �d|��}|D ]�}|js6|r6dj|j d �}z(t j| j�|�d d�}| �d |�|_W q6 t j y� } z(i |_| j � d d t|�i� W Y d}~q6d}~0 0 q6|S )av List all available flavors. :param get_extra: Whether or not to fetch extra specs for each flavor. Defaults to True. Default behavior value can be overridden in clouds.yaml by setting openstack.cloud.get_extra_specs to False. :returns: A list of flavor ``munch.Munch``. z/flavors/detail�None)� is_public��paramszError fetching flavor listr) r' � /flavors/{id}/os-extra_specs��id�!Error fetching flavor extra specs� extra_specs�/Fetching extra specs for flavor failed: %(msg)s�msgN)r r. r r/ r: Z_normalize_flavorsr0 r_ r& r] r �OpenStackCloudHTTPErrorrQ rR �str)r r r2 r' r �endpoint�er r r r! � s: �� � � �� � z ComputeCloudMixin.list_flavorsc C s0 | � � s g S | j�|�}|�| j� | �|j�S )z�List all security groups associated with the given server. :returns: A list of security group ``munch.Munch``. )�_has_secgroupsr � get_serverZfetch_security_groupsZ_normalize_secgroups�security_groups�r �serverr r r �list_server_security_groups� s z-ComputeCloudMixin.list_server_security_groupsc C s� | � � st�d��t|t�sD| j|dd�}|d u rD| j�d|� dS t|tt f�sX|g}g }|D ]>}t|t�s�| � |�}|d u r�| j�d|� dS |� |� q`||fS )Nz$Unavailable feature: security groupsT�rC zServer %s not found)NNz&Security group %s not found for adding) rf r Z OpenStackCloudUnavailableFeaturer9 r: rg rQ rR rK �tupleZget_security_grouprP )r rj rh Zsec_group_objs�sgr r r �_get_server_security_groups� s, � � z-ComputeCloudMixin._get_server_security_groupsc C s8 | � ||�\}}|r|s dS |D ]}| j�||� q dS )aj Add security groups to a server. Add existing security groups to an existing server. If the security groups are already present on the server this will continue unaffected. :returns: False if server or security groups are undefined, True otherwise. :raises: ``OpenStackCloudException``, on operation error. FT)ro r Z add_security_group_to_server)r rj rh rn r r r �add_server_security_groups� s �z,ComputeCloudMixin.add_server_security_groupsc C sn | � ||�\}}|r|s dS d}|D ]D}z| j�||� W q$ tjyf | j�d|j|j� d}Y q$0 q$|S )aw Remove security groups from a server Remove existing security groups from an existing server. If the security groups are not present on the server this will continue unaffected. :returns: False if server or security groups are undefined, True otherwise. :raises: ``OpenStackCloudException``, on operation error. FTzMThe security group %s was not present on server %s so no action was performed)ro r Z!remove_security_group_from_serverr �ResourceNotFoundrQ rR r )r rj rh rT rn r r r � remove_server_security_groups s �� z/ComputeCloudMixin.remove_server_security_groupsc C s� |r | j dkr | j||||d�S t�� | j | j kr�| jdu }| j�|�r�z8|rZ| jdusv| j|||d�| _t�� | _W | j�� n | j�� 0 t� | jd|�S )a� List all available servers. :param detailed: Whether or not to add detailed additional information. Defaults to False. :param all_projects: Whether to list servers from all projects or just the current auth scoped project. :param bare: Whether to skip adding any additional information to the server record. Defaults to False, meaning the addresses dict will be populated as needed from neutron. Setting to True implies detailed = False. :param filters: Additional query parameters passed to the API server. :returns: A list of server ``munch.Munch``. r )rA rB rC r7 Nr@ ) � _SERVER_AGE� _list_servers�timer r r �acquire�releaser r; )r rA rB rC r7 Z first_runr r r rD $ s( � � z ComputeCloudMixin.list_serversc sD |pi }�fdd��j jf |dd�|��D �}� ��fdd�|D �S )Nc s g | ]}� � |�� ��qS r )�_normalize_serverZ _to_munch��.0rj r r r � <listcomp>Z s �z3ComputeCloudMixin._list_servers.<locals>.<listcomp>T)rB rJ c s g | ]}�� |�� ��qS r )�_expand_serverry �rC rA r r r r{ b s �)r rE )r rA rB rC r7 rE r r} r rt W s ����z ComputeCloudMixin._list_serversc C s t | j�� �S )z\List all available server groups. :returns: A list of server group dicts. )rK r rH r r r r rG g s z$ComputeCloudMixin.list_server_groupsc C st i }d}d}|rD| � |�}|s(t�d��|j}||d< dj||d�}t�| jjd|d��}| � d |�}| j ||d �S ) a, Get compute limits for a project :param name_or_id: (optional) project name or ID to get limits for if different from the current project :raises: OpenStackCloudException if it's not a valid project :returns: Munch object with the limits NzFailed to get limits�project does not existZ tenant_idz!{msg} for the project: {project} )ra �projectz/limitsrY �limits)� project_id) � get_projectr r% r] r& r r. r r/ r0 Z_normalize_compute_limits)r r< rZ r� � error_msg�projr2 r� r r r �get_compute_limitso s" �� z$ComputeCloudMixin.get_compute_limitsc C s t �| d||�S )a� Get a keypair by name or ID. :param name_or_id: Name or ID of the keypair. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :returns: A keypair ``munch.Munch`` or None if no matching keypair is found. �keypair�r � _get_entity�r r< r7 r r r � get_keypair� s z ComputeCloudMixin.get_keypairc C s t j| j|d�}t�| |||�S )a6 Get a flavor by name or ID. :param name_or_id: Name or ID of the flavor. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :param get_extra: Whether or not the list_flavors call should get the extra flavor specs. :returns: A flavor ``munch.Munch`` or None if no matching flavor is found. r )� functools�partialr? r r� )r r< r7 r Z search_funcr r r r � s �z ComputeCloudMixin.get_flavorc C s� t j| j�dj|d��dj|d�d�}| �| �d|��}|js�|r�dj|jd�}z(t j| j�|�dd�}| �d|�|_W nB t j y� } z(i |_| j � d d t |�i� W Y d }~n d }~0 0 |S ) z� Get a flavor by ID :param id: ID of the flavor. :param get_extra: Whether or not the list_flavors call should get the extra flavor specs. :returns: A flavor ``munch.Munch``. � /flavors/{id}r\ z!Error getting flavor with ID {id}r) r r[ r^ r_ r` ra N)r r. r r/ r& �_normalize_flavorr0 r_ r] r rb rQ rR rc )r r] r r2 r rd re r r r �get_flavor_by_id� s4 � � � �� �z"ComputeCloudMixin.get_flavor_by_idc C sT t |t�s| j|dd�}|s&t�d��z| �|d |�W S tjyN Y dS 0 dS )au Get the console log for a server. :param server: The server to fetch the console log for. Can be either a server dict or the Name or ID of the server. :param int length: The number of lines you would like to retrieve from the end of the log. (optional, defaults to all) :returns: A string containing the text of the console log or an empty string if the cloud does not support console logs. :raises: OpenStackCloudException if an invalid server argument is given or if something else unforseen happens Trl z(Console log requested for invalid serverr] � N)r9 r: rg r r% �_get_server_console_outputZOpenStackCloudBadRequest)r rj �lengthr r r �get_server_console� s �z$ComputeCloudMixin.get_server_consolec C s$ | j j||d�}d|v r |d S d S )N)rj r� �output)r Zget_server_console_output)r � server_idr� r� r r r r� � s �z,ComputeCloudMixin._get_server_console_outputc C s2 t j| j|d|d�}t�| |||�}| �|||�S )a� Get a server by name or ID. :param name_or_id: Name or ID of the server. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'last_name': 'Smith', 'other': { 'gender': 'Female' } } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :param detailed: Whether or not to add detailed additional information. Defaults to False. :param bare: Whether to skip adding any additional information to the server record. Defaults to False, meaning the addresses dict will be populated as needed from neutron. Setting to True implies detailed = False. :param all_projects: Whether to get server from all projects or just the current auth scoped project. :returns: A server ``munch.Munch`` or None if no matching server is found. T)rA rC rB )r� r� rF r r� r| )r r< r7 rA rC rB Z searchfuncrj r r r rg s !�z ComputeCloudMixin.get_serverc C s, |s|s |S |r t �| |�S t �| |�S d S r5 )r �get_hostvars_from_server�add_server_interfaces)r rj rA rC r r r r| * s z ComputeCloudMixin._expand_serverc C sV z:t �| j�dj|d���}| �d|�}t�| | �|��W S t j yP Y dS 0 dS )z�Get a server by ID. :param id: ID of the server. :returns: A server dict or None if no matching server is found. � /servers/{id}r\ rj N) r r. r r/ r& r0 r r� rx r rq )r r] r2 rj r r r �get_server_by_id2 s � �z"ComputeCloudMixin.get_server_by_idc C s t �| d||�S )at Get a server group by name or ID. :param name_or_id: Name or ID of the server group. :param filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'policy': 'affinity', } OR A string containing a jmespath expression for further filtering. Example:: "[?last_name==`Smith`] | [?other.gender]==`Female`]" :returns: A server groups dict or None if no matching server group is found. � server_groupr� r� r r r �get_server_groupB s �z"ComputeCloudMixin.get_server_groupc C s& d|i}|r||d< | j jf i |��S )z�Create a new keypair. :param name: Name of the keypair being created. :param public_key: Public key for the new keypair. :raises: OpenStackCloudException on operation error. r � public_key)r �create_keypair)r r r� r� r r r r� Y s �z ComputeCloudMixin.create_keypairc C s> z| j j|dd� W n$ tjy8 | j�d|� Y dS 0 dS )z�Delete a keypair. :param name: Name of the keypair to delete. :returns: True if delete succeeded, False otherwise. :raises: OpenStackCloudException on operation error. F�Zignore_missingz!Keypair %s not found for deletingT)r �delete_keypairr rq rQ rR )r r r r r r� h s z ComputeCloudMixin.delete_keypair� c K sL t |t�s2| j|dd�}|s.t�dj|d���|}| jj|||||d�}|S )aV Create an image by snapshotting an existing server. ..note:: On most clouds this is a cold snapshot - meaning that the server in question will be shutdown before taking the snapshot. It is possible that it's a live snapshot - but there is no way to know as a user, so caveat emptor. :param name: Name of the image to be created :param server: Server name or ID or dict representing the server to be snapshotted :param wait: If true, waits for image to be created. :param timeout: Seconds to wait for image creation. None is forever. :param metadata: Metadata to give newly-created image entity :returns: A ``munch.Munch`` of the Image object :raises: OpenStackCloudException if there are problems uploading Trl zJServer {server} could not be found and therefore could not be snapshotted.�rj )r �metadata�wait�timeout)r9 r: rg r r% r& r Zcreate_server_image)r r rj r� r� r� Z server_obj�imager r r �create_image_snapshotx s �� �z'ComputeCloudMixin.create_image_snapshotc C s | j |dd�}|r|d S d S )NTrl r] )rg )r r< rj r r r � get_server_id� s z ComputeCloudMixin.get_server_idc C s t �|| �S r5 )r �get_server_private_ipri r r r r� � s z'ComputeCloudMixin.get_server_private_ipc C s t �| |�S r5 )r Zget_server_external_ipv4ri r r r �get_server_public_ip� s z&ComputeCloudMixin.get_server_public_ipc C s& t �| |�}t �| ||�}t||d�S )N)� server_vars�groups)r r� Zget_groups_from_serverr: )r rj r� r� r r r �get_server_meta� s z!ComputeCloudMixin.get_server_metar �files�userdataZreservation_idZ return_raw� min_count� max_countrh �key_name�availability_zoneZblock_device_mapping�block_device_mapping_v2�nics�scheduler_hints� config_drive� admin_pass� disk_config� �50c - K s |s t d��|s |s t d��d}d|i}|�dg �}|rLt|d t�sL|g}|rvg |d< |D ]}|d �t|d�� q\d|v r�|�d�}|r�| �|�|d< d D ] \}}|�|d�}|r�|||< q�|�d i �} |r�| �|�} | s�t � d j |d ���| d | d< | �r | |d< |� d|�dd�� |� d|�dd�� d|v �r�t|d t��s�t|d t��rl|d g|d< nt � dj |d d���| �r d|v�s�|d �s g } t| t��s�| g} | D ]`} t| t��r�d | v �r�| } n | j | d�} | �st � dj | | j| jd���| �d| d i� �q�| |d< | �sZd|v�s:|d �sZ| �� }!|!�rZd|!d ig|d< g }"|�dg �D �]$}#i }$d|#v �r�|#�d�|$d< |#�dd� nBd|#v �r�|#�d�} | � | �}%|%�s�t � d j | d ���|%d |$d< d D ]<}&|#�|&d�}'|'�r |$�d ��r t � d ��|'�r�|'|$d < �q�d!D ] }(|(|#v �r"|#�|(�|$d"< �q"d#|#v �rht�| jd$�}|#�d#�|$d#< |#�r�t � d%j |#�� d&���|"�|$� �qj|"�r�|"|d'< |�r�t|t��r�|d |d(< n| �|�j|d(< t|t��r�|d |d)< n| j|d*d+�j|d)< |du �r g }|�r |�s |}| j|| |t|�|||d,�}||d-< d.})d/|v �rRd0})t�d1��x t � | jj |)||d2��}*| � d|*�}+|+�d3��p�|�d4�},| �s�| � |+j�}+|+j!d5k�r�t j"d|+jd6��W d � n1 �s�0 Y | �r| j#|+|||| | |d7�}+|,|+_$|+S )8a? Create a virtual server instance. :param name: Something to name the server. :param image: Image dict, name or ID to boot with. image is required unless boot_volume is given. :param flavor: Flavor dict, name or ID to boot onto. :param auto_ip: Whether to take actions to find a routable IP for the server. (defaults to True) :param ips: List of IPs to attach to the server (defaults to None) :param ip_pool: Name of the network or floating IP pool to get an address from. (defaults to None) :param root_volume: Name or ID of a volume to boot from (defaults to None - deprecated, use boot_volume) :param boot_volume: Name or ID of a volume to boot from (defaults to None) :param terminate_volume: If booting from a volume, whether it should be deleted when the server is destroyed. (defaults to False) :param volumes: (optional) A list of volumes to attach to the server :param meta: (optional) A dict of arbitrary key/value metadata to store for this server. Both keys and values must be <=255 characters. :param files: (optional, deprecated) A dict of files to overwrite on the server upon boot. Keys are file names (i.e. ``/etc/passwd``) and values are the file contents (either as a string or as a file-like object). A maximum of five entries is allowed, and each file must be 10k or less. :param reservation_id: a UUID for the set of servers being requested. :param min_count: (optional extension) The minimum number of servers to launch. :param max_count: (optional extension) The maximum number of servers to launch. :param security_groups: A list of security group names :param userdata: user data to pass to be exposed by the metadata server this can be a file type object as well or a string. :param key_name: (optional extension) name of previously created keypair to inject into the instance. :param availability_zone: Name of the availability zone for instance placement. :param block_device_mapping: (optional) A dict of block device mappings for this server. :param block_device_mapping_v2: (optional) A dict of block device mappings for this server. :param nics: (optional extension) an ordered list of nics to be added to this server, with information about connected networks, fixed IPs, port etc. :param scheduler_hints: (optional extension) arbitrary key-value pairs specified by the client to help boot an instance :param config_drive: (optional extension) value for config drive either boolean, or volume-id :param disk_config: (optional extension) control how the disk is partitioned when the server is created. possible values are 'AUTO' or 'MANUAL'. :param admin_pass: (optional extension) add a user supplied admin password. :param wait: (optional) Wait for the address to appear as assigned to the server. Defaults to False. :param timeout: (optional) Seconds to wait, defaults to 60. See the ``wait`` parameter. :param reuse_ips: (optional) Whether to attempt to reuse pre-existing floating ips should a floating IP be needed (defaults to True) :param network: (optional) Network dict or name or ID to attach the server to. Mutually exclusive with the nics parameter. Can also be a list of network names or IDs or network dicts. :param boot_from_volume: Whether to boot from volume. 'boot_volume' implies True, but boot_from_volume=True with no boot_volume is valid and will create a volume from the image and use that. :param volume_size: When booting an image from volume, how big should the created volume be? Defaults to 50. :param nat_destination: Which network should a created floating IP be attached to, if it's not possible to infer from the cloud's configuration. (Optional, defaults to None) :param group: ServerGroup dict, name or id to boot the server in. If a group is provided in both scheduler_hints and in the group param, the group param will win. (Optional, defaults to None) :returns: A ``munch.Munch`` representing the created server. :raises: OpenStackCloudException on operation error. z5create_server() missing 1 required argument: 'flavor'z8create_server() requires either 'image' or 'boot_volume'Nrj rh �r r� � user_data))zOS-DCF:diskConfigr� )r� r� )r� r� )r� r )� adminPassr� r� zAServer Group {group} was requested but was not found on the cloud)�groupr] r� zos:scheduler_hintsr� � r� r� zBnics parameter to create_server takes a list of dicts. Got: {nics})r� )r< z<Network {network} is not a valid network in {cloud}:{region})�network�cloud�regionznet-id�uuidznet-namez+Requested network {net} could not be found.)�net)z v4-fixed-ipz v6-fixed-ip�fixed_ipr� z=Only one of v4-fixed-ip, v6-fixed-ip or fixed_ip may be given)�portzport-idr� �tagz2.42zEAdditional unsupported keys given for server network creation: {keys})�keys�networks�imageRefZ flavorRefFr )r� �boot_from_volume� boot_volume� volume_size�terminate_volume�volumes�kwargsr z/serversr� z/os-volumes_bootzError in creating instance)�json� microversionr� r� �ERROR)�resourceZ resource_id)�auto_ip�ips�ip_pool�reuser� �nat_destination)%� TypeErrorr/ r9 rK rP r: �pop�_encode_server_userdatar� r r% r& � setdefaultZ get_networkr r Zget_default_networkr Zpick_microversionr r� � get_imager] r � _get_boot_from_volume_kwargsrc r �shade_exceptionsr r. �postr0 r� �statusZ OpenStackCloudCreateException�wait_for_serverr� )-r r r� r r� r� r� Z root_volumer� r� r� Z reuse_ipsr� r� r� r� r� r� r� r� r� Z server_jsonrh Z sec_groupr� Zdesired�given�value�hintsZ group_objr� Znet_nameZ network_objZdefault_networkr� Znicr� Znic_netZip_keyr� r rd r2 rj r� r r r � create_server� s. g�� �� �� �� �� � �� � �� �&�z ComputeCloudMixin.create_serverc C s� |s |s |r|� dg � n|S |rv| �|�}|sJt�dj|| j| jd���d|d|d dd�} |d �| � d|d < nh|r�t|t �r�|} n | � |�} | s�t�d j|| j| jd ���d|d| d d |d �} d|d < |d �| � |�r|d �rdddd |d d�} |d �| � |D ]R}| �|�} | �sBt�dj|| j| jd���ddd| d dd�} |d �| � �q|�sz|�sz|�r�| j � | � |S )zbReturn block device mappings :param image: Image dict, name or id to boot with. r� z>Volume {boot_volume} is not a valid volume in {cloud}:{region})r� r� r� �0�volumer] )� boot_index�delete_on_termination�destination_typer� � source_typer� r� z6Image {image} is not a valid image in {cloud}:{region})r� r� r� r� )r� r� r� r� r� r� r T�local)r� r� r� r� r� z9Volume {volume} is not a valid volume in {cloud}:{region})r� r� r� z-1F) r� Z get_volumer r% r& r r rP r9 r: r� � list_volumes� invalidate) r r� r� r� r� r� r� r� r� Z block_mappingZ image_objZ volume_objr r r r� � s� ��� ���� ��� z.ComputeCloudMixin._get_boot_from_volume_kwargsc C s� |d }d} t � � } tj|| | jp$dd�D ]�} z| �|�}W n tyR Y q*Y n0 |sZq*|tt � � | � } | dkr�t�| ��| j |||||d| |d�}|dur*|d d kr*| S q*dS ) z; Wait for a server to reach ACTIVE status. r] z*Timeout waiting for the server to come up.� �r� r T)rj r� r� r� r� r� r� r� Nr� �ACTIVE) ru r �iterate_timeoutrs rg � Exception�intr ZOpenStackCloudTimeout�get_active_server) r rj r� r� r� r� r� r� r� Ztimeout_message� start_time�countZremaining_timeoutr r r r� s2 � �z!ComputeCloudMixin.wait_for_serverc C s |d dkrXd|v rDd|d v rDt jdj|d d d�t|d�d��t jd t|d�d��|d d k�rd |v r�|d r�| j||||||||d �S | j�d d|d i� z| j|||d� W n> ty� } z&t jd�| �t|d�d��W Y d } ~ n d } ~ 0 0 t jdt|d�d��d S )Nr� r� �fault�messagezEError in creating the server. Compute service reports fault: {reason})�reasonr� �� extra_dataz?Error in creating the server (no further information available)r� � addresses)r� r� r� r� z^Server %(server)s reached ACTIVE state without being allocated an IP address. Deleting server.rj r] )rj r� r� zdServer reached ACTIVE state without being allocated an IP address AND then could not be deleted: {0}zBServer reached ACTIVE state without being allocated an IP address.) r r% r& r: Zadd_ips_to_serverrQ rR �_delete_serverr� ) r rj r� r� r� r� r� r� r� re r r r r� G sN ��� � �� �� �z#ComputeCloudMixin.get_active_serverc C s i }|r||d< |r ||d< t j| jjdj|d�d|id�dd�} | �d | �} |sh| j| �| �||d �S | �d�pt|}t j |d �|�| j d �D ]j} z| j |d d�} W n t y� Y q�Y n0 | s�q�| d dkr�tjdt| d�d��| d dkr�|| _ q�q�| j| ||d�S )Nr� r� z/servers/{server_id}/action�r� Zrebuild�r� z Error in rebuilding instancer) rj �rC rA z*Timeout waiting for server {0} to rebuild.r� Trl r� r� z Error in rebuilding the serverr� r� r� )rA rC )r r. r r� r& r0 r| rx r/ r r� rs rg r� r r% r: r� ) r r� Zimage_idr� rA rC r� r� r� r2 rj r� r r r �rebuild_serverr sP �� ��� � z ComputeCloudMixin.rebuild_serverc C s@ | j |dd�}|s$t�dj|d���| jjf d|ji|�� dS )a� Set metadata in a server instance. :param str name_or_id: The name or ID of the server instance to update. :param dict metadata: A dictionary with the key=value pairs to set in the server instance. It only updates the key=value pairs provided. Existing ones will remain untouched. :raises: OpenStackCloudException on operation error. Trl �Invalid Server {server}r� rj N)rg r r% r& r �set_server_metadatar] )r r< r� rj r r r r � s �z%ComputeCloudMixin.set_server_metadatac C s: | j |dd�}|s$t�dj|d���| jj|j|d� dS )a2 Delete metadata from a server instance. :param str name_or_id: The name or ID of the server instance to update. :param metadata_keys: A list with the keys to be deleted from the server instance. :raises: OpenStackCloudException on operation error. Trl r r� )rj r� N)rg r r% r& r �delete_server_metadatar] )r r< Z metadata_keysrj r r r r � s � �z(ComputeCloudMixin.delete_server_metadatar� c C s* | j |dd�}|sdS | j|||||d�S )a� Delete a server instance. :param name_or_id: name or ID of the server to delete :param bool wait: If true, waits for server to be deleted. :param int timeout: Seconds to wait for server deletion. :param bool delete_ips: If true, deletes any floating IPs associated with the instance. :param int delete_ip_retry: Number of times to retry deleting any floating ips, should the first try be unsuccessful. :returns: True if delete succeeded, False otherwise if the server does not exist. :raises: OpenStackCloudException on operation error. Trl F)r� r� � delete_ips�delete_ip_retry)rg r )r r< r� r� r r rj r r r � delete_server� s �z ComputeCloudMixin.delete_serverc C s� t j|d dd�}|D ]p}z| jd d|d id�}W n tjyL Y qY n0 |sTq| j|d |d�}|st�d j|d |d d ���qd S ) Nr� Zfloating)Zext_tagZfloating_ip_address�addr)r] r7 r] )�retryz~Tried to delete floating ip {floating_ip} associated with server {id} but there was an error deleting it. Not deleting server.)Z floating_ipr] )r Zfind_nova_interfacesZget_floating_ipr �OpenStackCloudURINotFoundZdelete_floating_ipr% r& )r rj r Z server_floatsZfip�ipZdeletedr r r �_delete_server_floating_ips� s, �� ���z-ComputeCloudMixin._delete_server_floating_ipsc C s. |sdS |r | � � r | �||� z&tj| j�dj|d d��dd� W n( tjy\ Y dS t yn � Y n0 |sxdS d}| j r�| � d�r�| � |�r�d}t j|d | jp�d d �D ]X}t�d��8 | j|d dd �}|s�W d � �q W d � q�1 � s�0 Y q�|�r | j�| � | j| j | _dS ) NFr� r] r\ zError in deleting serverr) Tr� z,Timed out waiting for server to get deleted.r� r� rl )Z_has_floating_ipsr r r. r �deleter& r r r� Z cache_enabledZ has_serviceZ get_volumesr r� rs r r� rg r� r� r )r rj r� r� r r Zreset_volume_cacher� r r r r � sJ �� ��� 4 z ComputeCloudMixin._delete_serverr � descriptionc K sz | j |dd�}|du r(t�dj|d���tj| jjdj|d d�d |id �d �|�d �}| �| � d |��}| j |||d �S )a� Update a server. :param name_or_id: Name of the server to be updated. :param detailed: Whether or not to add detailed additional information. Defaults to False. :param bare: Whether to skip adding any additional information to the server record. Defaults to False, meaning the addresses dict will be populated as needed from neutron. Setting to True implies detailed = False. :name: New name for the server :description: New description for the server :returns: a dictionary representing the updated server. :raises: OpenStackCloudException on operation error. T)r< rC Nz failed to find server '{server}'r� z/servers/{server_id}r] r rj r zError updating server {0}r) r ) rg r r% r& r r. r �putrx r0 r| )r r< rA rC r� rj r2 r r r � update_server- s ��� �z ComputeCloudMixin.update_serverc C s2 d|i}|r||d< |r ||d< | j jf i |��S )a Create a new server group. :param name: Name of the server group being created :param policies: List of policies for the server group. :returns: a dict representing the new server group. :raises: OpenStackCloudException on operation error. r �policies�policy)r �create_server_group)r r r r Zsg_attrsr r r r N s � �z%ComputeCloudMixin.create_server_groupc C s4 | � |�}|s | j�d|� dS | jj|dd� dS )z�Delete a server group. :param name_or_id: Name or ID of the server group to delete :returns: True if delete succeeded, False otherwise :raises: OpenStackCloudException on operation error. z&Server group %s not found for deletingFr� T)r� rQ rR r �delete_server_group)r r< r� r r r r c s �z%ComputeCloudMixin.delete_server_group�autor � �?c C s� t �dj|d���T |||| |||||d� } |dkr<d| d< t�| jjdt| d�d ��} W d � n1 sl0 Y | �| � d | ��S ) a\ Create a new flavor. :param name: Descriptive name of the flavor :param ram: Memory in MB for the flavor :param vcpus: Number of VCPUs for the flavor :param disk: Size of local disk in GB :param flavorid: ID for the flavor (optional) :param ephemeral: Ephemeral space size in GB :param swap: Swap space in MB :param rxtx_factor: RX/TX factor :param is_public: Make flavor accessible to the public :returns: A ``munch.Munch`` describing the new flavor. :raises: OpenStackCloudException on operation error. z Failed to create flavor {name}r� ) �diskzOS-FLV-EXT-DATA:ephemeralr] zos-flavor-access:is_publicr r � rxtx_factor�swap�vcpusr Nr] z/flavors�r r r ) r r� r& r r. r r� r: r� r0 ) r r r r r ZflavoridZ ephemeralr r rX �payloadr2 r r r � create_flavoru s, � � �& �z ComputeCloudMixin.create_flavorc C sV | j |dd�}|du r(| j�d|� dS tj| j�dj|d d��dj|d �d � d S ) z�Delete a flavor :param name_or_id: ID or name of the flavor to delete. :returns: True if delete succeeded, False otherwise. :raises: OpenStackCloudException on operation error. Fr Nz Flavor %s not found for deletingr� r] r\ z Unable to delete flavor {name}r� r) T)r rQ rR r r. r r r& )r r< r r r r � delete_flavor� s ����z ComputeCloudMixin.delete_flavorc C s, t j| jjdj|d�t|d�d�dd� dS )a+ Add extra specs to a flavor :param string flavor_id: ID of the flavor to update. :param dict extra_specs: Dictionary of key-value pairs. :raises: OpenStackCloudException on operation error. :raises: OpenStackCloudResourceNotFound if flavor ID is not found. r[ r\ )r_ r zUnable to set flavor specsr) N)r r. r r� r& r: )r r r_ r r r �set_flavor_specs� s ��z"ComputeCloudMixin.set_flavor_specsc C s4 |D ]*}t j| j�dj||d��d�|�d� qdS )a" Delete extra specs from a flavor :param string flavor_id: ID of the flavor to update. :param keys: List of spec keys to delete. :raises: OpenStackCloudException on operation error. :raises: OpenStackCloudResourceNotFound if flavor ID is not found. z"/flavors/{id}/os-extra_specs/{key})r] r z Unable to delete flavor spec {0}r) N)r r. r r r& )r r r� r r r r �unset_flavor_specs� s ���z$ComputeCloudMixin.unset_flavor_specsc C sr t �dj||d���J dj|d�}d|i}dj|d�}t�| jj|||id�� W d � n1 sd0 Y d S ) z<Common method for adding and removing flavor access z7Error trying to {action} access from flavor ID {flavor})�actionr z/flavors/{id}/actionr\ Ztenantz{action}TenantAccess)r$ r N)r r� r& r r. r r� )r r$ r r� rd �accessZ access_keyr r r �_mod_flavor_access� s � �z$ComputeCloudMixin._mod_flavor_accessc C s | � d||� dS )z�Grant access to a private flavor for a project/tenant. :param string flavor_id: ID of the private flavor. :param string project_id: ID of the project/tenant. :raises: OpenStackCloudException on operation error. r1 N�r& �r r r� r r r �add_flavor_access� s z#ComputeCloudMixin.add_flavor_accessc C s | � d||� dS )z�Revoke access from a private flavor for a project/tenant. :param string flavor_id: ID of the private flavor. :param string project_id: ID of the project/tenant. :raises: OpenStackCloudException on operation error. �removeNr' r( r r r �remove_flavor_access� s z&ComputeCloudMixin.remove_flavor_accessc C s8 t j| j�dj|d��dj|d�d�}t�| �d|��S )a List access from a private flavor for a project/tenant. :param string flavor_id: ID of the private flavor. :returns: a list of ``munch.Munch`` containing the access description :raises: OpenStackCloudException on operation error. z /flavors/{id}/os-flavor-accessr\ z2Error trying to list access from flavorID {flavor}r r) Z flavor_access)r r. r r/ r& r Znormalize_flavor_accessesr0 )r r r2 r r r �list_flavor_access� s ��� �z$ComputeCloudMixin.list_flavor_accessc C s t | jjf ddd�|���S )zVList all hypervisors :returns: A list of hypervisor ``munch.Munch``. T)�detailsrJ )rK r Z hypervisorsrL r r r �list_hypervisors s ��z"ComputeCloudMixin.list_hypervisorsc C s | � � }t�|||�S )a? Seach host aggregates. :param name: aggregate name or id. :param filters: a dict containing additional filters to use. :returns: a list of dicts containing the aggregates :raises: ``OpenStackCloudException``: if something goes wrong during the OpenStack API call. )�list_aggregatesr r; )r r< r7 � aggregatesr r r �search_aggregates s z#ComputeCloudMixin.search_aggregatesc C s | j jf ddi|��S )z[List all available host aggregates. :returns: A list of aggregate dicts. rJ T)r r0 rL r r r r/ s z!ComputeCloudMixin.list_aggregatesc C s t �| d||�S )a5 Get an aggregate by name or ID. :param name_or_id: Name or ID of the aggregate. :param dict filters: A dictionary of meta data to use for further filtering. Elements of this dictionary may, themselves, be dictionaries. Example:: { 'availability_zone': 'nova', 'metadata': { 'cpu_allocation_ratio': '1.0' } } :returns: An aggregate dict or None if no matching aggregate is found. � aggregater� r� r r r � get_aggregate' s z ComputeCloudMixin.get_aggregatec C s | j j||d�S )a% Create a new host aggregate. :param name: Name of the host aggregate being created :param availability_zone: Availability zone to assign hosts :returns: a dict representing the new host aggregate. :raises: OpenStackCloudException on operation error. )r r� )r �create_aggregate)r r r� r r r r4 < s �z"ComputeCloudMixin.create_aggregatec K s | � |�}| jj|fi |��S )aX Update a host aggregate. :param name_or_id: Name or ID of the aggregate being updated. :param name: New aggregate name :param availability_zone: Availability zone to assign to hosts :returns: a dict representing the updated host aggregate. :raises: OpenStackCloudException on operation error. )r3 r �update_aggregate)r r< r� r2 r r r r5 K s z"ComputeCloudMixin.update_aggregatec C s| t |ttf�r<|�� s<| �|�}|s6| j�d|� dS |j}z| jj |dd� W dS t j yv | j�d|� Y dS 0 dS )z�Delete a host aggregate. :param name_or_id: Name or ID of the host aggregate to delete. :returns: True if delete succeeded, False otherwise. :raises: OpenStackCloudException on operation error. z#Aggregate %s not found for deletingFr� TN) r9 rc �bytes�isdigitr3 rQ rR r] r �delete_aggregater rq )r r< r2 r r r r8 Z s" �� �z"ComputeCloudMixin.delete_aggregatec C s* | � |�}|s t�d| ��| j�||�S )ap Set aggregate metadata, replacing the existing metadata. :param name_or_id: Name of the host aggregate to update :param metadata: Dict containing metadata to replace (Use {'key': None} to remove a key) :returns: a dict representing the new host aggregate. :raises: OpenStackCloudException on operation error. � Host aggregate %s not found.)r3 r r% r �set_aggregate_metadata)r r< r� r2 r r r r: t s �z(ComputeCloudMixin.set_aggregate_metadatac C s* | � |�}|s t�d| ��| j�||�S )z�Add a host to an aggregate. :param name_or_id: Name or ID of the host aggregate. :param host_name: Host to add. :raises: OpenStackCloudException on operation error. r9 )r3 r r% r �add_host_to_aggregate�r r< Z host_namer2 r r r r; � s �z'ComputeCloudMixin.add_host_to_aggregatec C s* | � |�}|s t�d| ��| j�||�S )z�Remove a host from an aggregate. :param name_or_id: Name or ID of the host aggregate. :param host_name: Host to remove. :raises: OpenStackCloudException on operation error. r9 )r3 r r% r �remove_host_from_aggregater< r r r r= � s �z,ComputeCloudMixin.remove_host_from_aggregatec K sL | � |�}|st�d��d|d< tj| jjdj|jd�d|id�dd � d S ) z� Set a quota in a project :param name_or_id: project name or id :param kwargs: key/value pairs of quota name and quota value :raises: OpenStackCloudException if the resource to set the quota does not exist. r~ T�force�/os-quota-sets/{project}�r � quota_setr zNo valid quota or resourcer) N) r� r r% r r. r r r& r] )r r< r� r� r r r �set_compute_quotas� s ��z$ComputeCloudMixin.set_compute_quotasc C s@ | � |�}|st�d��t�| j�dj|jd���}| � d|�S )z� Get quota for a project :param name_or_id: project name or id :raises: OpenStackCloudException if it's not a valid project :returns: Munch object with the quotas r~ r? r@ rA ) r� r r% r r. r r/ r& r] r0 )r r< r� r2 r r r �get_compute_quotas� s ��z$ComputeCloudMixin.get_compute_quotasc C s4 | � |�}|st�d��t�| j�dj|jd���S )z� Delete quota for a project :param name_or_id: project name or id :raises: OpenStackCloudException if it's not a valid project or the nova client call failed :returns: dict with the quotas r~ r? r@ ) r� r r% r r. r r r& r] )r r< r� r r r �delete_compute_quotas� s ��z'ComputeCloudMixin.delete_compute_quotasc C s� dd� }dd� }|s |d�}nt |tj�s2||�}|sBtj�� }nt |tj�sV||�}||�}||�}| �|�}|s�t�dj|jd���tj | j j dj|jd �t |� � |� � d �d �d j|jd�d �}| �| �d|��S )a Get usage for a specific project :param name_or_id: project name or id :param start: :class:`datetime.datetime` or string. Start date in UTC Defaults to 2010-07-06T12:00:00Z (the date the OpenStack project was started) :param end: :class:`datetime.datetime` or string. End date in UTC. Defaults to now :raises: OpenStackCloudException if it's not a valid project :returns: Munch object with the usage c S s: z t �| �W S t j jy4 t�dj| d���Y n0 d S )NzeDate given, {date}, is invalid. Please pass in a date string in ISO 8601 format - YYYY-MM-DDTHH:MM:SS��date)�iso8601� parse_dateZ ParseErrorr r% r& rE r r r rH � s ��z7ComputeCloudMixin.get_compute_usage.<locals>.parse_datec S s( | � � }|r | tj|d� } | jd d�S )N)�hours)�tzinfo)� utcoffset�datetime� timedelta�replace)rF �offsetr r r �parse_datetime_for_nova� s zDComputeCloudMixin.get_compute_usage.<locals>.parse_datetime_for_novaz 2010-07-06z project does not exist: {name}r� z!/os-simple-tenant-usage/{project}r@ )�start�endrY z'Unable to get usage for project: {name}r) Z tenant_usage)r9 rL �utcnowr� r r% r& r] r r. r r/ r: � isoformatZ_normalize_compute_usager0 )r r< rQ rR rH rP r� r2 r r r �get_compute_usage� s: � ��� �z#ComputeCloudMixin.get_compute_usagec C sR t |d�r|�� }t|t�sBt|t�s6tdt|� ��|�dd�}t� |�� d�S )N�readz%s can't be encodedzutf-8�strict) �hasattrrV r9 r6 rc r� �type�encode�base64� b64encode�decode)r r� r r r r� " s z)ComputeCloudMixin._encode_server_userdatac C s t �| |�S r5 )r r� ri r r r �get_openstack_vars0 s z$ComputeCloudMixin.get_openstack_varsc C s t �| |�S r5 )r Zexpand_server_varsri r r r �_expand_server_vars3 s z%ComputeCloudMixin._expand_server_vars)NT)NN)NNT)NNFFF)NN)N)F)F)FFFN)FFFN)N)N)NT)F)N)N)NNFFF)NN)N)Fr� )NNTNNNFFr� TNFr� NNNN)TNNTr� N)TNNTFr� N)NFFFr� )Fr� Fr� )Fr� Fr� )FF)r r r r T)NN)N)N)NN)R�__name__� __module__� __qualname__r �propertyr r r( r Zcache_on_argumentsr4 r6 r> r? rF rI r8 rV r! rk ro rp rr rD rt rG r� r� r r� r� r� rg r| r� r� r� r� r� r� r� r� r� Z valid_kwargsr� r� r� r� r r r r r r r r r r r! r" r# r& r) r+ r, r. r1 r/ r3 r4 r5 r8 r: r; r= rB rC rD rU r� r^ r_ r r r r r " s� � # # � 3 � ! � ' � � � Y � . � + � + � � 3� � ( Ar )r[ rL r� rG r# r ru �typesZopenstack.cloudr r r r Z openstackr r r Z Normalizerr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка