File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/clouds/__pycache__/joyent.cpython-310.pyc
Back
o ;j*| � @ 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 sP t � }t�d| t�}|r t|�|v r || d || d< || S td|� d���)z( Return the image object to use �image�id�namezThe specified image, '�', could not be found.)� avail_imagesr �get_cloud_config_valuer �strr )�vm_ZimagesZvm_imager r r � get_image� s r! c C sH t � }t�d| t�}|std��|r t|�|v r || S td|� d���)z% Return the VM's size object �sizez No size specified for this VM.zThe specified size, 'r )� avail_sizesr 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__�formatr �salt�utils�cloudZ wait_for_ipr r r r )r r- r< r: �excr r; r �query_instance� sP � � ����� �� ���rG 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 rH r& Zdriverr* r+ ��argsr* r+ zCreating Cloud VM %s in %s�locationz a-zA-Z0-9-.)r r r" rN �networkszrequesting instancezsalt/cloud/{}/requesting�kwargsZ requestingzError creating %s on JOYENTr% r, � key_filenamer0 r/ Zssh_hostzcloud.bootstrapzcreated instancezsalt/cloud/{}/created�createdr )r Zis_profile_configuredr r r r rA rB r4 �infor8 �DEFAULT_LOCATIONrC rD rE Z check_namer! r$ �list� create_noder. rG r3 )r rQ rP r: r r r �create� s� ���� � � �� � � ��� �� rW 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 rN rO �tag�locality�metadata�firewall_enabled)r �packager Nz metadata.ztag.� my/machines�POST��commandr: �methodrN r r0 z Failed to create node %s: %s) r8 �itemsrC rD �json�dumps�query�VALID_RESPONSE_CODESr4 r. )rP r r" r rN rO rX rY rZ r[ Z create_data�keyr r: �retr r r rV [ s> � rV c C s� |dkrt d��td ddd| � d�d| itd td d � t| �}td �|d �|d dd�}td ddd| � d�d| itd td d � t�dd�du r\td | 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 instancez salt/cloud/z /destroyingr r* r+ rL �my/machines/{}r rN �DELETE�r` rN ra zdestroyed instancez /destroyedZupdate_cachedirFTz cloud.delete_minion_cachedir�:r ) r rA r �get_nodere rB r8 r �splitrf �r r- �noderh r r r �destroy� s> � � � � � rq 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^ ri r rN r% �reboot�r r- ra r` rN r: r �rm � take_actionrB rf ro r r r rs � � � rs c C rr ) 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^ ri r rN r% �stoprt r ru ro r r r rx � rw rx c C rr ) 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^ ri r rN r% �startrt r ru ro r r r ry � rw ry �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 rC rD rc rd re r4 rS � Exceptionr r. �logging�DEBUG) r r- r` r: ra rN Zcallerrh rF r r r rv s4 � � � ��rv 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= rK )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 rN Fr� )r r8 r r r rT r; r r r � get_locationE 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- rh rg r r r �avail_locationsX 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_methodv 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 rU )rb rh �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 rm � s rm 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 ri r rN rz rk )rm re rB ro 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 SUSPENDED�ERRORZPAUSED) r r0 � r{ � � � � � 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� r{ 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 rN r� r� �ipsNr1 )rC rD rE Z is_public_ip�append�keysr� )r� �fullZ desired_keys�iprg 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] rz rk r r0 r rN )r� r� z.Invalid response when listing Joyent nodes: %s) r �POLL_ALL_LOCATIONSr� re rf r� r4 r. r� )r� r- rh rN �resultr� rp 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_fullG 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)rC rD rE �list_nodes_selectr� r r, r r r r� Y 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_sslFTrJ �https�http)r r r r )r� r r r � _get_protod s �r� c C s� | dkrt d��tjdt� tdd�}tjdt� tdt� t� d|� d�d �}|�d �s7|�d �s7t� � d |� �}t d dd�\}}t � |� i }|D ]}|||d < qH|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�rK Z image_url�/z/imagesrJ zhttp://zhttps://�://z my/imagesrz �r` ra r ) r r r r r rT �JOYENT_API_HOST_SUFFIX� startswithr� re r4 r9 )r- r Zimg_url�rcoder: rh r r r r r x 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` )rb )r re rf r� )r- r� rb 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/keysrz r� rg r r� )r4 r. re )rP r- rh 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/{}rz r� r� r rg �r4 r. re rB �rP 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.�rrg N)r rg r: r� r^ )r` ra r: r� r )r4 r. �os�path�isfilerC rD �filesZfopenZ stringutilsZ to_unicode�readrc rd re r9 �pprintZpformat)rP 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� rj r� r� r� r r r � delete_key s �r� c C s t � � d| � |� �S )zm create url from location variable :param location: joyent data center location :return: url r� )r� �rN �api_host_suffixr r r �get_location_path, 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 � d| � �}nt |�dkr�d|d � d|d � d| � �}nt�d� ddt |d �!||�"t��d �}t#|t$��si }|�stj%j&�'i �}d}tj%j(j)| ||||dddd|td � }t� d |d � d!|v�rD|d |d" gS d#|d! v �rV|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_sslTrJ rI 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� r� zUser: '%s' on PATH: %sNz%a, %d %b %Y %H:%M:%S %Z�sha256)Zalgor0 r z/keys/r� z/users/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� r9 �datetime�utcnow�strftime�striprC ZcryptZ get_rsa_key�HAS_M2r Z MessageDigest�update�encodeZ__salt_system_encoding__�final�signr �newr �base64� b64encodern �len�JOYENT_API_VERSIONrB r� r5 r6 rD rc rd r� re ZyamlZ safe_load)r% r` rM ra rN r: r r r� Z ssh_keyfileZ ssh_keynamer� r� Ztimenow� timestampZrsa_keyZmd�digestZsignedZrsa_Zhash_Zuser_arrZkeyidr� Zreturn_contentr� �contentr r r re 7 s� �� ������� �� � re )NNr )NF)FN)NNNrz NN)S�__doc__r� r� � http.clientr� r~ r� r� r� Z salt.configr Zsalt.utils.cloudrC Zsalt.utils.filesZsalt.utils.httpZsalt.utils.jsonZsalt.utils.yamlZsalt.exceptionsr r r r ZM2Cryptor r r� � ImportErrorZCryptodome.Hashr ZCryptodome.Signaturer Z Crypto.HashZCrypto.Signature� getLogger�__name__r4 r r� r� r� rT r� �client�OK�ACCEPTED�CREATED� NO_CONTENTrf r r r r! r$ rG rW rV rq rs rx ry rv r� r� r� r� r� rm r3 r� r� r� r� r� r� r� r r# r� r� r� r� r� re r r r r �<module> s� 2 ����� �� Cb / 6 �0 1 ' . , �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings