Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/scaleway.cpython-39.pyc
Ðазад
a q�h�^ � @ s. d Z ddlZz ddlZW n ey2 ddlZY n0 ddlmZmZ ddlm Z ddl m Z m Z m Z mZ ddl mZ ddl mZmZmZ ddlmZ dd lmZmZ dd lmZ dd lmZ g d �Z d dd dd�Z dddd�dddd�gZ G dd� de�Z G dd� de�Z d d � Z!d d � Z"G d d!� d!e �Z#dS )"z Scaleway Driver � N)�ConnectionUserAndKey� JsonResponse)� ProviderError)� NodeDriver� NodeImage�Node�NodeSize)� NodeLocation)� StorageVolume�VolumeSnapshot�KeyPair)�Provider)� NodeState�VolumeSnapshotState)� parse_date)�httplib)�ScalewayResponse�ScalewayConnection�ScalewayNodeDriverzcp-par1.scaleway.comzaccount.scaleway.comzcp-ams1.scaleway.com)�default�account�par1�ams1r zParis 1ZFR)�id�nameZcountryr z Amsterdam 1�NLc s8 e Zd ZejejejejgZ� fdd�Z dd� Z � Z S )r c s t t| ��� d S )N�message)�superr � parse_error��self�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/scaleway.pyr ; s z ScalewayResponse.parse_errorc C s | j | jv S �N)�status�valid_response_codesr r# r# r$ �success> s zScalewayResponse.success) �__name__� __module__� __qualname__r �OK�ACCEPTED�CREATED� NO_CONTENTr' r r( � __classcell__r# r# r! r$ r 7 s � r c sD e Zd ZdZed ZdZeZd � fdd� Z d dd �Z d d � Z � Z S )r z3 Connection class for the Scaleway driver. r FN�GETc sR |r6| j } tt|t�r |jn| | _ | j | ks6| �� tt| ��|||||||�S r% ) �host�SCALEWAY_API_HOSTS� isinstancer r �connectr r �request) r �action�params�data�headers�method�raw�stream�regionZold_hostr! r# r$ r6 K s �� �zScalewayConnection.requestc s� |d u r i }t |t�r d|d< nt |t�r4|�d� | �||||||||�j} | j�� j} | r�d| v r�| j| d d |||||d�j� | j�� j} � fdd�t| � � �D �} | } qZ| S ) N�d �per_page)r@ r? �next�url)r9 r: r; r< r= c s i | ]\}}||� | �qS r# r# )�.0�root�child�rA r# r$ � <dictcomp>l s �z5ScalewayConnection._request_paged.<locals>.<dictcomp>) r4 �dict�list�appendr6 �object� connection� getresponse�links�items) r r7 r8 r9 r: r; r< r= r> �resultsrN Zmergedr# rF r$ �_request_pagedY s* � � �z!ScalewayConnection._request_pagedc C s | j |d< d|d< |S )zB Add headers that are necessary for every request z X-Auth-Tokenzapplication/jsonz Content-Type��key)r r: r# r# r$ �add_default_headersr s z&ScalewayConnection.add_default_headers)NNNr1 FFN)NNNr1 FFN) r) r* r+ �__doc__r3 r2 Zallow_insecurer Z responseClsr6 rQ rT r0 r# r# r! r$ r B s � � r c C s t | d d d �S �Ni� ��int��sizer# r# r$ � _to_lib_size{ s r[ c C s t | d d d �S rV rW rY r# r# r$ � _to_api_size s r\ c @ s( e Zd ZdZejZeZdZ dZ e j e j e jd�Zdd� Zd<dd �Zd d � Zd=d d �Zd>dd�Zd?dd�Zd@dd�Zdd� ZdAdd�Zdd� ZdBdd�ZdCd d �Zd d � Z d d!� Z dDd"d#�Z d$d%� Z dEd&d'�Z d(d)� Z!dFd*d+�Z"dGd,d-�Z#dHd.d/�Z$dId0d1�Z%d2d3� Z&d4d5� Z'd6d7� Z(d8d9� Z)d:d;� Z*dS )Jr z� Scaleway Node Driver Class This is the primary driver for interacting with Scaleway. It contains all of the standard libcloud methods that Scaleway's API supports. ZScalewayzhttps://www.scaleway.com/)Z snapshotting� available�errorc s � fdd�t D �S )z� List data centers available. :return: list of node location objects :rtype: ``list`` of :class:`.NodeLocation` c s$ g | ] }t f d � it�|����qS )�driver)r �copy�deepcopy)rC �locationr r# r$ � <listcomp>� s �z5ScalewayNodeDriver.list_locations.<locals>.<listcomp>)�SCALEWAY_LOCATION_DATAr r# r r$ �list_locations� s �z!ScalewayNodeDriver.list_locationsNc sR �j jd|d�}|d ��j jd|d�}|d � t� ��fdd��D �dd� d �S ) a( List available VM sizes. :param region: The region in which to list sizes (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: list of node size objects :rtype: ``list`` of :class:`.NodeSize` z/products/servers�r> �serversz /products/servers/availabilityc s" g | ]}�� |�| � | ��qS r# )�_to_size)rC r �� availabilityr �sizesr# r$ rc � s �z1ScalewayNodeDriver.list_sizes.<locals>.<listcomp>c S s | j S r% �r )�xr# r# r$ �<lambda>� � z/ScalewayNodeDriver.list_sizes.<locals>.<lambda>rR )rL rQ �sorted)r r> �responser# ri r$ � list_sizes� s ����z ScalewayNodeDriver.list_sizesc C s� |d r t |d d pd�nd}|d r<t |d d p8d�n|}|d |d |d |d |d |t|d d ppdd �|d d |d d� }t||t|d p�dd �|t|d d p�dd �|d | |d�S )NZvolumes_constraintZmin_sizer � �max_sizeZncpusZ monthly_price�arch� baremetalrj �networkZsum_internal_bandwidthi Z ipv6_support� alt_names) ZcoresZmonthlyru rv rj �max_diskZinternal_bandwidthZipv6rx �ramZsum_internet_bandwidthZ hourly_price)r r rz �disk� bandwidthZpricer_ �extra)r[ rX r )r r rZ rj Zmin_diskry r} r# r# r$ rh � sF ������ ����zScalewayNodeDriver._to_sizec s* � j jd|d�}|d }� fdd�|D �S )a' List available VM images. :param region: The region in which to list images (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: list of image objects :rtype: ``list`` of :class:`.NodeImage` �/imagesrf �imagesc s g | ]}� � |��qS r# )� _to_image)rC �imager r# r$ rc � ro z2ScalewayNodeDriver.list_images.<locals>.<listcomp>�rL rQ )r r> rq r r# r r$ � list_images� s z ScalewayNodeDriver.list_imagesc C sR | j ||jd |jd d d d�}| jjdt�|�|dd�}|jd }| �|�S ) a� Create a VM image from an existing node's root volume. :param node: The node from which to create the image :type node: :class:`.Node` :param name: The name to give the image :type name: ``str`` :param region: The region in which to create the image (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: the newly created image object :rtype: :class:`.NodeImage` ru �volumes�0r )� organizationr ru � root_volumer~ �POST�r9 r> r; r� )rS r} rL r6 �json�dumpsrK r� )r �noder r> r9 rq r� r# r# r$ � create_image� s �� z ScalewayNodeDriver.create_imagec C s | j jd|j |dd��� S )a� Delete a VM image. :param node_image: The image to delete :type node_image: :class:`.NodeImage` :param region: The region in which to find/delete the image (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: True if the image was deleted, otherwise False :rtype: ``bool`` � /images/%s�DELETE�r> r; �rL r6 r r( )r Z node_imager> r# r# r$ � delete_image s �z ScalewayNodeDriver.delete_imagec C s( | j jd| |d�}|jd }| �|�S )a� Retrieve a specific VM image. :param image_id: The id of the image to retrieve :type image_id: ``int`` :param region: The region in which to create the image (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: the requested image object :rtype: :class:`.NodeImage` r� rf r� )rL r6 rK r� )r Zimage_idr> rq r� r# r# r$ � get_image s � z ScalewayNodeDriver.get_imagec C sX |d t |�di ��dd��p dt|d �t|d �|d d �}t|d |d | |d �S ) Nru r� rZ r �2 � creation_date�modification_dater� )ru rZ r� r� r� r r )r r r_ r} )r[ �getr r )r r� r} r# r# r$ r� & s � ��z ScalewayNodeDriver._to_imagec s* � j jd|d�}|d }� fdd�|D �S )a List all nodes. :param region: The region in which to look for nodes (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: list of node objects :rtype: ``list`` of :class:`.Node` �/serversrf rg c s g | ]}� � |��qS r# )�_to_node)rC �serverr r# r$ rc A ro z1ScalewayNodeDriver.list_nodes.<locals>.<listcomp>r� )r r> rq rg r# r r$ � list_nodes4 s z ScalewayNodeDriver.list_nodesc C s� |d }|d }|d pi }t |d |d t�|d �|rD|d gng |rP|gng | |d |d |d |d |�d d �d�t|d �d�S )N� public_ip� private_iprb r r �state�addressr� �tagsru r� �zone_idr )r� r� ru r� r> r� )r r r� Z public_ipsZ private_ipsr_ r} Z created_at)r r Z fromstringr� r )r r� r� r� rb r# r# r$ r� C s" � �zScalewayNodeDriver._to_nodec C s� || j |j|pi |j|pg d�}|j�dd�}|d D ]} |t| d �7 }q6||jk r�|j| dkrjd} n |j| } t|d �d } d|| f | j t| �dd �|d t| �< || 7 }qL||j�d |j�k�r |j�d |j�|jkr�d |j nd |j�d |j�|jf } t d |j| |f d| d��| j j dt � |�|dd�} | jd }| �|�}t|t��r`|jn|�phd|jd< | �|jd� |S )a Create a new node. :param name: The name to give the node :type name: ``str`` :param size: The size of node to create :type size: :class:`.NodeSize` :param image: The image to create the node with :type image: :class:`.NodeImage` :param ex_volumes: Additional volumes to create the node with :type ex_volumes: ``dict`` of :class:`.StorageVolume`s :param ex_tags: Tags to assign to the node :type ex_tags: ``list`` of ``str`` :param region: The region in which to create the node (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: the newly created node object :rtype: :class:`.Node` )r r� r� r� Zcommercial_typer� rZ r� r� � � z%s-%d�l_ssd)r r� rZ � volume_typery zof %dGBzbetween %dGB and %dGBz3%s only supports a total volume size %s; tried %dGBi� )�valueZ http_coder_ r� r� r� r� r r> Zpoweron)rS r r} r� r[ r{ �lenr\ �strr rL r6 r� r� rK r� r4 r �_action)r r rZ r� Z ex_volumesZex_tagsr> r9 Zallocate_space�volumeZbumpZvol_num�rangerq r� r� r# r# r$ � create_nodeT s\ � � � �� ��� ��z ScalewayNodeDriver.create_nodec C s& | j jd| |t�d|i�dd��� S )Nz/servers/%s/actionr7 r� �r> r9 r; )rL r6 r� r� r( )r Z server_idr7 r> r# r# r$ r� � s �zScalewayNodeDriver._actionc C s | � |jd�S )z� Reboot a node. :param node: The node to be rebooted :type node: :class:`Node` :return: True if the reboot was successful, otherwise False :rtype: ``bool`` Zreboot�r� r �r r� r# r# r$ � reboot_node� s z ScalewayNodeDriver.reboot_nodec C s | � |jd�S )z� Destroy a node. :param node: The node to be destroyed :type node: :class:`Node` :return: True if the destroy was successful, otherwise False :rtype: ``bool`` � terminater� r� r# r# r$ � destroy_node� s z ScalewayNodeDriver.destroy_nodec s* � j jd|d�}|d }� fdd�|D �S )a3 Return a list of volumes. :param region: The region in which to look for volumes (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: A list of volume objects. :rtype: ``list`` of :class:`StorageVolume` �/volumesrf r� c s g | ]}� � |��qS r# )� _to_volume)rC r� r r# r$ rc � ro z3ScalewayNodeDriver.list_volumes.<locals>.<listcomp>r� )r r> rq r� r# r r$ � list_volumes� s z ScalewayNodeDriver.list_volumesc C sH |d |d t |d �t |d �d�}t|d |d t|d �| |d �S ) Nr� r� r� r� )r� r� r� r� r r rZ )r r rZ r_ r} )r r r[ )r r� r} r# r# r$ r� � s � �z ScalewayNodeDriver._to_volumec s8 � j jd|d�}t�fdd�|d �}� fdd�|D �S )a List snapshots for a storage volume. @inherits :class:`NodeDriver.list_volume_snapshots` :param region: The region in which to look for snapshots (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` � /snapshotsrf c s | d d � j kS )NZ base_volumer )r )�s)r� r# r$ rn � ro z:ScalewayNodeDriver.list_volume_snapshots.<locals>.<lambda>� snapshotsc s g | ]}� � |��qS r# )� _to_snapshot)rC �snapshotr r# r$ rc � ro z<ScalewayNodeDriver.list_volume_snapshots.<locals>.<listcomp>)rL rQ �filter)r r� r> rq r� r# )r r� r$ �list_volume_snapshots� s �z(ScalewayNodeDriver.list_volume_snapshotsc C sN | j �|d tj�}|d |d d�}t|d | t|d �t|d �||d�S ) Nr� r� r� )r� r� r rZ r� )r r_ rZ �createdr� r} )�SNAPSHOT_STATE_MAPr� r �UNKNOWNr r[ r )r r� r� r} r# r# r$ r� � s �� �z ScalewayNodeDriver._to_snapshotc C sB || j dt|�d�}| jjd|t�|�dd�}|jd }| �|�S )a� Create a new volume. :param size: Size of volume in gigabytes. :type size: ``int`` :param name: Name of the volume to be created. :type name: ``str`` :param region: The region in which to create the volume (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: The newly created volume. :rtype: :class:`StorageVolume` r� )r r� r� rZ r� r� r� r� )rS r\ rL r6 r� r� rK r� )r rZ r r> r9 rq r� r# r# r$ � create_volume� s �� z ScalewayNodeDriver.create_volumec C s> || j |jd�}| jjd|t�|�dd�}|jd }| �|�S )a� Create snapshot from volume. :param volume: The volume to create a snapshot from :type volume: :class`StorageVolume` :param name: The name to give the snapshot :type name: ``str`` :param region: The region in which to create the snapshot (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: The newly created snapshot. :rtype: :class:`VolumeSnapshot` )r r� Z volume_idr� r� r� r� )rS r rL r6 r� r� rK r� )r r� r r> r9 rq r� r# r# r$ �create_volume_snapshot s �� z)ScalewayNodeDriver.create_volume_snapshotc C s | j jd|j |dd��� S )a� Destroys a storage volume. :param volume: Volume to be destroyed :type volume: :class:`StorageVolume` :param region: The region in which to look for the volume (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: True if the destroy was successful, otherwise False :rtype: ``bool`` z /volumes/%sr� r� r� )r r� r> r# r# r$ �destroy_volume3 s �z!ScalewayNodeDriver.destroy_volumec C s | j jd|j |dd��� S )a� Dostroy a volume snapshot :param snapshot: volume snapshot to destroy :type snapshot: class:`VolumeSnapshot` :param region: The region in which to look for the snapshot (if None, use default region specified in __init__) :type region: :class:`.NodeLocation` :return: True if the destroy was successful, otherwise False :rtype: ``bool`` z /snapshots/%sr� r� r� )r r� r> r# r# r$ �destroy_volume_snapshotE s �z*ScalewayNodeDriver.destroy_volume_snapshotc s8 � j jd� �� dd�}|jd d }� fdd�|D �S )z� List all the available SSH keys. :return: Available SSH keys. :rtype: ``list`` of :class:`KeyPair` � /users/%sr rf �user�ssh_public_keysc sP g | ]H}t d �|d �d �dd� �d �|d �d �dd� �|d � d��qS )� rS � N� fingerprint�r � public_keyr� r_ )r �join�split�rC rS r r# r$ rc a s � �z5ScalewayNodeDriver.list_key_pairs.<locals>.<listcomp>)rL r6 � _get_user_idrK )r rq �keysr# r r$ �list_key_pairsW s � �z!ScalewayNodeDriver.list_key_pairsc sN t � d�|�d�dd� �d| d�}� fdd�| �� D �}|�|� | �|�S )a Import a new public key from string. :param name: Key pair name. :type name: ``str`` :param key_material: Public key material. :type key_material: ``str`` :return: Imported key pair object. :rtype: :class:`KeyPair` r� Nr� r� c s g | ]}|j � ks|�qS r# rl r� rl r# r$ rc w ro zBScalewayNodeDriver.import_key_pair_from_string.<locals>.<listcomp>)r r� r� r� rJ � _save_keys)r r Z key_materialZnew_keyr� r# rl r$ �import_key_pair_from_stringf s � z.ScalewayNodeDriver.import_key_pair_from_stringc s � fdd�| � � D �}| �|�S )z� Delete an existing key pair. :param key_pair: Key pair object. :type key_pair: :class:`KeyPair` :return: True of False based on success of Keypair deletion :rtype: ``bool`` c s g | ]}|j � j ks|�qS r# rl r� ��key_pairr# r$ rc � s �z6ScalewayNodeDriver.delete_key_pair.<locals>.<listcomp>)r� r� )r r� r� r# r� r$ �delete_key_pair{ s z"ScalewayNodeDriver.delete_key_pairc C s$ | j jd| j dd�}|jd d S )Nz /tokens/%sr rf �tokenZuser_id)rL r6 �secretrK )r rq r# r# r$ r� � s �z ScalewayNodeDriver._get_user_idc C s< ddd� |D �i}| j jd| �� ddt�|�d�}|�� S )Nr� c S s g | ]}d d|j |jf i�qS )rS z%s %s)r� r r� r# r# r$ rc � s �z1ScalewayNodeDriver._save_keys.<locals>.<listcomp>r� r �PATCH)r> r; r9 )rL r6 r� r� r� r( )r r� r9 rq r# r# r$ r� � s ���z ScalewayNodeDriver._save_keys)N)N)N)N)N)N)NNN)N)N)N)N)N)N)N)+r) r* r+ rU r ZSCALEWAY�typer Z connectionClsr Zwebsiter ZCREATINGZ AVAILABLE�ERRORr� re rr rh 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 � sL � � M r )$rU r` Z simplejsonr� � ImportErrorZlibcloud.common.baser r Zlibcloud.common.typesr Zlibcloud.compute.baser r r r r r r r Zlibcloud.compute.providersr Zlibcloud.compute.typesr r Zlibcloud.utils.iso8601r Zlibcloud.utils.py3r �__all__r3 rd r r r[ r\ r r# r# r# r$ �<module> s8 � � 9
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка