File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/aws_sqs.cpython-310.pyc
Back
o ;j � @ s� d Z ddlZddlZddlZe�e�ZdZdd� Z dd� Z dd � Z dd d �Z dd d�Z ddd�Zddd�Zddd�Zddd�Zdd� ZdS )z. Support for the Amazon Simple Queue Service. � Nz --output jsonc C s t jj�d�r dS dS )NZawsT)Fz=The module aws_sqs could not be loaded: aws command not found)�salt�utils�path�which� r r �H/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/aws_sqs.py� __virtual__ s r c C s d| � �S )z% Return the region argument. z --region r )�regionr r r �_region s r c K s� |� dd�}|r ||d< |� dd�}|r||d< dd� |�� D �}dj| d �|�t|�td �} td | |d d �}|rAtjj � |�S dS )z� Runs the given command against AWS. cmd Command to run region Region to execute cmd in opts Pass in from salt user Pass in from salt kwargs Key-value arguments to pass to the command � receipthandleNzreceipt-handle�numzmax-number-of-messagesc S s" g | ] \}}d |� d|� d��qS )z--z "�"r )�.0�k�vr r r � <listcomp>4 s " z _run_aws.<locals>.<listcomp>z#aws sqs {cmd} {args} {region} {out}� )�cmd�argsr �outzcmd.runF)ZrunasZ python_shell� ) �pop�items�format�joinr �_OUTPUTZ__salt__r r �json�loads) r r �opts�user�kwargsr r Z_formatted_args�rtnr r r �_run_aws s �r" � c C s\ ddi}t |||�}t|�}| |vrt�d| � |S td||||| |d�}|d |d< |S )aU Receive one or more messages from a queue in a region queue The name of the queue to receive messages from region Region where SQS queues exists num : 1 The max number of messages to receive opts : None Any additional options to add to the command line user : None Run as a user other than what the minion runs as CLI Example: .. code-block:: bash salt '*' aws_sqs.receive_message <sqs queue> <region> salt '*' aws_sqs.receive_message <sqs queue> <region> num=10 .. versionadded:: 2014.7.0 ZMessagesN�"%s" queue does not exist.zreceive-message)�queuer �� list_queues�_parse_queue_list�log�infor" ) r% r r r r �ret�queues�url_mapr r r r �receive_message? s � r. c C sH t |||�}t|�}| |vrt�d| � dS td|||||| d�}dS )a� Delete one or more messages from a queue in a region queue The name of the queue to delete messages from region Region where SQS queues exists receipthandle The ReceiptHandle of the message to delete. The ReceiptHandle is obtained in the return from receive_message opts : None Any additional options to add to the command line user : None Run as a user other than what the minion runs as CLI Example: .. code-block:: bash salt '*' aws_sqs.delete_message <sqs queue> <region> receipthandle='<sqs ReceiptHandle>' .. versionadded:: 2014.7.0 r$ Fzdelete-message)r r% Tr& )r% r r r r r, r- r r r r �delete_messagej s �r/ c C s t d| ||�}d|d d�}|S )aW List the queues in the selected region. region Region to list SQS queues for opts : None Any additional options to add to the command line user : None Run hg as a user other than what the minion runs as CLI Example: .. code-block:: bash salt '*' aws_sqs.list_queues <region> z list-queuesr Z QueueUrls)�retcode�stdout�r" )r r r r r+ r r r r' � s �r' c C s2 d| i}t d |||d�|��}d|d dd�}|S ) a� Creates a queue with the correct name. name Name of the SQS queue to create region Region to create the SQS queue in opts : None Any additional options to add to the command line user : None Run hg as a user other than what the minion runs as CLI Example: .. code-block:: bash salt '*' aws_sqs.create_queue <sqs queue> <region> z queue-name� create-queue�r r r r ZQueueUrlr �r0 r1 �stderrN)r3 r2 )�namer r r �creater r+ r r r � create_queue� s �r9 c C s� t |||�}t|�}t�d|� | |v r/d|| i}td|||d�|��}d}d} | � d�} nd} d} d }|r9d nd | | d �} | S )a� Deletes a queue in the region. name Name of the SQS queue to deletes region Name of the region to delete the queue from opts : None Any additional options to add to the command line user : None Run hg as a user other than what the minion runs as CLI Example: .. code-block:: bash salt '*' aws_sqs.delete_queue <sqs queue> <region> zmap %sz queue-url� delete-queuer4 Tr z deletedz Delete failedFr r# r5 N)r: )r' r( r) �debugr" ) r7 r r r r, r- �deleter! �success�errr r+ r r r � delete_queue� s" �r? c C s t |||�}| t|�v S )a� Returns True or False on whether the queue exists in the region name Name of the SQS queue to search for region Name of the region to search for the queue in opts : None Any additional options to add to the command line user : None Run hg as a user other than what the minion runs as CLI Example: .. code-block:: bash salt '*' aws_sqs.queue_exists <sqs queue> <region> )r' r( )r7 r r r �outputr r r � queue_exists s rA c C s dd� | d D �}|S )z6 Parse the queue to get a dict of name -> URL c S s i | ] }|� d �d |�qS )�/���)�split)r �qr r r � <dictcomp>' s z%_parse_queue_list.<locals>.<dictcomp>r1 r )Z list_outputr, r r r r( # s r( )r# NN)NN)�__doc__�loggingZsalt.utils.jsonr Zsalt.utils.path� getLogger�__name__r) r r r r" r. r/ r' r9 r? rA r( r r r r �<module> s " + . # /
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings