golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/clouds/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
171 B
Del
OK
aliyun.cpython-310.pyc
19.81 KB
Del
OK
azurearm.cpython-310.pyc
39.67 KB
Del
OK
clc.cpython-310.pyc
8.91 KB
Del
OK
cloudstack.cpython-310.pyc
10.87 KB
Del
OK
digitalocean.cpython-310.pyc
27.39 KB
Del
OK
dimensiondata.cpython-310.pyc
12.62 KB
Del
OK
ec2.cpython-310.pyc
92.28 KB
Del
OK
gce.cpython-310.pyc
48.78 KB
Del
OK
gogrid.cpython-310.pyc
11.07 KB
Del
OK
hetzner.cpython-310.pyc
11.82 KB
Del
OK
joyent.cpython-310.pyc
22.78 KB
Del
OK
libvirt.cpython-310.pyc
16.69 KB
Del
OK
linode.cpython-310.pyc
59.17 KB
Del
OK
lxc.cpython-310.pyc
10.9 KB
Del
OK
msazure.cpython-310.pyc
71.44 KB
Del
OK
oneandone.cpython-310.pyc
18.39 KB
Del
OK
opennebula.cpython-310.pyc
90.2 KB
Del
OK
openstack.cpython-310.pyc
23.53 KB
Del
OK
packet.cpython-310.pyc
12.06 KB
Del
OK
parallels.cpython-310.pyc
11.89 KB
Del
OK
profitbricks.cpython-310.pyc
25.34 KB
Del
OK
proxmox.cpython-310.pyc
27.25 KB
Del
OK
pyrax.cpython-310.pyc
2.59 KB
Del
OK
qingcloud.cpython-310.pyc
16.64 KB
Del
OK
saltify.cpython-310.pyc
11.91 KB
Del
OK
scaleway.cpython-310.pyc
9.36 KB
Del
OK
softlayer.cpython-310.pyc
13.26 KB
Del
OK
softlayer_hw.cpython-310.pyc
13.5 KB
Del
OK
tencentcloud.cpython-310.pyc
20.55 KB
Del
OK
vagrant.cpython-310.pyc
8.32 KB
Del
OK
virtualbox.cpython-310.pyc
9.57 KB
Del
OK
vmware.cpython-310.pyc
94.14 KB
Del
OK
vultrpy.cpython-310.pyc
12.8 KB
Del
OK
xen.cpython-310.pyc
25.66 KB
Del
OK
Edit: joyent.cpython-310.pyc
o �xec| � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl m Z ddl Z ddl Z ddlZ ddlZ ddlZ ddlmZmZmZmZ z ddlmZ dZdZW nA ey� dZzddlm Z ddl m Z dZW n% ey� zddl m Z ddl m Z dZW n ey� dZY nw Y nw Y nw e�!e"�Z#d Z$d Z%d Z&d d ddd�Z'dZ(dZ)ej*j+ej*j,ej*j-ej*j.gZ/dd� Z0dd� Z1dd� Z2dd� Z3dd� Z4dYd d �Z5d d � Z6d d!� Z7dZd"d#�Z8dZd$d%�Z9dZd&d'�Z:dZd(d)�Z;ddddd*e(fd+d,�Z<d-d.� Z=dZd/d0�Z>dZd1d2�Z?d3d4� Z@dZd5d6�ZAd7d8� ZBdZd9d:�ZCd;d<� ZDd=d>� ZEd[d?d@�ZFd\dAdB�ZGdZdCdD�ZHdZdEdF�ZIdGdH� ZJdZdIdJ�ZKdZdKdL�ZLdYdMdN�ZMdYdOdP�ZNdYdQdR�ZOdYdSdT�ZPe(e%fdUdV�ZQd]dWdX�ZRdS )^aH Joyent Cloud Module =================== The Joyent Cloud module is used to interact with the Joyent cloud system. Set up the cloud configuration at ``/etc/salt/cloud.providers`` or ``/etc/salt/cloud.providers.d/joyent.conf``: .. code-block:: yaml my-joyent-config: driver: joyent # The Joyent login user user: fred # The Joyent user's password password: saltybacon # The location of the ssh private key that can log into the new VM private_key: /root/mykey.pem # The name of the private key keyname: mykey When creating your profiles for the joyent cloud, add the location attribute to the profile, this will automatically get picked up when performing tasks associated with that vm. An example profile might look like: .. code-block:: yaml joyent_512: provider: my-joyent-config size: g4-highcpu-512M image: centos-6 location: us-east-1 This driver can also be used with the Joyent SmartDataCenter project. More details can be found at: .. _`SmartDataCenter`: https://github.com/joyent/sdc Using SDC requires that an api_host_suffix is set. The default value for this is `.api.joyentcloud.com`. All characters, including the leading `.`, should be included: .. code-block:: yaml api_host_suffix: .api.myhostname.com :depends: PyCrypto � N)�SaltCloudExecutionFailure�SaltCloudExecutionTimeout�SaltCloudNotFound�SaltCloudSystemExit)�EVPTF)�SHA256)� PKCS1_v1_5�joyentz.api.joyentcloud.comz~7.2zNorth Virginia, USAzBay Area, California, USAzLas Vegas, Nevada, USAzAmsterdam, Netherlands)� us-east-1z us-west-1zus-sw-1zeu-ams-1r c C s t du rdS t� du r dS tS )z" Check for Joyent configs F)Fz4Either PyCrypto or Cryptodome needs to be installed.)�HAS_REQUIRED_CRYPTO�get_configured_provider�__virtualname__� r r �L/opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/clouds/joyent.py� __virtual__| s r c C s" zt �� W S ty t Y S w �N)Z__active_provider_name__�value�AttributeErrorr r r r �_get_active_provider_name� s �r c C s t �tt� ptd�S )z/ Return the first configured instance. )�user�password)�configZis_provider_configured�__opts__r r r r r r r � s �r c C sN t � }t�d| t�}|r t|�|v r || d || d< || S td�|���)z( Return the image object to use �image�id�namez.The specified image, '{}', could not be found.)� avail_imagesr �get_cloud_config_valuer �strr �format)�vm_ZimagesZvm_imager r r � get_image� s �r! c C sF t � }t�d| t�}|std��|r t|�|v r || S td�|���)z% Return the VM's size object �sizez No size specified for this VM.z-The specified size, '{}', could not be found.)� avail_sizesr r r r r r )r ZsizesZvm_sizer r r �get_size� s �r$ c s t � t�r|dkr� dd�� |dkrtd��td ddd �� d �td td d � � fdd�}z#tjjj |t j d� tdd�t j d� tdd�t j d� tdd�d�}W |S t t fy� } z!zzW n tyi Y nw W tt|���W tt|���tt|���d}~ww )z= Query an instance upon creation from the Joyent API �actionr )r �provider�functionz=The query_instance action must be called with -a or --action.�cloud.fire_event�eventzquerying instancezsalt/cloud/{}/queryingr �sock_dir� transport)r* r+ c s� t � d dd�} | st�d� dS t| t�r%d| v r%t�d| �d�� dS t�d| � d | d v r?| d d d kr?| d d S d S ) Nr r% ��callz8There was an error while querying Joyent. Empty responseF�errorz"There was an error in the query %szReturned query data: %s� primaryIp� �state�running)� show_instance�logr. � isinstance�dict�warning�get�debug)�data�r r r �_query_ip_address� s z)query_instance.<locals>._query_ip_addressZwait_for_ip_timeoutiX )�defaultZwait_for_ip_interval� Z wait_for_ip_interval_multiplierr0 )�timeout�intervalZinterval_multiplierN)r5 r r � __utils__r r �salt�utils�cloudZ wait_for_ipr r r r )r r- r< r: �excr r; r �query_instance� sP � � ����� �� ���rF c C s� z| d rt jtt� p d| d | d�du rW dS W n ty" Y nw t jd| tddd�}td d d d �| d �td d| g d��td td d� t� d| d | � dt �� t j j�| d d� | d t| �t| �| � dt �d�}d| v r}| � d�|d< td d dd�| d �dtd d|t|��itd td d� td'i |��}|i kr�t�d | d � dS t| � t| d d d �}|| d < |d d! | d"< td# | t� td d d$d%�| d �td d&| g d��td td d� |d S )(z� Create a single VM from a data dict CLI Example: .. code-block:: bash salt-cloud -p profile_name vm_name �profiler r; F� private_keyN�� search_globalr= r( r) zstarting createzsalt/cloud/{}/creatingr zcloud.filter_eventZcreating)r rG r& Zdriverr* r+ ��argsr* r+ zCreating Cloud VM %s in %s�locationz a-zA-Z0-9-.)r r r" rM �networkszrequesting instancezsalt/cloud/{}/requesting�kwargsZ requestingzError creating %s on JOYENTr% r, � key_filenamer0 r/ Zssh_hostzcloud.bootstrapzcreated instancezsalt/cloud/{}/createdZcreatedr )r Zis_profile_configuredr r r r rA r r4 �infor8 �DEFAULT_LOCATIONrB rC rD Z check_namer! r$ �list� create_noder. rF r3 )r rP rO r: r r r �create� s� ���� � � �� � � ��� �� rU c K s. | d }| d }| d }| d }| � d�}| � d�}| � d�}| � d�}| � d �} ||d |d d �} |d ur;|| d< |d urC|| d< |d urW|�� D ] \} } | | d �| �< qK|d urk|�� D ] \} } | | d �| �< q_| d urs| | d < tjj�| �} td| d|d�}|d tv r�|d S t � d||d � i S )zK convenience function to make the rest api call for node creation. r r" r rM rN �tag�locality�metadata�firewall_enabled)r �packager Nz metadata.{}ztag.{}� my/machines�POST��commandr: �methodrM r r0 z Failed to create node %s: %s) r8 �itemsr rB rC �json�dumps�query�VALID_RESPONSE_CODESr4 r. )rO r r" r rM rN rV rW rX rY Z create_data�keyr r: �retr r r rT _ s> � rT c C s� |dkrt d��td ddd�| �d| itd td d � t| �}td �|d �|d dd�}td ddd�| �d| itd td d � t�dd�du rZtd | t� �d�d t� |d t v S )a< destroy a machine by name :param name: name given to the machine :param call: call value in this case is 'action' :return: array of booleans , true if successfully stopped and true if successfully removed CLI Example: .. code-block:: bash salt-cloud -d vm_name r' zEThe destroy action must be called with -d, --destroy, -a or --action.r( r) zdestroying instancezsalt/cloud/{}/destroyingr r* r+ rK �my/machines/{}r rM �DELETE�r^ rM r_ zdestroyed instancezsalt/cloud/{}/destroyedZupdate_cachedirFTz cloud.delete_minion_cachedir�:r ) r rA r r �get_noderc r8 r �splitrd �r r- �noderf r r r �destroy� s> �� �� � ro c C �: t | �}t| |dd�|d �|d ddid�}|d tv S ) z� reboot a machine by name :param name: name given to the machine :param call: call value in this case is 'action' :return: true if successful CLI Example: .. code-block:: bash salt-cloud -a reboot vm_name r\ rg r rM r% �reboot�r r- r_ r^ rM r: r �rk � take_actionr rd rm r r r rq � � � rq c C rp ) z� stop a machine by name :param name: name given to the machine :param call: call value in this case is 'action' :return: true if successful CLI Example: .. code-block:: bash salt-cloud -a stop vm_name r\ rg r rM r% �stoprr r rs rm r r r rv � ru rv c C rp ) z� start a machine by name :param name: name given to the machine :param call: call value in this case is 'action' :return: true if successful CLI Example: .. code-block:: bash salt-cloud -a start vm_name r\ rg r rM r% �startrr r rs rm r r r rw � ru rw �GETc C s� t �� d d }|dkrtd��|rtjj�|�}g }zt||||d�}t� d|| � W |S t ya } z(dt |�v r@di g}ntj d || |t jd � d i g}W Y d }~|S W Y d }~|S d }~ww ) ae take action call used by start,stop, reboot :param name: name given to the machine :param call: call value in this case is 'action' :command: api path :data: any data to be passed to the api, must be in json format :method: GET,POST,or DELETE :location: data center to execute the command on :return: true if successful r0 � r% z/This action must be called with -a or --action.r] zSuccess %s for node %sZ InvalidState�� z Failed to invoke %s node %s: %s)Zexc_info_on_loglevel�d N)�inspect�stackr rB rC ra rb rc r4 rQ � Exceptionr r. �logging�DEBUG) r r- r^ r: r_ rM Zcallerrf rE r r r rt s4 � � � ��rt c C s t jd| tddd�S )zj Return the ssh_interface type to connect to. Either 'public_ips' (default) or 'private_ips'. � ssh_interface� public_ipsF�r= rJ )r r r r; r r r r� @ s �r� c C s" t �dtjd| p t� t tdd��S )z� Return the joyent data center to use, in this order: - CLI parameter - VM parameter - Cloud profile setting rM Fr� )r r8 r r r rR r; r r r � get_locationJ s ��r� c C s4 | dkrt d��i }tD ] }|t| d�||< q |S )z& List all available locations r% zfThe avail_locations function must be called with -f or --function, or with the --list-locations option)r Zregion)r �JOYENT_LOCATIONS)r- rf re r r r �avail_locations] s �r� c C s |t | �v rdS t�d|� dS )z; Find if the provided object has a specific method Tz Method '%s' not yet supported!F)�dirr4 r. )�obj� method_namer r r � has_method{ s r� c C sT | du rg } i }| r(t | t�r(| D ]}d|v r'd|vr!|d |d< |||d < q|S )z� convert list to dictionary using the key as the identifier :param items: array to iterate over :return: dictionary Nr r )r5 rS )r` rf �itemr r r �key_list� s �r� c C s t � }| |v r || S dS )zp gets the node from the full node list by name :param name: name of the vm :return: node object N)� list_nodes)r �nodesr r r rk � s rk c C s( t | �}td�|d �|d dd�}|S )z� get details about a machine :param name: name given to the machine :param call: call value in this case is 'action' :return: machine information CLI Example: .. code-block:: bash salt-cloud -a show_instance vm_name rg r rM rx ri )rk rc r rm r r r r3 � s �r3 c C sP ddddddddd d � }ddd dddd dddd d d� }t | t�r$|| S || S )z( Libcloud supported node states ZRUNNINGZ REBOOTINGZ TERMINATEDZPENDING�UNKNOWNZSTOPPEDZ SUSPENDEDZERRORZPAUSED) r r0 � ry � � � � � ZSTARTINGZSTOPPINGZ RECONFIGURING) r2 Z rebootingZstartingZ terminated�pending�unknown�stopping�stoppedZ suspendedr. ZpausedZ reconfiguring)r5 r )�id_Z states_intZ states_strr r r �_old_libcloud_node_state� s0 � �r� c C s* ddddddd�}| |vrd} t || �S )z� Convert joyent returned state to state common to other data center return values for consistency :param id_: joyent state value :return: state value r r� ry r� )r2 r� r� Z provisioningZdeletedr� r� )r� )r� Zstatesr r r �joyent_node_state� s � r� c C s� g d�}g | d< g | d< d| v r-| d D ]}t jj�|�r%| d �|� q| d �|� q|D ] }|| vr9d| |< q/g }|sN| �� D ] }||vrM|�|� qB|D ]}| |= qPd| v rbt| d �| d< | S )z� Reformat the returned data from joyent, determine public/private IPs and strip out fields if necessary to provide either full or brief content. :param item: node dictionary :param full: full or brief output :return: dict )r r r1 r� � private_ipsr" r rM r� r� ZipsNr1 )rB rC rD Z is_public_ip�append�keysr� )r� �fullZ desired_keys�ipre Zto_delr r r � reformat_node� s. � �r� c C s� |dkrt d��i }trDtD ]3}td|dd�}|d tv r9|d }|D ]}d|v r7||d < t|| d �||d < q#qt�d |d � q|S t� }td|dd�}|d }|D ]}d|v rh||d < t|| d �||d < qT|S ) zx list of nodes, keeping only a brief listing CLI Example: .. code-block:: bash salt-cloud -Q r% z=The list_nodes function must be called with -f or --function.r[ rx ri r r0 r rM )r� r� z.Invalid response when listing Joyent nodes: %s) r �POLL_ALL_LOCATIONSr� rc rd r� r4 r. r� )r� r- rf rM �resultr� rn r r r r� % s6 � �� ��r� c C s | dkrt d��tdd�S )z� list of nodes, maintaining all content provided from joyent listings CLI Example: .. code-block:: bash salt-cloud -F r% zBThe list_nodes_full function must be called with -f or --function.T)r� )r r� r, r r r �list_nodes_fullL s � r� c C s t jj�td�td | �S )zO Return a list of the VMs that are on the provider, with select fields r' zquery.selection)rB rC rD �list_nodes_selectr� r r, r r r r� ^ s �r� c C s& t jdt� tddd�} | du rdS dS )z� Checks configuration to see whether the user has SSL turned on. Default is: .. code-block:: yaml use_ssl: True �use_sslFTrI �https�http)r r r r )r� r r r � _get_protoi s �r� c C s� | dkrt d��tjdt� tdd�}tjdt� tdd�tt|�d�}|�d �s3|�d �s3d �t � |�}t d d d�\}}t � |� i }|D ]}|||d < qD|S )z� Get list of available images CLI Example: .. code-block:: bash salt-cloud --list-images Can use a custom URL for images. Default is: .. code-block:: yaml image_url: images.joyent.com/images r% z`The avail_images function must be called with -f or --function, or with the --list-images optionr F�rJ Z image_urlz{}{}/{}/imagesrI zhttp://zhttps://z{}://{}z my/imagesrx �r^ r_ r ) r r r r r r rR �JOYENT_API_HOST_SUFFIX� startswithr� rc r4 r9 )r- r Zimg_url�rcoder: rf r r r r r } s, � � � r c C s4 | dkrt d��tdd�\}}|tvri S t|d�S )zu get list of available packages CLI Example: .. code-block:: bash salt-cloud --list-sizes r% z^The avail_sizes function must be called with -f or --function, or with the --list-sizes optionz my/packages)r^ )r` )r rc rd r� )r- r� r` r r r r# � s � r# c C sT |dkr t �d� dS | si } i }tddd�\}}|D ] }|d ||d < qd |iS ) �! List the keys available r' �<The list_keys function must be called with -f or --function.F�my/keysrx r� re r r� )r4 r. rc )rO r- rf r� r: �pairr r r � list_keys� s r� c C sb |dkr t �d� dS | si } d| vrt �d� dS td�| d �dd�\}}d |d |d iiS ) r� r' r� F�keyname�A keyname is required.� my/keys/{}rx r� r� r re �r4 r. rc r �rO r- r� r: r r r �show_key� s �r� c C s |dkr t �d� dS | si } d| vrt �d� dS d| vr%t �d� dS tj�| d �s7t �d| d � dS tjj�| d d ��}tjj � |� � �| d < W d � n1 sWw Y | d | d d �}tjj � |�| d < tdd| d d�\}}t �t�|�� d|d |d iiS )z� List the keys available CLI Example: .. code-block:: bash salt-cloud -f import_key joyent keyname=mykey keyfile=/tmp/mykey.pub r' z=The import_key function must be called with -f or --function.Fr� r� �keyfilez,The location of the SSH keyfile is required.z*The specified keyfile (%s) does not exist.�rre N)r re r: r� r\ )r^ r_ r: r� r )r4 r. �os�path�isfilerB rC �filesZfopenZ stringutilsZ to_unicode�readra rb rc r9 �pprintZpformat)rO r- Zfp_Z send_datar� r: r r r � import_key� s4 � �r� c C sR |dkr t �d� dS | si } d| vrt �d� dS td�| d �dd�\}}|S ) z� List the keys available CLI Example: .. code-block:: bash salt-cloud -f delete_key joyent keyname=mykey r' z>The delete_keys function must be called with -f or --function.Fr� r� r� rh r� r� r� r r r � delete_key s �r� c C s d� t� | |�S )zm create url from location variable :param location: joyent data center location :return: url z {}://{}{})r r� �rM �api_host_suffixr r r �get_location_path1 s r� c C s� t jdt� tdd�}|st�d� t jdt� tdd�}t jdt� tddd�}t jd t� tddd�} | s8t�d � t jd t� tddd�} | sJt�d � |sOt� }t jd t� tdtd�} t|| d�} | rf| | 7 } |ro| d� |�7 } t� d|| � |r~| r~| r~|s�dS t j � � } | � d��� }tj�| d�}tr�t�d�}|�|�t�� |�� }|j|dd�}nt�|�}t �� }|�|�t�� |�|�}t � |�}|� d�}t |�dkr�d� |d | �}nt |�dkr�d� |d |d | �}nt�d� d d t!|d � ||�"t��d �}t#|t$��s i }|�stj%j&�'i �}d}tj%j(j)| ||||dddd|td � }t� d |d! � d"|v�r>|d! |d# gS d$|d" v �rP|d% }tj%j*�+|�}|d! |gS )&z# Make a web call to Joyent r Fr� z[username is required for Joyent API requests. Please set one in your provider configurationr � verify_sslTrI rH z_ssh_keyfile is required for Joyent API requests. Please set one in your provider configurationr� z_ssh_keyname is required for Joyent API requests. Please set one in your provider configurationr� r� z/{}zUser: '%s' on PATH: %sNz%a, %d %b %Y %H:%M:%S %Z�sha256)Zalgo�/r0 z /{}/keys/{}r r� z/{}/users/{}/keys/{}zMalformed user stringzapplication/jsonz.Signature keyId="{}",algorithm="rsa-sha256" {})z Content-TypeZAcceptz X-Api-VersionZDateZ Authorization) �paramsZ header_dictr: �decode�text�status�headersr� �optsz Joyent Response Status Code: %sr� r� r. zContent-Lengthr� ),r r r r r4 r. r� r� r� r r9 �datetime�utcnow�strftime�striprB ZcryptZ get_rsa_key�HAS_M2r Z MessageDigest�update�encodeZ__salt_system_encoding__�final�signr �newr �base64� b64encoderl �len�JOYENT_API_VERSIONr� r5 r6 rC ra rb r� rc ZyamlZ safe_load)r% r^ rL r_ rM r: r r r� Z ssh_keyfileZ ssh_keynamer� r� Ztimenow� timestampZrsa_keyZmd�digestZsignedZrsa_Zhash_Zuser_arrZkeyidr� Zreturn_contentr� �contentr r r rc < s� �� ������� �� � rc )NNr )NF)FN)NNNrx NN)S�__doc__r� r� � http.clientr� r| r r� r� Z salt.configr Zsalt.utils.cloudrB Zsalt.utils.filesZsalt.utils.httpZsalt.utils.jsonZsalt.utils.yamlZsalt.exceptionsr r r r ZM2Cryptor r r� � ImportErrorZCryptodome.Hashr ZCryptodome.Signaturer Z Crypto.HashZCrypto.SignatureZ getLogger�__name__r4 r r� r� r� rR r� �client�OK�ACCEPTED�CREATED� NO_CONTENTrd r r r r! r$ rF rU rT ro rq rv rw rt r� r� r� r� r� rk r3 r� r� r� r� r� r� r� r r# r� r� r� r� r� rc r r r r �<module> s� 2 ����� �� Cb / 6 �1 1 ' . , �
Save