File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/__pycache__/botomod.cpython-310.pyc
Back
o ;j� � @ s: d Z ddlZddlZddlZddlmZ ddlZddlZddl Zddl m Z ddl m Z zddlZddlZe�d��ej� dZW n eyL dZY nw e�e�ZdadZejj�� Z e � d i �Z d d � Z d d � Z d!dd�Z!dd� Z" d"dd�Z#d#dd�Z$dd� Z%d$dd�Z&dd � Z'd%d d �Z(d d � Z)dS )&a� Boto Common Utils ================= Note: This module depends on the dicts packed by the loader and, therefore, must be accessed via the loader or from the __utils__ dict. This module provides common functionality for the boto execution modules. The expected usage is to call `assign_funcs` from the `__virtual__` function of the module. This will bring properly initialized partials of `_get_conn` and `_cache_id` into the module's namespace. Example Usage: .. code-block:: python def __virtual__(): __utils__['boto.assign_funcs'](__name__, 'vpc') def test(): conn = _get_conn() vpc_id = _cache_id('test-vpc') .. versionadded:: 2015.8.0 � N)�partial)�SaltInvocationError)� minion_mods�botoTF� __context__c C s, t jjjdd�} | du rtstt�atS | S )zg Only load if boto libraries exist and if boto libraries are greater than a given version. F)Z check_boto3T)�salt�utilsZversionsZcheck_boto_reqs�__salt__r Z__opts__�__virtualname__)Zhas_boto_requirements� r �F/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/botomod.py� __virtual__< s r c C s |r)t |t�rtd |�}nt |t�r|}|�dd �}|�dd �}|�d|p'd �}|s;td | d �r;td | d �}|s?d}|sQtd | d �rQtd | d �}|sctd | d �rctd | d �}d | � d �}|r�|| | }tjj�|�}|t � |�� � }n|| }||||fS ) Nz config.option�key�keyid�regionz.regionz us-east-1z.keyz.keyidZboto_�:) � isinstance�strr �dict�getr r Z stringutils�to_bytes�hashlib�md5� hexdigest) �servicer r r �profileZ_profileZlabelZ hash_string�cxkeyr r r � _get_profileJ s. r c s� t | ||||�\} } } } |r| � d|� d|� d�} n| � d|� d�} |rK| tv r-t| = dS � t�� v rI� fdd�t�� D �} t�� t�| � dS dS � rS� t| < dS t�| �S )a Cache, invalidate, or retrieve an AWS resource id keyed by name. .. code-block:: python __utils__['boto.cache_id']('ec2', 'myinstance', 'i-a1b2c3', profile='custom_profile') r z:idTc s i | ] \}}|� kr||�qS r r )�.0�k�v�� resource_idr r � <dictcomp>� s z cache_id.<locals>.<dictcomp>F)r r �values�items�clear�updater ) r �nameZ sub_resourcer" Z invalidater r r r r �_�ctxr r! r �cache_idh s$ r+ c C s t t| �S )z� Returns a partial ``cache_id`` function for the provided service. .. code-block:: python cache_id = __utils__['boto.cache_id_func']('ec2') cache_id('myinstance', 'i-a1b2c3') instance_id = cache_id('myinstance') )r r+ )r r r r � cache_id_func� s r, c C s� t |p| �}d| �dd�\}}tt||gd�|�}t| ||||�\}}}}|d }|tv r2t| S z|j|||d�} | du rGtd|� d ���W n tj j yY td � | |���w | t|< | S ) z� Return a boto connection for the service. .. code-block:: python conn = __utils__['boto.get_connection']('ec2', profile='custom_profile') zboto.�.� )�fromlistz:conn)Zaws_access_key_idZaws_secret_access_keyNzRegion "z" is not valid.z^No authentication credentials found when attempting to make boto {} connection to region "{}".) r �rsplit�getattr� __import__r r Zconnect_to_regionr r � exceptionZNoAuthHandlerFound�format) r �moduler r r r Z submoduleZsvc_modr �connr r r �get_connection� s, ����r7 c C s t t| |d�S )z� Returns a partial ``get_connection`` function for the provided service. .. code-block:: python get_conn = __utils__['boto.get_connection_func']('ec2') conn = get_conn() �r5 )r r7 )r r5 r r r �get_connection_func� s r9 c C s� i }t | d�r | j|d< t | d�r| j|d< t | d�r%| jdkr%| j|d< t | d�r4| jd ur4| j|d< d|v rGd|v rGd�|d |d �}nd|v rP|d }n d|v rY|d }nd}d|i}|re||d< |S ) N�status�reason�message� � error_code�codez{}: {}�aws)�hasattrr: r; r< r> r4 )�er@ r< �rr r r � get_error� s( rD r. c s, t | �� t� fdd�t|�D ��ot� � S )zb Tests that exactly N items in an iterable are "truthy" (neither None, False, nor 0). c 3 s � | ]}t � �V qd S �N)�any)r �j��ir r � <genexpr>� s � z exactly_n.<locals>.<genexpr>)�iter�all�rangerF )�l�nr rH r � exactly_n� s $rP c C s t | �S rE )rP )rN r r r � exactly_one� s rQ c C sF |r|a tj| }t|dt||d�� t|dt|�� t|dt� dS )z� Assign _get_conn and _cache_id functions to the named module. .. code-block:: python __utils__['boto.assign_partials'](__name__, 'ec2') Z _get_connr8 Z _cache_idZ _exactly_oneN)r �sys�modules�setattrr9 r, rQ )�modnamer r5 �pack�modr r r � assign_funcs� s rX c o sL � |� dd�}|� dd�} | |i |��}|�|�}|V |s!dS |||< q)z� Retrieve full set of values from a boto API call that may truncate its results, yielding each page as it is obtained. � marker_flag�markerTN)�popr )�function�args�kwargsrY Z marker_arg�retrZ r r r � paged_call s � �r` )NNFNNNN)NNNNNrE )r. )NN)*�__doc__r �loggingrR � functoolsr Zsalt.loader.contextr Zsalt.utils.stringutilsZsalt.utils.versionsZsalt.exceptionsr Z salt.loaderr r Zboto.exception� getLogger�setLevel�CRITICALZHAS_BOTO� ImportError�__name__�logr r �loader�contextZ LoaderContextZ__salt_loader__Z named_contextr r r r+ r, r7 r9 rD rP rQ rX r` r r r r �<module> sT � ! �- � &
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings