| Server IP : 198.38.94.13 / Your IP : 216.73.217.33 Web Server : Apache System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : revivere ( 1140) PHP Version : 8.2.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/__pycache__/ |
Upload File : |
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 �
$
�-
�
&
�