File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/boto_datapipeline.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlZddlZe�e�Zz ddlZddlZ ej ej d� e�d�� ej � dZ W n ey6 dZ Y nw dd� Zd d d �Z d d d �Zd dd�Zd dd�Z d!dd�Zd dd�Zd dd�Z d"dd�Zdd � Zd d � ZdS )#zY Connection module for Amazon Data Pipeline .. versionadded:: 2016.3.0 :depends: boto3 � N)�level�botocoreTFc C s t jjjdd�S )z. Only load if boto3 libraries exists. F)Z check_boto)�salt�utilsZversionsZcheck_boto_reqs� r r �R/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/boto_datapipeline.py� __virtual__ s r c C �l t ||||�}i }z |j| d� d|d< W |S tjjtjjfy5 } z t|�|d< W Y d}~|S d}~ww )z� Start processing pipeline tasks. This function is idempotent. CLI Example: .. code-block:: bash salt myminion boto_datapipeline.activate_pipeline my_pipeline_id �� pipelineIdT�result�errorN)� _get_client�activate_pipeliner � exceptions� BotoCoreError� ClientError�str�� pipeline_id�region�key�keyid�profile�client�r�er r r r ! � ���r � c C st t ||||�}i }z|j| ||d�} | d |d< W |S tjjtjjfy9 } z t| �|d< W Y d} ~ |S d} ~ ww )z� Create a new, empty pipeline. This function is idempotent. CLI Example: .. code-block:: bash salt myminion boto_datapipeline.create_pipeline my_name my_unique_id )�nameZuniqueId� descriptionr r r N)r �create_pipeliner r r r r ) r Z unique_idr r r r r r r �responser r r r r! 5 s ����r! c C r )z� Delete a pipeline, its pipeline definition, and its run history. This function is idempotent. CLI Example: .. code-block:: bash salt myminion boto_datapipeline.delete_pipeline my_pipeline_id r Tr r N)r �delete_pipeliner r r r r r r r r r# O r r# c C sh t ||||�}i }z |j| d�|d< W |S tjjtjjfy3 } z t|�|d< W Y d}~|S d}~ww )z� Retrieve metadata about one or more pipelines. CLI Example: .. code-block:: bash salt myminion boto_datapipeline.describe_pipelines ['my_pipeline_id'] )Z pipelineIdsr r N)r �describe_pipelinesr r r r r )Z pipeline_idsr r r r r r r r r r r$ c s ���r$ �latestc C sj t ||||�}i }z |j| |d�|d< W |S tjjtjjfy4 } z t|�|d< W Y d}~|S d}~ww )z� Get the definition of the specified pipeline. CLI Example: .. code-block:: bash salt myminion boto_datapipeline.get_pipeline_definition my_pipeline_id )r �versionr r N)r �get_pipeline_definitionr r r r r ) r r& r r r r r r r r r r r' v s ����r' c C s� t | |||�}i }z|�d�}g }|�� D ]}||d 7 }q||d< W |S tjjtjjfyC } z t| �|d< W Y d} ~ |S d} ~ ww )z� Get a list of pipeline ids and names for all pipelines. CLI Example: .. code-block:: bash salt myminion boto_datapipeline.list_pipelines profile=myprofile �list_pipelinesZpipelineIdListr r N)r Z get_paginatorZpaginater r r r r ) r r r r r r Z paginatorZ pipelinesZpager r r r r( � s ���r( c C sV i }t � }d|v r |S |d D ]}|d | kr!|d |d< | S qd| � �|d< |S )z� Get the pipeline id, if it exists, for the given name. CLI Example: .. code-block:: bash salt myminion boto_datapipeline.pipeline_id_from_name my_pipeline_name r r r �idz No pipeline found with name=)r( )r r r r r r Zresult_pipelinesZpipeliner r r �pipeline_id_from_name� s �r* c C s� |pg }|pg }t ||||�}i } z |j| |||d�} | d r(| d | d< W | S | | d< W | S tjjtjjfyM } z t| �| d< W Y d} ~ | S d} ~ ww )a% Add tasks, schedules, and preconditions to the specified pipeline. This function is idempotent and will replace an existing definition. CLI Example: .. code-block:: bash salt myminion boto_datapipeline.put_pipeline_definition my_pipeline_id my_pipeline_objects )r ZpipelineObjectsZparameterObjectsZparameterValuesZerroredZvalidationErrorsr r N)r �put_pipeline_definitionr r r r r ) r Zpipeline_objectsZparameter_objectsZparameter_valuesr r r r r r r" r r r r r+ � s* � ����r+ c C s* t | |||�}|st�d� dS |�d�S )z1 Get a boto connection to Data Pipeline. z"Failed to get datapipeline client.NZ datapipeline)� _get_session�logr r )r r r r �sessionr r r r � s r c C s� |r't |t�rtd |�}nt |t�r|}|�dd�}|�dd�}|�dd�} | s5td d�r5td d�} | s9d} tjj| ||d�S ) z Get a boto3 session z config.optionr Nr r zdatapipeline.regionz us-east-1)Z region_nameZaws_secret_access_keyZaws_access_key_id)� isinstancer Z__salt__�dict�get�boto3r. ZSession)r r r r Z_profiler r r r, � s" �r, )NNNN)r NNNN)r% NNNN)NNNNNN)�__doc__�loggingZsalt.utils.versionsr � getLogger�__name__r- r2 Zbotocore.exceptionsr Zset_stream_logger�CRITICAL�setLevelZ HAS_BOTO3� ImportErrorr r r! r# r$ r' r( r* r+ r r, r r r r �<module> s@ � � � �(
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings