File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/digitalocean.cpython-310.pyc
Back
o ;j�h � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZm Z m Z m Z m Z m Z mZmZ ddlmZmZ ddlmZ ddlmZmZ d d gZG d d � d e �ZG d d � d �ZG dd � d ee�ZG dd� d�Z dS )z DigitalOcean Driver � N)�httplib)�InvalidCredsError)�Node�KeyPair�NodeSize� NodeImage� NodeDriver� NodeLocation� StorageVolume�VolumeSnapshot)�Provider� NodeState)� parse_date)�DigitalOcean_v1_Error�DigitalOcean_v2_BaseDriver�DigitalOceanNodeDriver�DigitalOcean_v2_NodeDriverc s0 e Zd ZdZejZdZdZd� fdd� Z � Z S ) r a� DigitalOcean NodeDriver defaulting to using APIv2. :keyword key: Personal Access Token required for authentication. :type key: ``str`` :keyword secret: Previously used with API version ``v1``. (deprecated) :type secret: ``str`` :keyword api_version: Specifies the API version to use. Defaults to using ``v2``, currently the only valid option. (optional) :type api_version: ``str`` Z DigitalOceanz https://www.digitalocean.comN�v2c sd | t u r(|dks |d ur|d ur|dkrtd��t� �|dkr"t} ntd| ��t� j| fi |��S )NZv1r z)secret not accepted for v2 authenticationzUnsupported API version: %s)r r r r �NotImplementedError�super�__new__)�cls�keyZsecret� api_version�kwargs�� __class__� �Y/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/digitalocean.pyr = s z DigitalOceanNodeDriver.__new__)Nr ) �__name__� __module__� __qualname__�__doc__r Z DIGITAL_OCEAN�type�nameZwebsiter � __classcell__r r r r r ) s c @ s e Zd Zdd� Zdd� ZdS )�SSHKeyc C s || _ || _|| _d S �N��idr$ �pub_key)�selfr) r$ r* r r r �__init__L s zSSHKey.__init__c C � d| j | j| jf S )Nz$<SSHKey: id=%s, name=%s, pub_key=%s>r( �r+ r r r �__repr__Q � �zSSHKey.__repr__N)r r r! r, r/ r r r r r& K s r& c @ s� e Zd ZdZejejejejd�Z g d�Z dd� Z dd� Z dcd d �Z d d � Zdddd�Zdd� Z dedd�Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d*d+� Z d,d-� Z dfd/d0�Z d1d2� Z d3d4� Z!dgd5d6�Z"d7d8� Z#ddd9d:�Z$d;d<� Z%d=d>� Z&d?d@� Z'dAdB� Z(dCdD� Z)dEdF� Z*dGdH� Z+dIdJ� Z,dKdL� Z-dMdN� Z.dOdP� Z/dQdR� Z0dSdT� Z1dUdV� Z2dWdX� Z3dYdZ� Z4d[d\� Z5d]d^� Z6d_d`� Z7dadb� Z8d S )hr z6 DigitalOcean NodeDriver using v2 of the API. )�newZoffZactive�archive)ZbackupsZipv6Zprivate_networking�tags�ssh_keysc C � | � dd�}tt| j|��S )Nz /v2/imagesZimages)�_paginated_request�list�map� _to_image�r+ �datar r r � list_imagesg � z&DigitalOcean_v2_NodeDriver.list_imagesc C r5 )z� List all the available SSH keys. :return: Available SSH keys. :rtype: ``list`` of :class:`KeyPair` �/v2/account/keysr4 )r6 r7 r8 � _to_key_pairr: r r r �list_key_pairsk s z)DigitalOcean_v2_NodeDriver.list_key_pairsTc C sN g }| � dd�}|D ]}|r |�d�r|�| �|�� q |�| �|�� q |S )z� List locations :param ex_available: Only return locations which are available. :type ex_evailable: ``bool`` z /v2/regions�regionsZ available)r6 �get�append� _to_location)r+ Z ex_availableZ locationsr; �locationr r r �list_locationsu s �z)DigitalOcean_v2_NodeDriver.list_locationsc C r5 )N� /v2/dropletsZdroplets)r6 r7 r8 �_to_noder: r r r � list_nodes� r= z%DigitalOcean_v2_NodeDriver.list_nodesNc s6 | � dd�}tt| j|��}� r� fdd�|D �}|S )Nz /v2/sizes�sizesc s$ g | ]}� j |j�d g �v r|�qS )rA )r) �extrarB )�.0�size�rE r r � <listcomp>� s $ z9DigitalOcean_v2_NodeDriver.list_sizes.<locals>.<listcomp>)r6 r7 r8 �_to_size)r+ rE r; rJ r rN r � list_sizes� s z%DigitalOcean_v2_NodeDriver.list_sizesc C r5 )N� /v2/volumesZvolumes)r6 r7 r8 � _to_volumer: r r r � list_volumes� r= z'DigitalOcean_v2_NodeDriver.list_volumesc C s� ||j |j|j|d�}|rt�d� ||d< |pi }|�� D ] } | | jv r+|| || < q | jjdt� |�dd�} | j d } | j � dd �} | d kr\| j � d d �} | j � d | �}t d| ��| j | d�S )a� Create a node. The `ex_create_attr` parameter can include the following dictionary key and value pairs: * `backups`: ``bool`` defaults to False * `ipv6`: ``bool`` defaults to False * `private_networking`: ``bool`` defaults to False * `tags`: ``list`` of ``str`` tags * `user_data`: ``str`` for cloud-config data * `ssh_keys`: ``list`` of ``int`` key ids or ``str`` fingerprints `ex_create_attr['ssh_keys']` will override `ex_ssh_key_ids` assignment. :keyword ex_create_attr: A dictionary of optional attributes for droplet creation :type ex_create_attr: ``dict`` :keyword ex_ssh_key_ids: A list of ssh key ids which will be added to the server. (optional) :type ex_ssh_key_ids: ``list`` of ``int`` key ids or ``str`` key fingerprints :keyword ex_user_data: User data to be added to the node on create. (optional) :type ex_user_data: ``str`` :return: The newly created node. :rtype: :class:`Node` )r$ rM �image�regionZ user_datazZThe ex_ssh_key_ids parameter has been deprecated in favor of the ex_create_attr parameter.r4 rG �POST�r; �method�droplet�status�OK�ERROR�messageN� error_messagezFailed to create node: %s�r; )r$ r) �warnings�warn�keys�EX_CREATE_ATTRIBUTES� connection�request�json�dumps�objectrB � ValueErrorrH )r+ r$ rM rU rE Zex_create_attrZex_ssh_key_idsZ ex_user_data�attrr �resr; r[ r^ r_ r r r � create_node� s0 *�� � z&DigitalOcean_v2_NodeDriver.create_nodec C �" | j jd|j dd�}|jtjkS )Nz/v2/droplets/%s�DELETE�rY �re rf r) r[ r � NO_CONTENT)r+ �noderl r r r � destroy_node� s z'DigitalOcean_v2_NodeDriver.destroy_nodec C �2 ddi}| j jd|j t�|�dd�}|jtjkS )Nr# Zreboot�/v2/droplets/%s/actionsrW rX �re rf r) rg rh r[ r �CREATED�r+ rs rk rl r r r � reboot_node� � � z&DigitalOcean_v2_NodeDriver.reboot_nodec C �4 d|d�}| j jd|j t�|�dd�}|jtjkS )a Create an image from a Node. @inherits: :class:`NodeDriver.create_image` :param node: Node to use as base for image :type node: :class:`Node` :param node: Name for image :type node: ``str`` :rtype: ``bool`` �snapshot�r# r$ rv rW rX rw �r+ rs r$ rk rl r r r � create_image� s � z'DigitalOcean_v2_NodeDriver.create_imagec C rn )z�Delete an image for node. @inherits: :class:`NodeDriver.delete_image` :param image: the image to be deleted :type image: :class:`NodeImage` :rtype: ``bool`` � /v2/images/%sro rp rq )r+ rU rl r r r � delete_image� s z'DigitalOcean_v2_NodeDriver.delete_imagec C s | � d| d�}| �|�S )z� Get an image based on an image_id @inherits: :class:`NodeDriver.get_image` :param image_id: Image identifier :type image_id: ``int`` :return: A NodeImage object :rtype: :class:`NodeImage` r� rU )r6 r9 )r+ Zimage_idr; r r r � get_image s z$DigitalOcean_v2_NodeDriver.get_imagec C r| )NZ change_kernel)r# �kernelrv rW rX rw )r+ rs Z kernel_idrk rl r r r �ex_change_kernel � � z+DigitalOcean_v2_NodeDriver.ex_change_kernelc C ru )Nr# Z enable_ipv6rv rW rX rw ry r r r �ex_enable_ipv6 r{ z)DigitalOcean_v2_NodeDriver.ex_enable_ipv6c C r| )N�renamer~ rv rW rX rw r r r r �ex_rename_node' r� z)DigitalOcean_v2_NodeDriver.ex_rename_nodec C ru )Nr# �shutdownrv rW rX rw ry r r r �ex_shutdown_node. r{ z+DigitalOcean_v2_NodeDriver.ex_shutdown_nodec C ru )Nr# Z power_cyclerv rW rX rw ry r r r �ex_hard_reboot5 r{ z)DigitalOcean_v2_NodeDriver.ex_hard_rebootc C ru )Nr# Zpower_onrv rW rX rw ry r r r �ex_power_on_node< r{ z+DigitalOcean_v2_NodeDriver.ex_power_on_nodec C s> d|j d d d�}| jjd|j t�|�dd�}|jtjkS )z� Destroy and rebuild the node using its base image. :param node: Node to rebuild :type node: :class:`Node` :return True if the operation began successfully :rtype ``bool`` ZrebuildrU r) )r# rU rv rW rX ) rK re rf r) rg rh r[ r rx ry r r r �ex_rebuild_nodeC s � z*DigitalOcean_v2_NodeDriver.ex_rebuild_nodec C s6 d|j d�}| jjd|j t�|�dd�}|jtjkS )a� Resize the node to a different machine size. Note that some resize operations are reversible, and others are irreversible. :param node: Node to rebuild :type node: :class:`Node` :param size: New size for this machine :type node: :class:`NodeSize` :return True if the operation began successfully :rtype ``bool`` �resize)r# rM rv rW rX ) r$ re rf r) rg rh r[ r rx )r+ rs rM rk rl r r r �ex_resize_nodeS s � z)DigitalOcean_v2_NodeDriver.ex_resize_node� c C s8 ||d�}| j jddt�|�d�}|jd }| j|d�S )z� Create a new SSH key. :param name: Key name (required) :type name: ``str`` :param public_key: Valid public key string (required) :type public_key: ``str`` )r$ � public_keyr> rW )rY r; �ssh_keyr` )re rf rg rh ri r? )r+ r$ r� rk rl r; r r r �create_key_pairg s z*DigitalOcean_v2_NodeDriver.create_key_pairc C s* |j d }| jjd| dd�}|jtjkS )z� Delete an existing SSH key. :param key: SSH key (required) :type key: :class:`KeyPair` r) �/v2/account/keys/%sro rp )rK re rf r[ r rr )r+ r Zkey_idrl r r r �delete_key_pairx s z*DigitalOcean_v2_NodeDriver.delete_key_pairc sB � fdd�| � � D �d }| j�d|jd �jd }| j|d�S )z� Retrieve a single key pair. :param name: Name of the key pair to retrieve. :type name: ``str`` :rtype: :class:`.KeyPair` c � g | ] }|j � kr|�qS r �r$ )rL �kr� r r rO � � z;DigitalOcean_v2_NodeDriver.get_key_pair.<locals>.<listcomp>r r� r) r� r` )r@ re rf rK ri r? )r+ r$ Zqkeyr; r r� r � get_key_pair� s z'DigitalOcean_v2_NodeDriver.get_key_pairc C sz |||j d�}| jjdt�|�dd�}|jd }|j�dd�}|dkr7|j�d d �} |j�d | �} td | ��| j|d �S )a� Create a new volume. :param size: Size of volume in gigabytes (required) :type size: ``int`` :param name: Name of the volume to be created :type name: ``str`` :param location: Which data center to create a volume in. If empty, undefined behavior will be selected. (optional) :type location: :class:`.NodeLocation` :param snapshot: Snapshot from which to create the new volume. (optional) :type snapshot: :class:`.VolumeSnapshot` :return: The newly created volume. :rtype: :class:`StorageVolume` )r$ �size_gigabytesrV rR rW rX �volumer[ r\ r] r^ Nr_ zFailed to create volume: %sr` ) r) re rf rg rh ri rB rj rS ) r+ rM r$ rE r} rk rl r; r[ r^ r_ r r r � create_volume� s z(DigitalOcean_v2_NodeDriver.create_volumec C rn )z� Destroys a storage volume. :param volume: Volume to be destroyed :type volume: :class:`StorageVolume` :rtype: ``bool`` z/v2/volumes/%sro rp rq )r+ r� rl r r r �destroy_volume� � z)DigitalOcean_v2_NodeDriver.destroy_volumec C s< d|j |j|jd d�}| jjdt�|�dd�}|jtj kS )aR Attaches volume to node. :param node: Node to attach volume to. :type node: :class:`.Node` :param volume: Volume to attach. :type volume: :class:`.StorageVolume` :param device: Where the device is exposed, e.g. '/dev/sdb' :type device: ``str`` :rytpe: ``bool`` �attach� region_slug)r# � droplet_id� volume_namerV �/v2/volumes/actionsrW rX ) r) r$ rK re rf rg rh r[ r �ACCEPTED)r+ rs r� Zdevicerk rl r r r � attach_volume� s � z(DigitalOcean_v2_NodeDriver.attach_volumec C sd d|j |jd d�}g }|jd D ]}||d< | jjdt�|�dd�}|�|� qtd d � |D ��S ) z� Detaches a volume from a node. :param volume: Volume to be detached :type volume: :class:`.StorageVolume` :rtype: ``bool`` �detachr� )r# r� rV � droplet_idsr� r� rW rX c S s g | ]}|j tjk�qS r )r[ r r� )rL �rr r r rO � s z<DigitalOcean_v2_NodeDriver.detach_volume.<locals>.<listcomp>)r$ rK re rf rg rh rC �all)r+ r� rk � responsesr� rl r r r � detach_volume� s � � z(DigitalOcean_v2_NodeDriver.detach_volumec C s< d|i}| j jd|j t�|�dd�}|jd }| j|d�S )z� Create a new volume snapshot. :param volume: Volume to create a snapshot for :type volume: class:`StorageVolume` :return: The newly created volume snapshot. :rtype: :class:`VolumeSnapshot` r$ �/v2/volumes/%s/snapshotsrW rX r} r` )re rf r) rg rh ri �_to_volume_snapshot)r+ r� r$ rk rl r; r r r �create_volume_snapshot� s � z1DigitalOcean_v2_NodeDriver.create_volume_snapshotc C s" | � d|j d�}tt| j|��S )z� List snapshots for a volume. :param volume: Volume to list snapshots for :type volume: class:`StorageVolume` :return: List of volume snapshots. :rtype: ``list`` of :class: `StorageVolume` r� Z snapshots)r6 r) r7 r8 r� )r+ r� r; r r r �list_volume_snapshots s z0DigitalOcean_v2_NodeDriver.list_volume_snapshotsc C rn )z� Delete a volume snapshot :param snapshot: volume snapshot to delete :type snapshot: class:`VolumeSnapshot` :rtype: ``bool`` zv2/snapshots/%sro rp rq )r+ r} rl r r r �delete_volume_snapshot r� z1DigitalOcean_v2_NodeDriver.delete_volume_snapshotc C s | � d�|�d�}| �|�S )z� Lists details of the specified server. :param node_id: ID of the node which should be used :type node_id: ``str`` :rtype: :class:`Node` z/v2/droplets/{}rZ )r6 �formatrH )r+ �node_idr; r r r �ex_get_node_details s z.DigitalOcean_v2_NodeDriver.ex_get_node_detailsc C s2 d|j i}| jjdt�|�dd�}| �|jd �S )a� Create new floating IP reserved to a region. The newly created floating IP will not be associated to a Droplet. See https://developers.digitalocean.com/documentation/v2/#floating-ips :param location: Which data center to create the floating IP in. :type location: :class:`.NodeLocation` :rtype: :class:`DigitalOcean_v2_FloatingIpAddress` rV �/v2/floating_ipsrW rX Z floating_ip)r) re rf rg rh �_to_floating_ipri )r+ rE rk �respr r r �ex_create_floating_ip) s z0DigitalOcean_v2_NodeDriver.ex_create_floating_ipc C s$ | j jd�|j�dd�}|jtjkS )z� Delete specified floating IP :param ip: floating IP to remove :type ip: :class:`DigitalOcean_v2_FloatingIpAddress` :rtype: ``bool`` z/v2/floating_ips/{}ro rp )re rf r� r) r[ r rr )r+ �ipr� r r r �ex_delete_floating_ip: s z0DigitalOcean_v2_NodeDriver.ex_delete_floating_ipc C s | � | �dd��S )zk List floating IPs :rtype: ``list`` of :class:`DigitalOcean_v2_FloatingIpAddress` r� � floating_ips)�_to_floating_ipsr6 r. r r r �ex_list_floating_ipsF s z/DigitalOcean_v2_NodeDriver.ex_list_floating_ipsc s2 | � � }� fdd�|D �}|std� ��|d S )z� Get specified floating IP :param ip: floating IP to get :type ip: ``str`` :rtype: :class:`DigitalOcean_v2_FloatingIpAddress` c r� r )� ip_address)rL �x�r� r r rO X r� zADigitalOcean_v2_NodeDriver.ex_get_floating_ip.<locals>.<listcomp>zFloating ip %s not foundr )r� rj )r+ r� r� Z matching_ipsr r� r �ex_get_floating_ipN s z-DigitalOcean_v2_NodeDriver.ex_get_floating_ipc C s6 d|j d�}| jjd|j t�|�dd�}|jtjkS )a Attach the floating IP to the node :param node: node :type node: :class:`Node` :param ip: floating IP to attach :type ip: ``str`` or :class:`DigitalOcean_v2_FloatingIpAddress` :rtype: ``bool`` Zassign)r# r� �/v2/floating_ips/%s/actionsrW rX ) r) re rf r� rg rh r[ r rx �r+ rs r� r; r� r r r � ex_attach_floating_ip_to_node] s � z8DigitalOcean_v2_NodeDriver.ex_attach_floating_ip_to_nodec C s2 ddi}| j jd|j t�|�dd�}|jtjkS )a? Detach a floating IP from the given node Note: the 'node' object is not used in this method but it is added to the signature of ex_detach_floating_ip_from_node anyway so it conforms to the interface of the method of the same name for other drivers like for example OpenStack. :param node: Node from which the IP should be detached :type node: :class:`Node` :param ip: Floating IP to detach :type ip: :class:`DigitalOcean_v2_FloatingIpAddress` :rtype: ``bool`` r# Zunassignr� rW rX )re rf r� rg rh r[ r rx r� r r r � ex_detach_floating_ip_from_nodeq s � z:DigitalOcean_v2_NodeDriver.ex_detach_floating_ip_from_nodec C s" g d�}d|v r| j �|d tj�}ntj}t|d �}|d }g }g }|rC|d D ]}|d dkr7|d g}|d d krB|d g}q*i } |D ] } | |v rS|| | | < qG|�d i ��d �| d < |�d �} | rl| �| �} nd } | �d �} | r{| �| �} nd } t|d |d || | |||| | d� }|S )N)�memory�vcpus�diskrU rM Z size_slug�locked� created_at�networksr� Z backup_idsZ snapshot_ids�featuresr3 r[ r� r� Zv4r# Zprivater� �publicrV r$ rU rM r) ) r) r$ �staterU rM � public_ips� private_ipsr� �driverrK )�NODE_STATE_MAPrB r �UNKNOWNr r9 rP r )r+ r; Z extra_keysr� �createdr� r� r� �netrK r Z resolve_datarU rM rs r r r rH � sT � � � z#DigitalOcean_v2_NodeDriver._to_nodec C sB |d |d |d |d |d |d d�}t |d |d | |d �S ) N� distributionr� �slugrA � min_disk_sizer� )r� r� r� rA r� r� r) r$ )r) r$ r� rK )r �r+ r; rK r r r r9 � s �z$DigitalOcean_v2_NodeDriver._to_imagec C s@ |d |d |d |d d d�}t |d |d |d | |d �S ) Nr� r� rV r� )r� r� rV r� r) r$ r� �r) r$ rM r� rK )r r� r r r rS � s ��z%DigitalOcean_v2_NodeDriver._to_volumec C s& |� dg �}t|d |d d || d�S )Nr� r� r$ )r) r$ ZcountryrK r� )rB r r� r r r rD � s �z'DigitalOcean_v2_NodeDriver._to_locationc C sH |d |d |d d�}t |d |d |d |d |d |d | |d �S ) Nr� rA � price_monthly)r� rA r� r� r� r� ZtransferZ price_hourly)r) r$ Zramr� Z bandwidthZpricer� rK )r r� r r r rP � s ��z#DigitalOcean_v2_NodeDriver._to_sizec C s, d|d i}t |d |d |d d | |d�S )Nr) r$ � fingerprintr� )r$ r� r� Z private_keyr� rK )r r� r r r r? � s �z'DigitalOcean_v2_NodeDriver._to_key_pairc C s< |d |d |d |d d�}t |d |d |d | |d �S ) Nr� � resource_idrA r� )r� r� rA r� r) r$ r� r� )r r� r r r r� s ��z.DigitalOcean_v2_NodeDriver._to_volume_snapshotc s � fdd�|D �S )Nc s g | ]}� � |��qS r )r� )rL r� r. r r rO s z?DigitalOcean_v2_NodeDriver._to_floating_ips.<locals>.<listcomp>r �r+ �objr r. r r� s z+DigitalOcean_v2_NodeDriver._to_floating_ipsc C s6 t |d |d |d r|d d nd d|d i| d�S )Nr� rZ r) rV )r) r� r� rK r� )�!DigitalOcean_v2_FloatingIpAddressr� r r r r� s �z*DigitalOcean_v2_NodeDriver._to_floating_ip)Tr' �NNN)r� )NN)9r r r! r" r ZPENDINGZSTOPPEDZRUNNINGZ TERMINATEDr� rd r< r@ rF rI rQ rT rm rt rz 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� rH r9 rS rD rP r? r� r� r� r r r r r Y sr � �I " B c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) r� z Floating IP info. Nc C s& t |�| _|| _|| _|| _|| _d S r' )�strr) r� rK r� r� )r+ r) r� r� rK r� r r r r, + s z*DigitalOcean_v2_FloatingIpAddress.__init__c C s | j �| �S )zC Delete this floating IP :rtype: ``bool`` )r� r� r. r r r �delete2 s z(DigitalOcean_v2_FloatingIpAddress.deletec C r- )NzA<DigitalOcean_v2_FloatingIpAddress: id=%s, ip_addr=%s, driver=%s>)r) r� r� r. r r r r/ : r0 z*DigitalOcean_v2_FloatingIpAddress.__repr__r� )r r r! r" r, r� r/ r r r r r� & s r� ) r" rg ra Zlibcloud.utils.py3r Zlibcloud.common.typesr Zlibcloud.compute.baser r r r r r r r Zlibcloud.compute.typesr r Zlibcloud.utils.iso8601r Z libcloud.common.digitaloceanr r �__all__r r& r r� r r r r �<module> s& ( " R
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings