File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/scaleway.cpython-310.pyc
Back
o ;jbY � @ s d Z ddlZddlmZ ddlmZmZ ddlmZ ddl m Z m Z m Z m Z mZmZmZmZ ddlmZmZ ddlmZ dd lmZ zddlZW n eyU ddlZY nw g d �Z d d d d d�Z dddd�dddd�gZ G dd� de�Z G dd� de�Z dd� Z!d d � Z"G d d � d e�Z#dS ) z Scaleway Driver � N)�httplib)� JsonResponse�ConnectionUserAndKey)� ProviderError)�Node�KeyPair�NodeSize� NodeImage� NodeDriver� NodeLocation� StorageVolume�VolumeSnapshot)� NodeState�VolumeSnapshotState)� parse_date)�Provider)�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 � �� d S )N�message)�super� parse_error��self�� __class__� �U/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/scaleway.pyr D s z ScalewayResponse.parse_errorc C s | j | jv S �N)�status�valid_response_codesr r# r# r$ �successG s zScalewayResponse.success) �__name__� __module__� __qualname__r �OK�ACCEPTED�CREATED� NO_CONTENTr' r r( � __classcell__r# r# r! r$ r < s � r c s` e Zd ZdZed ZdZeZ d � fdd� Z d dd �Z d d � Z � Z S ) r z3 Connection class for the Scaleway driver. r FN�GETc sN |r| j } tt|t�r|jn| | _ | j | ks| �� t� �|||||||�S r% )�host�SCALEWAY_API_HOSTS� isinstancer r �connectr �request) r �action�params�data�headers�method�raw�stream�regionZold_hostr! r# r$ r6 T s � zScalewayConnection.requestc s� |d u ri }t |t�rd|d< n t |t�r|�d� | �||||||||�j} | j�� j} | r^d| v r^| j| d d |||||d�j� | j�� j} � fdd�t| � � �D �} | } | r^d| v s3| 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>� 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_pagedi s0 �� � 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_headers� s z&ScalewayConnection.add_default_headers)NNNr1 FFN) r) r* r+ �__doc__r3 r2 Zallow_insecurer Z responseClsr6 rQ rT r0 r# r# r! r$ r K s, � �%r c C s t | d d d �S �Ni� ��int��sizer# r# r$ � _to_lib_size� � r[ c C s t | d d d �S rV rW rY r# r# r$ � _to_api_size� r\ 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� Zd<dd�Zdd� Zd=dd�Zd<d d �Zd d � Z d d!� Z d<d"d#�Z d$d%� Z d<d&d'�Z d(d)� Z!d<d*d+�Z"d<d,d-�Z#d<d.d/�Z$d<d0d1�Z%d2d3� Z&d4d5� Z'd6d7� Z(d8d9� Z)d:d;� Z*dS )>r 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 snapshottingZ 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 dd � it�|����qS )�driverr# )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 3 s& � | ]}�� |�| � | �V qd S r% )�_to_size)rC r �� availabilityr Zsizesr# r$ � <genexpr>� s �$ z0ScalewayNodeDriver.list_sizes.<locals>.<genexpr>c S s | j S r% �r )�xr# r# r$ �<lambda>� s 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 rt |d d p d�nd}|d r t |d d p d�n|}|d |d |d |d |d |t|d d p8dd �|d d |d d� }t||t|d pOdd �|t|d d p[dd �|d | |d�S )NZvolumes_constraintZmin_sizer � Zmax_sizeZncpusZ monthly_price�arch� baremetalrj �networkZsum_internal_bandwidthi Z ipv6_support� alt_names) ZcoresZmonthlyrs rt rj �max_diskZinternal_bandwidthZipv6rv �ramZsum_internet_bandwidthZ hourly_price)r r rx �diskZ bandwidthZpricer_ �extra)r[ rX r )r r rZ rj Zmin_diskrw rz r# r# r$ rh � s< ����� ��zScalewayNodeDriver._to_sizec �* � 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 � g | ]}� � |��qS r# )� _to_image)rC �imager r# r$ rc � z2ScalewayNodeDriver.list_images.<locals>.<listcomp>�rL rQ )r r> rp r} r# r r$ � list_images� � 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` rs �volumes�0r )� organizationr rs � root_volumer| �POST�r9 r> r; r� )rS rz rL r6 �json�dumpsrK r )r �noder r> r9 rp r� r# r# r$ � create_image s �� z ScalewayNodeDriver.create_imagec C � | 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% � ��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> rp r� r# r# r$ � get_image7 s z ScalewayNodeDriver.get_imagec C sX |d t |�di ��dd��pdt|d �t|d �|d d �}t|d |d | |d �S ) Nrs r� rZ r �2 � creation_date�modification_dater� )rs rZ r� r� r� r r )r r r_ rz )r[ �getr r )r r� rz r# r# r$ r I s �z ScalewayNodeDriver._to_imagec r{ )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 r~ r# )�_to_node)rC �serverr r# r$ rc ` r� z1ScalewayNodeDriver.list_nodes.<locals>.<listcomp>r� )r r> rp rg r# r r$ � list_nodesS r� z ScalewayNodeDriver.list_nodesc C s� |d }|d }|d p i }t |d |d t�|d �|r"|d gng |r(|gng | |d |d |d |d |�d d �d�t|d �d�S )N� public_ip� private_iprb r r �state�addressr� �tagsrs r� Zzone_idr )r� r� rs r� r> r� )r r r� Z public_ipsZ private_ipsr_ rz Z created_at)r r Z fromstringr� r )r r� r� r� rb r# r# r$ r� b s$ � �zScalewayNodeDriver._to_nodec C s� || j |j|pi |j|p g d�}|j�dd�}|d D ] } |t| d �7 }q||jk r_|j| dkr5d} n|j| } t|d �d } d|| f | j t| �dd �|d t| �< || 7 }||jk s+||j�d |j�kr�|j�d |j�|jkryd |j n d |j�d |j�|jf } t d |j| |f d| d��| j j dt � |�|dd�} | jd }| �|�}t|t�r�|jn|p�d|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_typerw 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 rz r� r[ ry �lenr] �strr rL r6 r� r� rK r� r4 r �_action)r r rZ r� Z ex_volumesZex_tagsr> r9 Zallocate_space�volumeZbumpZvol_num�rangerp r� r� r# r# r$ � create_nodew sT � � � �� �� � 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 � | � |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� � z ScalewayNodeDriver.reboot_nodec C r� )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� r� z ScalewayNodeDriver.destroy_nodec r{ )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 r~ r# )� _to_volume)rC r� r r# r$ rc � r� z3ScalewayNodeDriver.list_volumes.<locals>.<listcomp>r� )r r> rp r� r# r r$ � list_volumes� r� 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_ rz )r r r[ )r r� rz 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 s z:ScalewayNodeDriver.list_volume_snapshots.<locals>.<lambda>� snapshotsc r~ r# )� _to_snapshot)rC �snapshotr r# r$ rc r� z<ScalewayNodeDriver.list_volume_snapshots.<locals>.<listcomp>)rL rQ �filter)r r� r> rp 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� rz )�SNAPSHOT_STATE_MAPr� r �UNKNOWNr r[ r )r r� r� rz 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 rp 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 rp r� r# r# r$ �create_volume_snapshot@ s � z)ScalewayNodeDriver.create_volume_snapshotc C r� )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_volumeX r� z!ScalewayNodeDriver.destroy_volumec C r� )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_snapshotj r� 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 | ]$}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 � s ���z5ScalewayNodeDriver.list_key_pairs.<locals>.<listcomp>)rL r6 � _get_user_idrK )r rp �keysr# r r$ �list_key_pairs| 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 � s 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_string� 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 ZsecretrK )r rp 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|j�i�qS )rS z{} {})�formatr� 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 rp r# r# r$ r� � s � �z ScalewayNodeDriver._save_keysr% )NNN)+r) r* r+ rU r ZSCALEWAY�typer Z connectionClsr Zwebsiter ZCREATINGZ AVAILABLE�ERRORr� re rq 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 � sJ � % Q r )$rU r` Zlibcloud.utils.py3r Zlibcloud.common.baser r Zlibcloud.common.typesr Zlibcloud.compute.baser r r r r r r r Zlibcloud.compute.typesr r Zlibcloud.utils.iso8601r Zlibcloud.compute.providersr Z simplejsonr� � ImportError�__all__r3 rd r r r[ r] r r# r# r# r$ �<module> s8 ( �� �L
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings