File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/boto_sqs.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlZddlZddlZddlZe�e�Z ddiZ zddl Z ddl Z e�d�� ej� dZW n ey; dZY nw dd � Zd d � Zdd d �Z ddd�Zddd�Zddd�Zddd�Z ddd�ZdS )a� Connection module for Amazon SQS .. versionadded:: 2014.7.0 :configuration: This module accepts explicit sqs 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 sqs.keyid: GKTADJGHEIQSXMKKRBJ08H sqs.key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs A region may also be specified in the configuration: .. code-block:: yaml sqs.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: boto3 � N�list_�list�boto3TFc C s& t jj�� } | du rtd td� | S )z- Only load if boto3 libraries exist. Tzboto3.assign_funcsZsqs)�salt�utilsZversionsZcheck_boto_reqs� __utils__�__name__)Z has_boto_reqs� r �I/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/boto_sqs.py� __virtual__H s r c s6 t | t�r tjj�| �} dd� � � fdd�| �� D �S )zC Pre-process incoming queue attributes before setting them c S s t | t�r tjj�| �S | S )N)� isinstance�dictr r �json�dumps)�valr r r � stringifiedY s z+_preprocess_attributes.<locals>.stringifiedc s i | ] \}}|� |��qS r r )�.0�attrr �r r r � <dictcomp>` s z*_preprocess_attributes.<locals>.<dictcomp>)r �strr r r �loads�items)� attributesr r r �_preprocess_attributesR s r c C s� t ||||d�}z |j| d� W dd iS tjjyG } z&d}|j�di ��d�|kr5ddiW Y d}~S d td |�iW Y d}~S d}~ww ) z� Check to see if a queue exists. CLI Example: .. code-block:: bash salt myminion boto_sqs.exists myqueue region=us-east-1 ��region�key�keyid�profile�� QueueNamez'AWS.SimpleQueueService.NonExistentQueue�ErrorZCode�resultFN�error�boto3.get_errorT)� _get_conn� get_queue_url�botocore� exceptions� ClientError�response�getr )�namer r r r �conn�eZ missing_coder r r �existsc s � ��r0 c C sv t ||||d�}|du ri }t|�}z |j| |d� W ddiS tjjy: } zdtd |�iW Y d}~S d}~ww )z� Create an SQS queue. CLI Example: .. code-block:: bash salt myminion boto_sqs.create myqueue region=us-east-1 r N)r! � Attributesr$ r% r# T)r& r Z create_queuer( r) r* r )r- r r r r r r. r/ r r r �createy s � ��r2 c C sp t ||||d�}z|j| d�d }|j|d� W dd iS tjjy7 } zdtd |�iW Y d}~S d}~ww ) z� Delete an SQS queue. CLI Example: .. code-block:: bash salt myminion boto_sqs.delete myqueue region=us-east-1 r r �QueueUrl)r3 r$ r% Nr# T)r& r' Z delete_queuer( r) r* r )r- r r r r r. �urlr/ r r r �delete� s � ��r5 � c s� t ||||d�}dd� � z|j| d�}|�dg �}d� fdd�|D �iW S tjjy@ } zd td |�iW Y d }~S d }~ww ) z� Return a list of the names of all visible queues. .. versionadded:: 2016.11.0 CLI Example: .. code-block:: bash salt myminion boto_sqs.list region=us-east-1 r c S s t j�| �j�d�d S )N�/� )�urllib�parse�urlparse�path�split)Z queue_urlr r r � extract_name� s zlist_.<locals>.extract_name)ZQueueNamePrefixZ QueueUrlsr# c s g | ]}� |��qS r r )r r4 �r> r r � <listcomp>� s zlist_.<locals>.<listcomp>r$ r% N)r& Z list_queuesr, r( r) r* r ) �prefixr r r r r. �rZurlsr/ r r? r r � s ��c C sx t ||||d�}z|j| d�d }|j|dgd�}d|d iW S tjjy; } zdtd |�iW Y d }~S d }~ww ) z� Return attributes currently set on an SQS queue. CLI Example: .. code-block:: bash salt myminion boto_sqs.get_attributes myqueue r r r3 ZAll)r3 ZAttributeNamesr# r1 r$ r% N)r& r' Zget_queue_attributesr( r) r* r ) r- r r r r r. r4 rB r/ r r r �get_attributes� s ��rC c C sz t ||||d�}t|�}z|j| d�d }|j||d� W dd iS tjjy< } zdtd |�iW Y d}~S d}~ww ) z� Set attributes on an SQS queue. CLI Example: .. code-block:: bash salt myminion boto_sqs.set_attributes myqueue '{ReceiveMessageWaitTimeSeconds: 20}' region=us-east-1 r r r3 )r3 r1 r$ r% Nr# T)r& r r' Zset_queue_attributesr( r) r* r ) r- r r r r r r. r4 r/ r r r �set_attributes� s � ��rD )NNNN)NNNNN)r6 NNNN)�__doc__�logging� urllib.parser9 Zsalt.utils.jsonr Zsalt.utils.versions� getLoggerr �logZ__func_alias__r r( �setLevel�CRITICALZ HAS_BOTO3� ImportErrorr r r0 r2 r5 r rC rD r r r r �<module> sB / � � � �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings