| Server IP : 3.96.16.70 / Your IP : 216.73.216.15 Web Server : Apache System : Linux ip-172-31-26-103.ca-central-1.compute.internal 6.1.163-186.299.amzn2023.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Feb 24 16:35:42 UTC 2026 x86_64 User : ec2-user ( 1000) PHP Version : 8.4.18 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /lib/python3.9/site-packages/cfnbootstrap/__pycache__/ |
Upload File : |
a
��0i�$ � @ s� d Z ddlmZ ddlmZ ddlmZmZ ddlmZ ddl m
Z
ddl Z ddl Z ddl
mZmZ e �d �ZG d
d � d ej�ZG d d
� d
e�ZdS )z�
SQS client-related classes
Classes:
SQSClient - an HTTP client that makes API calls against SQS
Message - a message from an SQS queue
� )�
aws_client)�V4Signer)�retry_on_failure�timeout)�
endpoint_tool)� ElementTreeN)�StringIO�BytesIOz
cfn.clientc s� e Zd ZdZdZde Zd� fdd� Zdd � Zed
d � �Z ed d
� �Z
e e j
�e�d�ed�ddd���Ze de j
�e�d�e� ddd���Ze e j
�e�d�e� d dd���Z� ZS ) � SQSClientaO
Makes API calls against SQS
Notes:
- Public methods of this class have a 1-to-1 equivalence to published SQS APIs.
- Calls are retried internally when appropriate; callers should not retry.
Attributes:
_apiVersion - the SQS API version
_xmlns - the XML namespace for the SQS API version in use
z
2012-11-05�"http://queue.amazonaws.com/doc/%s/N� us-east-1c sp |st �|�}n
| �|�}|s(t �|�}|s4td��t|d�}tt | �j|d||dt j |d� t �
d|� d S )Nz(Region is required for AWS V4 SignaturesZsqsFr )�signer�xmlns� proxyinfoz'SQS client initialized with endpoint %s) r
�endpointForRegion�
_fix_endpoint�regionForEndpoint�
ValueErrorr �super�__init__� _apiVersion�log�debug)�selfZ credentials�url�regionr �endpointr
�� __class__� �;/usr/lib/python3.9/site-packages/cfnbootstrap/sqs_client.pyr 5 s
�zSQSClient.__init__c C s� t �tj|�pt �tj|�}|r�t�d�D ]V}|j|�d�kr*|j}|� d�rj|�d��
d�rj|d d� }d||�d�f S q*dtj |�d�|�d�f S |S )N� AmazonSQS� �.cn� ���z https://%s%s�https://) �re�matchr � SQS_PATTERN�SQS_LEGACY_PATTERN�get_endpoints_for_servicer �group�hostname�endswith�
startswith�
SQS_FORMAT)r Z unparsed_url�mr Zfixed_hostnamer r r r J s � zSQSClient._fix_endpointc C sH t �d�D ] }|j|kr
d|j S q
dt j||�d�r>dndf S )Nr! �
https://%sr& Zcnr# � )r r+ r r- r0 r/ )�clsr r r r r r X s
zSQSClient.endpointForRegionc C sV t �d�D ] }|d|j kr
|j S q
t�t j|�pBt�t j|�}|rR|�d�S d S )Nr! r2 r" ) r r+ r- r r' r( r) r* r, )r4 Z
parsed_urlr r1 r r r r _ s �
zSQSClient.regionForEndpoint)�http_error_extractor�< r" c
C s� |s
dg}| � |�}t�d|� dtjt|�d�}tt|��D ]}|| |d|d < q>|rht|�|d< |rxt|�|d< | j||||r�|d nd
d �j �
d �} t � t
| �| j�S )
zs
Calls ReceiveMessage and returns a list of Message objects
Throws an IOError on failure.
ZAllz Receiving messages for queue %sZReceiveMessage)�Action�VersionZMaxNumberOfMessageszAttributeName.%sr" ZVisibilityTimeoutZWaitTimeSeconds� N)r �utf-8)r r r r
r �str�range�len�_call�content�decode�Message� _parse_listr �_xmlns)
r � queue_url�
attributesZ max_messagesZvisibility_timeout�request_credentialsZ wait_time�params�iZresponse_contentr r r �receive_messagej s0
� ��
�zSQSClient.receive_message� )Z max_triesr5 c C s� | � |�}t�d||� dtj|d�}|r2||d< tjt| j|||dd�j� d��d�}|�
d | j | j f �}|�
d
| j | j f �}||fS ) z
Calls SendMessage and returns a tuple of (MessageId, MD5OfMessageBody)
Throws an IOError on failure.
zSending %s to queue %sZ SendMessage)r7 r8 Z MessageBodyZ DelaySecondsZPOST)Zverbr: ��filez#{%s}SendMessageResult/{%s}MessageIdz*{%s}SendMessageResult/{%s}MD5OfMessageBody) r r r r
r r r r> r? r@ �findtextrC ) r rD Z message_bodyZ
delay_secondsrF rG �root�
message_id� md5_of_bodyr r r � send_message� s&
�
��
��zSQSClient.send_messagec C s8 | � |�}t�d||� dtj|d�}| �|||� dS )zj
Calls DeleteMessage on a specified receipt handle
Throws an IOError on failure.
zDeleting %s from queue %sZ
DeleteMessage)r7 r8 Z
ReceiptHandleN)r r r r
r r> )r rD �receipt_handlerF rG r r r �delete_message� s
�zSQSClient.delete_message)Nr N)Nr" NNN)NN)N)�__name__�
__module__� __qualname__�__doc__r rC r r � classmethodr r r r �ClientZ_get_xml_extractorr rI rQ rS �
__classcell__r r r r r
$ s(
� r
c @ s| e Zd ZdZedd� �Zedd� �Zdd� Zdd � Zd
d � Z e
d d
� �Z e
dd� �Z e
dd� �Z
e
dd� �Ze
dd� �ZdS )rA z A message off of an SQS queuec s: |sg S t j |d�}|�d��f �}� �fdd�|D �S )NrK z${%s}ReceiveMessageResult/{%s}Messagec s g | ]}� � |���qS r )�
_from_elem)�.0�elem�r4 r r r �
<listcomp>� � z'Message._parse_list.<locals>.<listcomp>)r �findall)r4 �datar rN Zmsgsr r^ r rB � s
�zMessage._parse_listc C sl i }|� d| �D ] }|�d| �||�d| �< qt|�d| �|�d| �|�d| �|�d| �|�S )Nz
{%s}Attributez {%s}Valuez{%s}Namez
{%s}MessageIdz{%s}ReceiptHandlez
{%s}MD5OfBodyz{%s}Body)ra rM rA )r4 r] r �attribsZattribr r r r[ � s � �zMessage._from_elemc C s& || _ || _|| _|| _t|�| _d S �N)� _message_id�_receipt_handle� _md5_of_body�_body�dict� _attributes)r Zmsg_idZhandleZmd5�bodyrc r r r r � s
zMessage.__init__c C s | � � S rd )�__str__�r r r r �__repr__� s zMessage.__repr__c C s d| j | j| j| j| jf S )NzMMessage[MessageId:%s, ReceiptHandle:%s, MD5OfBody:%s, Body:%s, Attributes:%s])rO rR rP rk rE rm r r r rl � s �zMessage.__str__c C s | j S rd )re rm r r r rO � s zMessage.message_idc C s | j S rd )rf rm r r r rR � s zMessage.receipt_handlec C s | j S rd )rg rm r r r rP � s zMessage.md5_of_bodyc C s | j S rd )rh rm r r r rk � s z Message.bodyc C s | j S rd )rj rm r r r rE � s zMessage.attributesN)rT rU rV rW rX rB r[ r rn rl �propertyrO rR rP rk rE r r r r rA � s$
rA )rW Z cfnbootstrapr Zcfnbootstrap.aws_clientr Zcfnbootstrap.utilr r r Z xml.etreer Zloggingr' �ior r Z getLoggerr rY r
�objectrA r r r r �<module> s