File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/__pycache__/boto3mod.cpython-310.pyc
Back
o ;j?! � @ sb d Z ddlZddlZddlZddlmZ ddlZddlZddl Zddl m Z z ddl Z ddl Z ddlZddlZe�d��ej� dZW n eyN dZY nw e�e�ZdZejj�� Ze� di �Z d d � Z d d � Z d d� Z d+dd�Z!dd� Z" d,dd�Z#d-dd�Z$dd� Z%dd� Z&d.d d �Z'd d � Z( ! "d/d#d$�Z)d%d&� Z*d'd(� Z+d)d*� Z,dS )0a� Boto3 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 `apply_funcs` from the `__virtual__` function of the module. This will bring properly initilized partials of `_get_conn` and `_cache_id` into the module's namespace. Example Usage: .. code-block:: python def __virtual__(): __utils__['boto.apply_funcs'](__name__, 'vpc') def test(): conn = _get_conn() vpc_id = _cache_id('test-vpc') .. versionadded:: 2015.8.0 � N)�partial)�SaltInvocationError�boto3TF� __context__c C s t jj�� } | du r tS | S )zg Only load if boto libraries exist and if boto libraries are greater than a given version. T)�salt�utilsZversionsZcheck_boto_reqs�__virtualname__)Zhas_boto� r �G/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/boto3mod.py� __virtual__< s r c C s@ | t v rt | S t�di �}| |v r|| S | tv r t| S dS )z* Look up the value for an option. ZmasterN)Z__opts__Z __pillar__�get)�valueZ master_optsr r r �_optionG s �r c C s |r%t |t�r t|�}nt |t�r|}|�dd �}|�dd �}|�dd �}|s3t| d �r3t| d �}|s=d}t�d|� |sKt| d �rKt| d �}|sYt| d �rYt| d �}d | � d �}|rx|| | }tjj � |�}|t � |�� � }n|| }||||fS ) N�key�keyid�regionz.regionz us-east-1zAssuming default region %sz.keyz.keyidZboto_�:)� isinstance�strr �dictr �log�infor r Z stringutils�to_bytes�hashlib�md5� hexdigest) �servicer r r �profileZ_profileZlabelZ hash_string�cxkeyr r r � _get_profileT s0 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_idu 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� |p| }t | ||||�\}}}}|d }|tv r t| S z(tjj|||d�}|du r2td|� d���|�|�}|du rCtd|� d���W n tjj yU td� | |���w |t|< |S )z� Return a boto connection for the service. .. code-block:: python conn = __utils__['boto.get_connection']('ec2', profile='custom_profile') z:conn3)Zaws_access_key_idZaws_secret_access_keyZ region_nameNzRegion "z" is not valid.z^No authentication credentials found when attempting to make boto {} connection to region "{}".) r r r �sessionZSessionr �client�botocore� exceptionsZNoCredentialsError�format) r �moduler r r r r r0 �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 t | |dd|�\}}}}|S )ze Retrieve the region for a particular AWS service based on configured region and/or profile. N)r )r r r r, r r r � get_region� s r: c C s* i }d}| j d }d|i}|r||d< |S )N� r �message�aws)�args)�er= r< �rr r r � get_error� s rA � 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>� � � z exactly_n.<locals>.<genexpr>)�iter�all�rangerD )�l�nr rF r � exactly_n� s $rO c C s t | �S rC )rO )rM r r r � exactly_one s rP � _get_conn� _cache_id� _exactly_onec C sJ t j| }t||t||d�� t||t|�� |dur#t||t� dS dS )z� Assign _get_conn and _cache_id functions to the named module. .. code-block:: python _utils__['boto.assign_partials'](__name__, 'ec2') r8 N)�sys�modules�setattrr9 r/ rP )�modnamer r5 Zget_conn_funcnameZcache_id_funcnameZexactly_one_funcname�modr r r � assign_funcs s �rY c o sL � |� dd�}|� dd�} | |i |��}|�|�}|V |s!dS |||< q)zRetrieve full set of values from a boto3 API call that may truncate its results, yielding each page as it is obtained. � marker_flagZ NextMarker� marker_argZMarkerTN)�popr )�functionr> �kwargsrZ r[ �ret�markerr r r � paged_call s � �ra c C sR t | ttf�rtdd� | D ��S t | t�r dd� | �� D �S t | t�r't| �S | S )Nc s s � | ]}t |�V qd S rC ��ordered)r! �xr r r rH / rI zordered.<locals>.<genexpr>c S s, i | ]\}}t |t�rt|�n|t|��qS r )r r rc r r r r r& 1 s , zordered.<locals>.<dictcomp>)r �list�tuple�sortedr r( r )�objr r r rc - s rc c C s t | �t |�kS )zCCompare two parsed JSON objects, given non-ordering in JSON objectsrb )�left�rightr r r �json_objs_equal7 s rk )NNFNNNN)NNNNNrC )rB )NrQ rR rS )-�__doc__r �loggingrT � functoolsr Zsalt.loader.contextr Zsalt.utils.stringutilsZsalt.utils.versionsZsalt.exceptionsr r Z boto3.sessionr2 Zbotocore.exceptions� getLogger�setLevel�CRITICALZHAS_BOTO� ImportError�__name__r r �loader�contextZ LoaderContextZ__salt_loader__Z named_contextr r r r r. r/ r7 r9 r: rA rO rP rY ra rc rk r r r r �<module> sd � $ �- � & �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings