File: //lib/python3/dist-packages/awscli/customizations/__pycache__/opsworks.cpython-38.pyc
U
<�^mR � @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl m Z d dl
mZmZmZ d dlmZ d dlmZ e�e�ZdZe jdd�Zd Zd
Z e� d ej �Z e� d �Z e� d
�Z!dZ"d�#� Z$dd� Z%dd� Z&G dd� de�Z'dd� Z(dd� Z)dS )� N)� ClientError)� shlex_quote�urlopen�ensure_text_type)� BasicCommand)�!create_client_from_parsed_globalszOpsWorks-Instance� )Zminutesz/AWS/OpsWorks/z7arn:aws:iam::aws:policy/AWSOpsWorksInstanceRegistrationz ^(?!-)[a-z0-9-]{1,63}(?<!-)$z
^i-[0-9a-f]+$z^\d+\.\d+\.\d+\.\d+$z@http://169.254.169.254/latest/dynamic/instance-identity/documenta�
set -e
umask 007
AGENT_TMP_DIR=$(mktemp -d /tmp/opsworks-agent-installer.XXXXXXXXXXXXXXXX)
curl --retry 5 -L %(agent_installer_url)s | tar xz -C $AGENT_TMP_DIR
cat >$AGENT_TMP_DIR/opsworks-agent-installer/preconfig <<EOF
%(preconfig)s
EOF
exec sudo /bin/sh -c "OPSWORKS_ASSETS_DOWNLOAD_BUCKET=%(assets_download_bucket)s $AGENT_TMP_DIR/opsworks-agent-installer/boot-registration; rm -rf $AGENT_TMP_DIR"
c C s | � dt� d S )Nz building-command-table.opsworks)�register�inject_commands)Zcli� r �@/usr/lib/python3/dist-packages/awscli/customizations/opsworks.py�
initialize= s r
c K s t |�| d< d S )Nr )�OpsWorksRegister)Z
command_table�session�kwargsr r r r
A s r
c s e Zd ZdZe�d��� Zdddd�dddd gd
d �d d
dd�dddd�dddd�dddd�dddd�d d d d�d d d!d"�d#d d$d"�d%dd&d'd(d)�g Z� fd*d+�Z d,d-� Z
d.d/� Z d0d1� Z d2d3� Z
d4d5� Zd6d7� Zd8d9� Zd:d;� Zd<d=� Zd>d?� ZedEdAdB��ZedCdD� �Z� ZS )Fr r z�
Registers an EC2 instance or machine with AWS OpsWorks.
Registering a machine using this command will install the AWS OpsWorks
agent on the target machine and register it with an existing OpsWorks
stack.
zstack-idTzZA stack ID. The instance will be registered with the
given stack.)�name�required� help_textzinfrastructure-class�ec2� on-premiseszzSpecifies whether to register an EC2 instance (`ec2`)
or an on-premises instance (`on-premises`).)r r �choicesr zoverride-hostname�hostnamezrThe instance hostname. If not provided, the current
hostname of the machine will be used.)r �destr zoverride-private-ip�
private_ipaA An IP address. If you set this parameter, the given IP
address will be used as the private IP address within
OpsWorks. Otherwise the private IP address will be
determined automatically. Not to be used with EC2
instances.zoverride-public-ip� public_ipa? An IP address. If you set this parameter, the given IP
address will be used as the public IP address within
OpsWorks. Otherwise the public IP address will be
determined automatically. Not to be used with EC2
instances.z override-ssh�sshzmIf you set this parameter, the given command will be
used to connect to the machine.z ssh-username�usernamezXIf provided, this username will be used to connect to
the host.zssh-private-key� private_keyzhIf provided, the given private key file will be used
to connect to the machine.�local�
store_truez�If given, instead of a remote machine, the local
machine will be imported. Cannot be used together
with `target`.)r �actionr zuse-instance-profilezRUse the instance profile instead of creating an IAM
user.�target�?z
[<target>]z�Either the EC2 instance ID or the hostname of the
instance or machine to be registered with OpsWorks.
Cannot be used together with `--local`.)r Zpositional_arg�nargsZsynopsisr c s> t t| ��|� d | _d | _d | _d | _d | _d | _d | _ d S �N)
�superr �__init__�_stack�
_ec2_instance� _prov_params� _use_address�
_use_hostname�
_name_for_iam�
access_key)�selfr �� __class__r r r& } s zOpsWorksRegister.__init__c C s" | j �d�| _t| j d|�| _d S )N�iam�opsworks)�_session�
create_clientr1 r r2 �r. �argsZparsed_globalsr r r �_create_clients� s �z OpsWorksRegister._create_clientsc C sL | � ||� | �|� | �|� | �|� | �|� | �|� | �|� d S r$ )r7 �prevalidate_arguments�retrieve_stack�validate_arguments�determine_details�create_iam_entities�setup_target_machiner5 r r r � _run_main� s
zOpsWorksRegister._run_mainc C s� |j s|jstd��n|j r*|jr*td��|jrDt�� dkrDtd��|jr^|jsV|jr^td��|jdkr�|j rvtd��|j
r�td��|jd kr�|j r�td
��|j r�t
�|j �s�td |j ��d S )
zN
Validates command line arguments before doing anything else.
z%One of target or --local is required.z4Arguments target and --local are mutually exclusive.ZLinuxz6Non-Linux instances are not supported by AWS OpsWorks.zYArgument --override-ssh cannot be used together with --ssh-username or --ssh-private-key.r z/--override-private-ip is not supported for EC2.z.--override-public-ip is not supported for EC2.r z1--use-instance-profile is only supported for EC2.zxInvalid hostname: '%s'. Hostnames must consist of letters, digits and dashes only and must not start or end with a dash.N)r! r �
ValueError�platform�systemr r r �infrastructure_classr r �use_instance_profiler � HOSTNAME_RE�match�r. r6 r r r r8 � sH
���
��
�� ��z&OpsWorksRegister.prevalidate_argumentsc s~ t �d� | jj� jgd�d d | _| jj| jd d�| _� jdk�rz� j �szt �d� | j
j d| jd d
�}d g i}g �d | jkr�|d � d
| jd gd�� n�� dd� � t
�� j�r̈ jg|d< n@t�� j�r�� � fdd�� � j| _n|d � d� jgd�� �fdd�|jf |�d D �}|�s@td� j ��n0t|�dk�rptd� jd�dd � |D ��f ��|d | _d S ) z�
Retrieves the stack from the API, thereby ensures that it exists.
Provides `self._stack`, `self._prov_params`, `self._use_address`, and
`self._ec2_instance`.
z,Retrieving stack and provisioning parameters)ZStackIdsZStacksr �StackId�rG r z#Retrieving EC2 instance information�Region)Z region_nameZFilters�VpcIdzvpc-id)�NameZValuesc S s d| kS )NrJ r ��instancer r r �<lambda>� � z1OpsWorksRegister.retrieve_stack.<locals>.<lambda>Z InstanceIdsc s | � d�� jkp | � d�� jkS )N�PrivateIpAddress�PublicIpAddress)�getr! rL �r6 r r rN � s ztag:Namec s4 g | ],}|d D ] � t � fdd��D ��r� �qqS )� Instancesc 3 s | ]}|� �V qd S r$ r )�.0�c��ir r � <genexpr>� s z=OpsWorksRegister.retrieve_stack.<locals>.<listcomp>.<genexpr>)�all)rU �r)�
conditionsrW r �
<listcomp>� s
�z3OpsWorksRegister.retrieve_stack.<locals>.<listcomp>Z Reservationsz&Did not find any instance matching %s.� z)Found multiple instances matching %s: %s.z, c s s | ]}|d V qdS )Z
InstanceIdNr )rU rX r r r rY s z2OpsWorksRegister.retrieve_stack.<locals>.<genexpr>N)�LOG�debugr2 Zdescribe_stacks�stack_idr' Z&describe_stack_provisioning_parametersr) rB r r3 r4 �append�INSTANCE_ID_RErE r! �
IP_ADDRESS_REr* �describe_instancesr? �len�joinr( )r. r6 r Z desc_args� instancesr )r6 r\ r r9 � sd
�����
�
�
�
�
����z OpsWorksRegister.retrieve_stackc s� � j rB| jj| jd d�d }t� fdd�|D ��rBtd� j ��� jdkr�� jr�t� t
t t ��
� ��d }|| jd kr�td
��d S ) zS
Validates command line arguments using the retrieved information.
rG rH rT c 3 s | ]}� j �� |d kV qdS )ZHostnameN)r �lower)rU rM rS r r rY s �z6OpsWorksRegister.validate_arguments.<locals>.<genexpr>z@Invalid hostname: '%s'. Hostnames must be unique within a stack.r �regionrI z1The stack's and the instance's region must match.N)r r2 re r' �anyr? rB r �json�loadsr r � IDENTITY_URL�read)r. r6 rh rj r rS r r: s0 �� ������z#OpsWorksRegister.validate_argumentsc C s� | j sn|jrn`|jdkr\d| jkr0| jd | _ qnd| jkrRt�d� | jd | _ qntd��n|jdkrn|j| _ |jr�|j| _ |j| _
n&|jr�d| _ t � � | _
nd| _ |j| _
dS )a
Determine details (like the address to connect to and the hostname to
use) from the given arguments and the retrieved data.
Provides `self._use_address` (if not provided already),
`self._use_hostname` and `self._name_for_iam`.
r rQ rP zYInstance does not have a public IP address. Trying to use the private address to connect.z1The instance does not seem to have an IP address.r N)
r* r rB r( r_ �warnr? r! r r+ r, �socketZ gethostnamerF r r r r; s0
��
z"OpsWorksRegister.determine_detailsc C sR |j rt�d� d| _dS t�d� dt| jd � }z | jj|td� t�d|� W nJ t k
r� } z,|j
� di �� d �d
kr�t�d |� n� W 5 d}~X Y nX t�d � d
t t| jd �d�t t| j
�d�f }td�D ]�}||r�d| nd }z| jj|td� W nN t k
�rV } z.|j
� di �� d �d
k�rDt�d|� n� W 5 d}~X Y q�X t�d|� �qtq�td��t�d� | jj||d� z| jjt|d� W n~ t k
�r } z^|j
� di �� d �dk�rt�dt|� | jjt| �| jd t�|d � t�d t|� n� W 5 d}~X Y nX t�d t|� t�d � | jj|d!�d" | _dS )#zp
Creates an IAM group, user and corresponding credentials.
Provides `self.access_key`.
z Skipping IAM entity creationNz#Creating the IAM group if necessaryz OpsWorks-%srG )� GroupName�PathzCreated IAM group %s�ErrorZCodeZEntityAlreadyExistsz IAM group %s exists, continuingzCreating an IAM userzOpsWorks-%s-%srK � � z+%s� )�UserNamers z/IAM user %s already exists, trying another namezCreated IAM user %sz&Couldn't find an unused IAM user name.z3Adding the user to the group and attaching a policy)rr rx )Z PolicyArnrx Z AccessDeniedzFUnauthorized to attach policy %s to user %s. Trying to put user policyZArn)Z
PolicyNameZPolicyDocumentrx zPut policy %s to user %sz Attached policy %s to user %szCreating an access key)rx Z AccessKey)rC r_ r` r- �
clean_for_iamr' r1 Z create_group�IAM_PATHr ZresponserR � shorten_namer, �rangeZ create_userr? Zadd_user_to_groupZattach_user_policy�IAM_POLICY_ARNZput_user_policy�IAM_USER_POLICY_NAME�_iam_policy_document�IAM_USER_POLICY_TIMEOUTZcreate_access_key)r. r6 Z
group_name�eZ
base_usernameZtry_r r r r r< G s�
� �
�
� ����
��z$OpsWorksRegister.create_iam_entitiesc C sh t | jd | �| �|��| jd d d� }|jrNt�d� t�dd|g� nt�d� | � ||� d S )
zz
Setups the target machine by copying over the credentials and starting
the installation process.
ZAgentInstallerUrl�
Parameters�assets_download_bucket)Zagent_installer_urlZ preconfigr� z Running the installer locally�/bin/sh�-cz6Connecting to the target machine to run the installer.N)
�
REMOTE_SCRIPTr) �
_to_ruby_yaml�_pre_config_documentr r_ r` �
subprocess�
check_callr )r. r6 �
remote_scriptr r r r= � s �
z%OpsWorksRegister.setup_target_machinec C s8 t �� dkr�z�tjddd�}|�|� |�� |j r<|j }nBd}|j
rT|d|j
7 }|j rh|d|j 7 }|d| j 7 }|d 7 }|d|j 7 }t
j|d
d � W 5 t�|j� X n�|j r�t�t|j ��}n@d d
g}|j
r�|�d|j
g� |j r�|�d|j g� |�| j � dd|g}|�d�dd� |D ��� t
�|� dS )zA
Runs a (sh) script on a remote machine via SSH.
ZWindowsZwtF)�deleteZplinkz -l "%s"z -i "%s"z "%s"z -mT)�shellr z-ttz-lz-ir� r� � c s s | ]}t |�V qd S r$ )r )rU Zwordr r r rY � s z'OpsWorksRegister.ssh.<locals>.<genexpr>N)r@ rA �os�remover �tempfileZNamedTemporaryFile�write�closer r r r* r� r� �shlex�split�str�extendrb rg )r. r6 r� Z script_file�callZ remote_callr r r r � s8
zOpsWorksRegister.sshc C s� t f d| jd i| jd ��}| jr@| jd |d< | jd |d< | jrP| j|d< |jr`|j|d < |jrp|j|d
< |jd k|d < t� d
|� |S )Nra rG r� Z AccessKeyIdZ
access_key_idZSecretAccessKeyZsecret_access_keyr r r r �importzUsing pre-config: %r)
�dictr' r) r- r+ r r rB r_ r` )r. r6 �
parametersr r r r� � s$ ���
z%OpsWorksRegister._pre_config_documentNc C sN dd| d�}|d k r8t j �� | }dd|�d�ii|d< |gdd �}t�|�S )
Nzopsworks:RegisterInstanceZAllow)ZActionZEffectZResourceZ DateLessThanzaws:CurrentTimez%Y-%m-%dT%H:%M:%SZZ Conditionz
2012-10-17)Z StatementZVersion)�datetimeZutcnow�strftimerl �dumps)ZarnZtimeoutZ statementZ valid_untilZpolicy_documentr r r r � s ����z%OpsWorksRegister._iam_policy_documentc C s d� dd� t| �� �D ��S )N�
c s s$ | ] \}}d |t �|�f V qdS )z:%s: %sN)rl r� )rU �k�vr r r rY s �z1OpsWorksRegister._to_ruby_yaml.<locals>.<genexpr>)rg �sorted�items)r� r r r r� s
�z OpsWorksRegister._to_ruby_yaml)N)�__name__�
__module__� __qualname__�NAME�textwrap�dedent�stripZ DESCRIPTIONZ ARG_TABLEr& r7 r> r8 r9 r: r; r< r= r r� � staticmethodr r� �
__classcell__r r r/ r r E sj ������������.
'L'\( r c C s t �dd| �S )z9
Cleans a name to fit IAM's naming requirements.
z[^A-Za-z0-9+=,.@_-]+�-)�re�sub)r r r r ry s ry c C sD t | �|kr| S t|d d�\}}| d|| � d | | d� S )z<
Shortens a name to the given number of characters.
� � Nz...)rf �divmod)r Z
max_length�qr[ r r r r{ s r{ )*r� rl Zloggingr� r@ r� r� rq r� r� r� Zbotocore.exceptionsr Z
awscli.compatr r r Z awscli.customizations.commandsr Zawscli.customizations.utilsr Z getLoggerr� r_ r~ Z timedeltar� rz r} �compile�IrD rc rd rn �lstripr� r
r
r ry r{ r r r r �<module>
sB
� M