Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
awscli
/
customizations
/
emr
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: emrutils.cpython-310.pyc
o .&�am � @ sX d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlm Z m Z d dl m Z e� e�Zdd� Zd d � Zd d � Zd d� Zdd� Zdd� Zdejdddfdd�Z dBdd�ZdCdd �ZdDd d �Zd d � Zd!d"� Z dEd#d$�Z d%d&� Z dFd(d)�Z d*d+� Z d,d-� Z!d.d/� Z"d0d1� Z#d2d3� Z$d4d5� Z%d6d7� Z&dGd:d;�Z'd<d=� Z(d>d?� Z)d@dA� Z*dS )H� N)�CLIOperationCaller)� constants)� exceptions)� WaiterError�NoCredentialsError)� xform_namec C sP g }| r&| D ] }|� d�dkr|d}}n|�dd�\}}|�||d�� q|S )N�=���� � ��Key�Value)�find�split�append)� raw_tags_list�tags_dict_list�tag�key�value� r �D/usr/lib/python3/dist-packages/awscli/customizations/emr/emrutils.py� parse_tags s r c C sb g }| d ur/| � d�}|D ] }|�d�dkr |d}}n|� dd�\}}|�||d�� q |S d S )N�,r r r r r )r r r )�key_value_string�key_value_list�raw_key_value_list�kvr r r r r �parse_key_value_string) s r c C s0 | r|rd| d | d }t |��| rdS dS )Nz aws: error: cannot use both z and z options together.TF)� ValueError)� true_option�true_option_name� false_option�false_option_name� error_messager r r �apply_boolean_options: s ����r& c C � |r|| |< | S �Nr ��paramsr r r r r �applyH � r+ c C r' r( r r) r r r � apply_dictO r, r- c C s$ || � � v r| | r| | ||< |S r( )�keys)� src_params�src_key� dest_params�dest_keyr r r � apply_paramsV s r3 �Stepc C sf t dd| d� i }t|d|� t|d|� i }| |d< t|d|� t|d|� t|d|� ||d< |S ) N� HadoopJarStep�Jar�� structure�namer �Name�ActionOnFailure�Args� MainClass� Properties)�check_required_fieldr- )�jarr9 �action_on_failure�args� main_class� properties�step� jar_configr r r � build_step] s � rG �Bootstrap Actionc C sN | d u r t jddd��i }t|d|� i }t|d|� | |d< t|d|� |S )N�ScriptBootstrapActionConfig�Path�� object_name�missingr: r< �ScriptBootstrapAction)r �MissingParametersErrorr- )�pathr9 rB � ba_config� script_configr r r �build_bootstrap_actions s � rS r � us-east-1c C s |d u rd}d� || �S )NrT z s3://{0}.elasticmapreduce{1})�format�� relative_path�regionr r r � build_s3_link� s rY c C s | d u rd} t tj| d�S )NrT rV )rY r �SCRIPT_RUNNER_PATH)rX r r r �get_script_runner� s �r[ c C s |s t j| |d��d S )NrK )r rO r7 r r r r? � s ��r? c C s4 |rt |�dkr|d �� dkrtj| d��d S d S )Nr r r )�param)�len�stripr �EmptyListError)r9 r r r r �check_empty_string_list� s �r` c C sJ | � � d u r t� �| jd|||d�}t�dt|� � t||�di |��S )N�emr�� region_name� endpoint_url�verifyzCalling r )�get_credentialsr � create_client�LOG�debug�str�getattr)�session�operation_name� parametersrc rd re �clientr r r �call� s �rp c C s t d| d �S )Nzawscli/examples/emr/z.rst)�open)�commandr r r �get_example_file� s rs � c C s t j| |d�S )N)�indent)�json�dumps)�dictru r r r �dict_to_string� s ry c C s | j dt| |�|j|jd�S )Nra rb )rg � get_regionrd � verify_ssl)rl �parsed_globalsr r r � get_client� s �r} c C s& t | |�}|j|d�}|d d d S )N�� ClusterId�Cluster�Status�State�r} �describe_cluster�rl r| � cluster_idro �datar r r �get_cluster_state� s r� c C s" t | |�}|j|d�}|d d S )z8 Returns the master_instance's 'PublicDnsName'. r~ r� �MasterPublicDnsNamer� r� r r r �find_master_dns� s r� c C sV t jd �t j�D ] }|�d�}t j�|| �}t j�|�r(t �|t j �r(| S q d S )N�PATH�") �os�environr �pathsepr^ rP �join�isfile�access�X_OK)�programrP �exe_filer r r �which� s �r� c C s t | �}|�d|||� d S )Nra )r �invoke)rl rm rn r| �cli_operation_callerr r r �call_and_display_response� s �r� c C s t | �}|�|||� d S r( )r �_display_response)rl rm �resultr| r� r r r �display_response� s �r� c C s |j }|d u r | �d�}|S )NrX )rX �get_config_variable)rl r| rX r r r rz � s rz r �andc C s\ dd� | D �} t | �dk rdS t | �dkr| d S d| }d�|�| dd � �|| d g�S ) zM Helper method to print a list of values [1,2,3] -> '1, 2 and 3' c S s g | ]}t |��qS r )rj )�.0�xr r r � <listcomp>� s zjoin.<locals>.<listcomp>r r r z%s � Nr )r] r� )�values� separator� lastSeparatorr r r r� � s �r� c C s" | � d�dkr | dfS | �dd�S )Nr r r r )r r )�stringr r r �split_to_key_value� s r� c C s0 d| i}t |d||||�}|d ur|�d�S d S )Nr r� r� )rp �get)r� rl rX rd r{ �describe_cluster_params�describe_cluster_responser r r � get_cluster s � �r� c C s& t | ||||�}|d ur|�d�S d S )N� ReleaseLabel)r� r� )r� rl rX rd r{ �clusterr r r �get_release_label s � �r� )rH N)r rT )rT )NNN)rt )r r� )+rv �loggingr� �awscli.clidriverr �awscli.customizations.emrr r �botocore.exceptionsr r �botocorer � getLogger�__name__rh r r r& r+ r- r3 �DEFAULT_FAILURE_ACTIONrG rS rY r[ r? r` rp rs ry r} r� r� r� r� r� rz r� r� r� r� r r r r �<module> sX � � �
Save
Cancel