File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/boto_dynamodb.cpython-310.pyc
Back
o ;j�; � @ s~ d Z ddlZddlZddlZddlmZ e�e�Z e�d�� ej � z9ddl Z ddl Z ddlZ ddlZddlmZmZmZmZmZmZ ddlmZ ddlmZ e�d�� ej � dZW n e yf d ZY nw e�e�Z d d � Z d"d d �Z d"dd�Z d"dd�Z d#dd�Z!d"dd�Z"d"dd�Z# d$dd�Z$ d"dd�Z% d"d d �Z&d"d d �Z'd%d d!�Z(dS )&a� Connection module for Amazon DynamoDB .. versionadded:: 2015.5.0 :configuration: This module accepts explicit DynamoDB credentials but can also utilize IAM roles assigned to the instance through Instance Profiles. Dynamic credentials are then automatically obtained from AWS API and no further configuration is necessary. More Information available at: .. code-block:: text http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/iam-roles-for-amazon-ec2.html If IAM roles are not used you need to specify them either in a pillar or in the minion's config file: .. code-block:: yaml keyid: GKTADJGHEIQSXMKKRBJ08H key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs A region may also be specified in the configuration: .. code-block:: yaml region: us-east-1 If a region is not specified, the default is us-east-1. It's also possible to specify key, keyid and region via a profile, either as a passed in dict, or as a string to pull from pillars or minion config: .. code-block:: yaml myprofile: keyid: GKTADJGHEIQSXMKKRBJ08H key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs region: us-east-1 :depends: boto � N)�SaltInvocationError�boto)�AllIndex�GlobalAllIndex�GlobalIncludeIndex�GlobalKeysOnlyIndex�HashKey�RangeKey)�Table)�JSONResponseErrorTFc C s* t jj�� } | du rtd tdtd� | S )z, Only load if boto libraries exist. Tzboto.assign_funcsZ dynamodb2)�pack)�salt�utilsZversionsZcheck_boto_reqs� __utils__�__name__Z__salt__)Z has_boto_reqs� r �N/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/boto_dynamodb.py� __virtual__U s r c C s* t d d||||d�}d}d}g }|r�z,t�d| � d} | dur8|j| | d �} || �d g �7 }| �d �} | dus d d � |D �W S tjjyS } ztt | ���d} ~ w tjj y� } z2|r| j �di ��d�dkr|d8 }t�d|� t � |� W Y d} ~ qt�d| | j� W Y d} ~ dS d} ~ ww dS )a) Returns a dictionary of all tags currently attached to a given resource. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.list_tags_of_resource resource_arn=arn:aws:dynamodb:us-east-1:012345678901:table/my-table .. versionadded:: 3006.0 �boto3.get_connection�dynamodb��region�key�keyid�profile� � z Garnering tags of resource %s� N)� ResourceArn� NextToken�Tagsr c S s i | ] }|d |d �qS �ZKeyZValuer )�.0�tagr r r � <dictcomp>~ � z)list_tags_of_resource.<locals>.<dictcomp>�Error�Code� Throttling� �/Throttled by AWS API, retrying in %s seconds...z'Failed to list tags for resource %s: %sF)r �log�debug�list_tags_of_resource�get�botocore� exceptions�ParamValidationErrorr �str� ClientError�response�time�sleep�error�message) � resource_arnr r r r �conn3�retriesr6 �tags�marker�ret�errr r r r- _ sD � � � � ����r- c C s t d d||||d�}d}d}t|t�r dd� |�� D �}|r�zt�d| � |j| |d � W d S tjj yC } zt t | ���d } ~ w tjj y� } z2|ro| j �d i ��d �dkro|d8 }t�d|� t�|� W Y d } ~ q t�d| | j� W Y d } ~ dS d } ~ ww d S )aK Sets given tags (provided as list or dict) on the given resource. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.tag_resource resource_arn=arn:aws:dynamodb:us-east-1:012345678901:table/my-table tags='{Name: my-table, Owner: Ops}' .. versionadded:: 3006.0 r r r r r c S s g | ] \}}||d ��qS )r! r )r" r �valr r r � <listcomp>� r% z tag_resource.<locals>.<listcomp>zSetting tags on resource %s)r r TNr& r' r( r) r* z%Failed to set tags on resource %s: %sF)r � isinstance�dict�itemsr+ r, � tag_resourcer/ r0 r1 r r2 r3 r4 r. r5 r6 r7 r8 ) r9 r< r r r r r: r; r6 r? r r r rE � s8 � � ����rE c C s� t d d||||d�}d}d}|ruzt�d| � |j| |d�} W dS tjjy5 } ztt| ���d } ~ w tjj yt } z2|ra| j � d i �� d �d kra|d 8 }t�d|� t � |� W Y d } ~ qt�d| | j� W Y d } ~ dS d } ~ ww d S )a? Removes given tags (provided as list) from the given resource. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.untag_resource resource_arn=arn:aws:dynamodb:us-east-1:012345678901:table/my-table tag_keys='[Name, Owner]' .. versionadded:: 3006.0 r r r r r z Removing tags from resource %s)r ZTagKeysTNr& r' r( r) r* z*Failed to remove tags from resource %s: %sF)r r+ r, �untag_resourcer/ r0 r1 r r2 r3 r4 r. r5 r6 r7 r8 ) r9 Ztag_keysr r r r r: r; r6 r> r? r r r rF � s4 � � ����rF c C s g } g }d}|r t ||d�}| �|� |�|� ||7 }| r6t| | d�}| �|� |�|� |d7 }|| 7 }|d7 }||d�}g }| rO| D ] }|�t|�� qEg }| ra| D ] }|�t|dd�� qUt||||d�}tj| | ||||d � d }t|�D ]}t| ||||�r� dS t � d � qzd S ) a\ Creates a DynamoDB table. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.create_table table_name / region=us-east-1 / hash_key=id / hash_key_data_type=N / range_key=created_at / range_key_data_type=N / read_capacity_units=1 / write_capacity_units=1 r �Z data_type�_�_index��read�writeT)� global_indexr )�schema� throughputZindexes�global_indexes� connection� r) F) r �appendr � extract_index� _get_connr �create�range�existsr5 r6 )� table_namer r r r �read_capacity_units�write_capacity_units�hash_key�hash_key_data_type� range_key�range_key_data_typeZ local_indexesrP rN Zprimary_index_fieldsZprimary_index_nameZ hash_key_objZ range_key_objrO Zlocal_table_indexes�indexZglobal_table_indexes�conn� MAX_ATTEMPTS�ir r r � create_table� sN � rd c C sT zt ||||d�}|�| � W dS ty) } z |jdkr$W Y d}~dS � d}~ww )z� Check to see if a table exists. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.exists table_name region=us-east-1 r ZResourceNotFoundExceptionNFT)rU Zdescribe_tabler Z error_code)rY r r r r ra �er r r rX + s � ��rX c C sZ t ||||d�}t| |d�}|�� d}t|�D ]}t| ||||�s% dS t�d� qdS )z� Delete a DynamoDB table. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.delete table_name region=us-east-1 r �rQ rR Tr) F)rU r �deleterW rX r5 r6 ) rY r r r r ra �tablerb rc r r r rg @ s rg c C s* t ||||d�}t| |d�}|j||d�S )z� Update a DynamoDB table. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.update table_name region=us-east-1 r rf )rO rP )rU r �update) rY rO rP r r r r ra rh r r r ri Z s ri c C �& t ||||d�}t| |d�}|�|�S )z� Creates a single global secondary index on a DynamoDB table. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.create_global_secondary_index table_name / index_name r rf )rU r � create_global_secondary_index)rY rM r r r r ra rh r r r rk q � rk c C rj )z� Updates the throughput of the given global secondary indexes. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.update_global_secondary_index table_name / indexes r rf )rU r � update_global_secondary_index)rY rP r r r r ra rh r r r rm � rl rm c C s$ t ||||d�}t| |d�}|�� S )z� Describe a DynamoDB table. CLI Example: .. code-block:: bash salt myminion boto_dynamodb.describe table_name region=us-east-1 r rf )rU r �describe)rY r r r r ra rh r r r rn � s rn c C s� i }g }| � � D ]b\}}|D ][}|� � D ]T\}}|dkr!||d< q|dkr*||d< q|dkr3||d< q|dkr<||d< q|dkrE||d< q|dkrN||d< q|dkrW||d< q|dkr`||d< q|d krhd |d < qqq|d r||�t|d |d d �� |�d�r�|�t|d |d d �� |r�|d r�|d r�|d |d d �|d < |d r�|r�|r�|�d �r�|�d�r�td��|�d�r�t|d ||d |d d�S |�d �r�t|d ||d d�S t|d ||d d�S t |d |d�S dS dS )z� Instantiates and returns an AllIndex object given a valid index configuration CLI Example: .. code-block:: bash salt myminion boto_dynamodb.extract_index index r\ r] r^ r_ �namerZ r[ �includesZ keys_onlyTrG rJ rO z,Only one type of GSI projection can be used.)�partsrO rp )rq rO )rq N) rD rS r r. r r r r r r ) Z index_datarM Z parsed_data�keysr �value�item�field�datar r r rT � s� ��� �� ����� � � � ���rT )NNNN) NNNNNNNNNNNN)NNNNNN)F))�__doc__�loggingr5 Zsalt.utils.versionsr Zsalt.exceptionsr � getLoggerr r+ �setLevel�INFOr Zboto3Zboto.dynamodb2r/ Zboto.dynamodb2.fieldsr r r r r r Zboto.dynamodb2.tabler Zboto.exceptionr ZHAS_BOTO� ImportErrorr r- rE rF rd rX rg ri rk rm rn rT r r r r �<module> sn . � � .) �* � N � � �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings