CURRENT PATH:
/
usr
/
lib
/
python3.9
/
site-packages
/
S3
/
__pycache__
/
[ ⬅ KEMBALI ]
|
[ HOME ]
Upload File:
Upload Ke Sini
Dir Baru
File Baru
Editing:
CloudFront.cpython-39.pyc
a �9peӒ � @ s� d dl mZ d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z m Z m Z m Z zd dl m mZ W n ey� d dlmZ Y n0 ddlmZ ddlmZ dd lmZmZ dd lmZmZmZ dd l m Z m Z m Z m Z m!Z!m"Z" dd l#m$Z$m%Z%m&Z&m'Z' dd l(m)Z) ddl*m*Z*m+Z+ ddl,m,Z, ddl-m-Z- ej.dkZ/dZ0dde0i Z1dd� Z2dd� Z3G dd� de4�Z5G dd � d e4�Z6G d d � d e4�Z7G d d � d e4�Z8G d!d"� d"e4�Z9G d#d$� d$e4�Z:G d%d&� d&e4�Z;G d'd(� d(e4�Z<G d)d*� d*e4�Z=dS )+� )�absolute_importN)� defaultdict)�datetime)�debug�info�warning�error� )�S3)�Config)�CloudFrontError�ParameterError)�EX_OK� EX_GENERAL� EX_PARTIAL)�getTreeFromXml�appendXmlTextNode�getDictFromTree�dateS3toPython� encode_to_s3�decode_from_s3)�getBucketFromHostname�getHostnameFromBucket� deunicodise� convertHeaderTupleListToDict)�sign_string_v2)�S3Uri�S3UriS3)�ConnMan)� SortedDict)� r z 2010-11-01z/%(api_ver)s/distribution�api_verc C s t j�| d � d S )N� )�sys�stdout�write)�message� r' �1/usr/lib/python3.9/site-packages/S3/CloudFront.py�output, s r) c C s" d| � d�} td| |f � d S )Nz%s:� z%s %s)�ljustr) )Zlabelr& r' r' r( � pretty_output/ s r, c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�DistributionSummaryc C s& |j dkrtd|j ��| �|� d S )Nr- z1Expected <DistributionSummary /> xml, got: <%s />)�tag� ValueError�parse��self�treer' r' r( �__init__E s z DistributionSummary.__init__c C sT t |�| _| jd �� dk| jd< d| jv rPt| jd �tkrP| jd g| jd< d S )N�Enabled�true�CNAME)r r �lower�type�listr1 r' r' r( r0 J s zDistributionSummary.parsec C s t d| jd �S �Nzcf://%s�Id�r r �r2 r' r' r( �uriP s zDistributionSummary.uriN��__name__� __module__� __qualname__r4 r0 r? r' r' r' r( r- 4 s r- c @ s e Zd Zdd� Zdd� ZdS )�DistributionListc C s. t |�}|jdkr td|j ��| �|� d S )NrD z.Expected <DistributionList /> xml, got: <%s />�r r. r/ r0 �r2 Zxmlr3 r' r' r( r4 _ s zDistributionList.__init__c C sL t |�| _| jd �� dk| jd< g | _|�d�D ]}| j�t|�� q2d S )N� IsTruncatedr6 z.//DistributionSummary)r r r8 � dist_summs�findall�appendr- )r2 r3 Z dist_summr' r' r( r0 e s zDistributionList.parseN)rA rB rC r4 r0 r' r' r' r( rD S s rD c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� Distributionc C s. t |�}|jdkr td|j ��| �|� d S )NrK z*Expected <Distribution /> xml, got: <%s />rE rF r' r' r( r4 { s zDistribution.__init__c C s8 t |�| _t| jd �| jd< t|�d�d�| jd< d S )NZLastModifiedTimez.//DistributionConfig)r3 �DistributionConfig)r r r rL �findr1 r' r' r( r0 � s zDistribution.parsec C s t d| jd �S r; r= r> r' r' r( r? � s zDistribution.uriNr@ r' r' r' r( rK n s rK c @ sF e Zd ZdZddei Zddd�Zdd� Zd d � Zd d � Z d d� Z dS )rL zq<DistributionConfig><S3Origin><DNSName/></S3Origin><CallerReference/><Enabled>true</Enabled></DistributionConfig>z0http://cloudfront.amazonaws.com/doc/%(api_ver)s/r! Nc C sD |d u rt j}|d u r t|�}|jdkr6td|j ��| �|� d S )NrL z0Expected <DistributionConfig /> xml, got: <%s />)rL � EMPTY_CONFIGr r. r/ r0 rF r' r' r( r4 � s zDistributionConfig.__init__c C s t |�| _| jd �� dk| jd< d| jvr6g | jd< t| jd �tkrZ| jd g| jd< dd� | jd D �| jd< d| jvr�d| jd< d| jvr�d| jd< |�d �}|r�t |d �}t|d �\|d < }|s�td |d � td | �| jd< n d | jd< d S )Nr5 r6 r7 c S s g | ] }|� � �qS r' )r8 )�.0�cnamer' r' r( � <listcomp>� � z,DistributionConfig.parse.<locals>.<listcomp>�Comment� �DefaultRootObjectz .//Loggingr �Bucketz%Logging to unparsable bucket name: %szs3://%(Bucket)s/%(Prefix)s�Logging) r r r8 r9 r: rI r r r )r2 r3 Z logging_nodesZ logging_dict�successr' r' r( r0 � s& zDistributionConfig.parsec C s t �d�}tj|jd< tdd|�}td| jd d |� td| jd |� | jd D ]}td|�� |� qT| jd r�td| jd |� td t| jd ��� |� t| jd �r�td t| jd �|� | jd �rt �d �}td t | jd � � �|� td | jd � � |� |� |� |S )NrL �xmlns�S3OriginrT �DNSName�CallerReferencer7 rS r5 rU rW rV ZPrefix) �ET�ElementrL rY Zattribr r r8 �strr �bucket�objectrJ )r2 r3 Zs3orgrP Z logging_elr' r' r( �get_printable_tree� s$ z%DistributionConfig.get_printable_treec C s t t�| �� ��S �N�r r] �tostringrb r> r' r' r( � __unicode__� s z DistributionConfig.__unicode__c C s( t rtj| �� dd�S t�| �� �S d S �NZunicode)�encoding��PY3r] re rb r> r' r' r( �__str__� s zDistributionConfig.__str__)NN) rA rB rC rN �cloudfront_api_versionrY r4 r0 rb rf rk r' r' r' r( rL � s rL c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� Invalidationc C s. t |�}|jdkr td|j ��| �|� d S )Nrm z*Expected <Invalidation /> xml, got: <%s />rE rF r' r' r( r4 � s zInvalidation.__init__c C s t |�| _d S rc �r r r1 r' r' r( r0 � s zInvalidation.parsec C s t | j�S rc �r_ r r> r' r' r( rk � s zInvalidation.__str__N�rA rB rC r4 r0 rk r' r' r' r( rm � s rm c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�InvalidationListc C s. t |�}|jdkr td|j ��| �|� d S )Nrq z.Expected <InvalidationList /> xml, got: <%s />rE rF r' r' r( r4 s zInvalidationList.__init__c C s t |�| _d S rc rn r1 r' r' r( r0 s zInvalidationList.parsec C s t | j�S rc ro r> r' r' r( rk s zInvalidationList.__str__Nrp r' r' r' r( rq � s rq c @ sD e Zd Zddg fdd�Zdd� Zdd� Zdd � Zd d � Zd d � ZdS )�InvalidationBatchNc C sL |r || _ n,|sd}d|t�t�� d�t�dd�f | _ g | _| �|� d S )N�0z%s.%s.%sz %Y%m%d%H%M%Si� i' )� referencer �strftimeZnow�randomZrandint�paths� add_objects)r2 rt � distributionrw r' r' r( r4 # s �zInvalidationBatch.__init__c C s | j �|� d S rc )rw �extend)r2 rw r' r' r( rx / s z InvalidationBatch.add_objectsc C s | j S rc )rt r> r' r' r( � get_reference2 s z InvalidationBatch.get_referencec C sT t �d�}| jD ]0}t|�dk s,|d dkr4d| }td||� qtd| j|� |S )Nrr r r �/�Pathr\ )r] r^ rw �lenr rt )r2 r3 �pathr' r' r( rb 5 s z$InvalidationBatch.get_printable_treec C s t t�| �� ��S rc rd r> r' r' r( rf > s z InvalidationBatch.__unicode__c C s( t rtj| �� dd�S t�| �� �S d S rg ri r> r' r' r( rk A s zInvalidationBatch.__str__) rA rB rC r4 rx r{ rb rf rk r' r' r' r( rr s rr c @ s e Zd Zddd�ddd�ddd�ddd�ddd�ddd�dd d�dd d�dd d�d � Zd Zd d� Zdd� Zg d d d fdd�Zg g d d d d fdd�Zdd� Z dd� Z dd� Z d/dd �Z d d � Z d d � Zd!d"� Zd0d#d$�Zd1d%d&�Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd S )2� CloudFrontZPOSTrT )�method�resourceZDELETEz /%(dist_id)sZGETz/%(dist_id)s/configZPUTz/%(dist_id)s/invalidationz(/%(dist_id)s/invalidation/%(request_id)s) � CreateDist� DeleteDist�GetList� GetDistInfo� GetDistConfig� SetDistConfig� Invalidate� GetInvalList� GetInvalInfoNc C s || _ d S rc )�config)r2 r� r' r' r( r4 X s zCloudFront.__init__c C s4 | � d�}t|d �|d< |d jd r0td��|S )Nr� �data� dist_listrG z3List is truncated. Ask s3cmd author to add support.)� send_requestrD r �NotImplementedError)r2 �responser' r' r( r� _ s zCloudFront.GetListc C s� t � }d|jd< |�� |jd d< t|�|jd< ||jd< |d krR|�� |jd< n ||jd< |D ](}|jd �|�d kr`|jd �|� q`|r�t|�|jd < t|�}td | � | j d |d �} t | d �| d< | S )NTr5 rZ r[ r\ rU rS r7 r rW z&CreateDistribution(): request_body: %sr� )�bodyr� ry ) rL r Z host_namer_ Z public_url�countrJ r r r� rK ) r2 r? � cnames_add�comment�logging�default_root_object� dist_configrP � request_bodyr� r' r' r( �CreateDistributiong s$ z CloudFront.CreateDistributionc C s |j dkrtd| ��td| � | �|�}|d } |d krF|| jd< |d krX|| jd< |d krj|| jd< |D ](} | jd �| �d krn| jd �| � qn|D ]*} | jd �| �d kr�| jd �| � q�q�|d kr�|d kr�d | jd < nt|�| jd < | �|| |d d �}|S )N�cf� Expected CFUri instead of: %s� Checking current status of %sr� r5 rS rU r7 r FrW �headers�etag) r9 r/ r r� r� rJ �remover r� ) r2 �cfurir� � cnames_remover� �enabledr� r� r� �dcrP r' r' r( �ModifyDistribution| s. z CloudFront.ModifyDistributionc C s� |j dkrtd| ��td| � | �|�}|d jd r�td� d|d jd< | �||d |d d �}td � td � | �|�}|d }|jd dkr�|jd dkr�td� q�td� t�d� qzt dd�}|d d |d< | j d|� � |d�}|S )Nr� r� r� r� r5 z)Distribution is ENABLED. Disabling first.Fr� r� z,Waiting for Distribution to become disabled.z+This may take several minutes, please wait.ry �StatusZDeployedz Distribution is now disabledzStill waiting...� T�Z ignore_case�if-matchr� )�dist_idr� ) r9 r/ r r� r� r r� �time�sleepr r� r� )r2 r� r� �dr� r' r' r( �DeleteDistribution� s2 � �z CloudFront.DeleteDistributionc C s< |j dkrtd| ��| jd|�� d�}t|d �|d< |S )Nr� r� r� �r� r� ry )r9 r/ r� r� rK �r2 r� r� r' r' r( r� � s zCloudFront.GetDistInfoc C s< |j dkrtd| ��| jd|�� d�}t|d �|d< |S )Nr� r� r� r� r� r� )r9 r/ r� r� rL r� r' r' r( r� � s zCloudFront.GetDistConfigc C sn |d kr"t d� | �|�d d }t d| � t|�}t d| � tdd�}||d< | jd |�� ||d �}|S ) Nz1SetDistConfig(): Etag not set. Fetching it first.r� r� zSetDistConfig(): Etag = %sz!SetDistConfig(): request_body: %sTr� r� r� )r� r� r� )r r� r_ r r� r� )r2 r� r� r� r� r� r� r' r' r( r� � s �zCloudFront.SetDistConfigc C s� |d urr|r|rrg }d| }|D ]L}|� |�s6||krb|rD|�|� |rl|�|d t|� � � q |�|� q |}| �|�} t|�dk�rznt�� } tt| �d��(} | �td� |�d �� W d � n1 s�0 Y t dt|� � t d| � W n t �y Y n0 t d��g } | D ]�} t | �� |d�}td | � | jd | �� t|�d �}| �� |d < |d dk�r�t|d �j}|d |d< td| � | �|� �q | S )Nr| i� �wr" z2Request to invalidate %d paths (max 999 supported)z"All the paths are now saved in: %sz Too many paths to invalidate)ry rw z%InvalidateObjects(): request_body: %sr� )r� r� r� �status�� r� r< � request_idz!InvalidateObjects(): response: %s)�endswithrJ r~ �get_dist_name_for_bucket�UtilsZ mktmpfile�openr r% �joinr � Exceptionr rr r� r r� r_ rm r )r2 r? rw �default_index_file� invalidate_default_index_on_cf�#invalidate_default_index_root_on_cfZ new_pathsZdefault_index_suffixr �cfurisZ tmp_filename�fpZ responsesr� Z invalbatchr� � inval_infor' r' r( �InvalidateObjects� sH 6 � z CloudFront.InvalidateObjectsc C s< |j dkrtd| ��| jd|�� d�}t|d �|d< |S )Nr� r� r� r� r� � inval_list)r9 r/ r� r� rq r� r' r' r( r� � s zCloudFront.GetInvalListc C sV |j dkrtd| ��|�� d u r*td��| jd|�� |�� d�}t|d �|d< |S )Nr� r� z Expected CFUri with Request IDr� �r� r� r� � inval_status)r9 r/ r� r� r� rm r� r' r' r( r� s zCloudFront.GetInvalInfoc C sj |d u r| j j}|d u r"tdd�}| j| }|r8d|d< | �||||�}| �� } td|d |d f � | j�|d |d ||d � | j� � } i } | j | d < | j | d < t | � � �| d< | �� | d < t�| � td | � | d d k�rBt| �} |�r>td|| f � td| �|� � t�| �|�� | j||||d d�S | �| d dk �s^| d dk�rft| ��| S )NTr� z text/plainz content-typezsend_request(): %s %sr� r� r� r� �reasonr� zCloudFront: response: %ri� z Retrying failed request: %s (%s)zWaiting %d sec...r )r� �retries�� i+ )r� � max_retriesr � operations�create_request�get_connectionr �c�requestZ getresponser� r� r Z getheaders�readr Zputr r � _fail_waitr� r� r� ) r2 Zop_namer� r� r� r� r� � operationr� �connZ http_responser� �er' r' r( r� s< zCloudFront.send_requestc C s� t |d ||d� }|s$tdd�}d|v rFd|vr@|d |d< |d= d|vrbt�dt�� �|d< t| jj�dkr�| j�� | jj|d < | � |�}d | jj d | |d < i }||d< ||d < |d |d< |S )Nr� r� Tr� �date� x-amz-datez%a, %d %b %Y %H:%M:%S +0000r zx-amz-security-tokenzAWS �:Z Authorizationr� r� ) �cloudfront_resourcer r� ru �gmtimer~ r� Z access_tokenZ role_refresh� sign_requestZ access_key)r2 r� r� r� r� r� � signaturer� r' r' r( r� 6 s* � zCloudFront.create_requestc C s, |d }t tt|���}td||f � |S )Nr� z"CloudFront.sign_request('%s') = %s)r r r r )r2 r� Zstring_to_signr� r' r' r( r� S s zCloudFront.sign_requestc C s t j| jjdd�}|S )NT)Zssl)r �getr� Zcloudfront_host)r2 r� r' r' r( r� Y s zCloudFront.get_connectionc C s | j j| d d S )Nr r )r� r� )r2 r� r' r' r( r� ] s zCloudFront._fail_waitc C sH |j dkr|gS |j dkr&td| ��td| � tjd u r�| �� }i t_|d jD ]�}d}d|jv r~t|jd d �d }n8d |jv rTt|jd d �d }|d t |� � �� }nqTtj� |d �d u r�t � tj|< tj| � |�� � qTtd tj � ztj|� � W S t�yB } z t|� td | ��W Y d }~n d }~0 0 d S ) Nr� �s3z,CloudFront or S3 URI required instead of: %sz _get_dist_name_for_bucket(%r)r� rT rZ r[ r � CustomOriginz dist_list: %sz>Unable to translate S3 URI to CloudFront distribution name: %s)r9 r r r� r� r� rH r r r~ r` r� �set�addr? r� )r2 r? r� r� Z distListIndexr� r' r' r( r� a s2 z#CloudFront.get_dist_name_for_bucket)N)NNNNN)NNN)rA rB rC r� r� r4 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r' r' r' r( r� I s> � � . % r� c @ sz e Zd ZdZG dd� de�Ze� Zedd� �Zedd� �Z edd � �Z ed d � �Z ed d � �Z edd� �Z edd� �ZdS )�Cmdz3 Class that implements CloudFront commands c @ s4 e Zd Zg Zg ZdZdZdZdZdd� Z dd� Z dS )z Cmd.OptionsNc C s dd� t | �D �S )Nc S s g | ]}|� d �r|�qS )Zcf_)� startswith)rO �optr' r' r( rQ � rR z+Cmd.Options.option_list.<locals>.<listcomp>)�dirr> r' r' r( � option_list� s zCmd.Options.option_listc C s t tj||� d S rc )�setattrr� �options)r2 �option�valuer' r' r( � update_option� s zCmd.Options.update_option) rA rB rC � cf_cnames_add�cf_cnames_remove� cf_comment� cf_enable� cf_logging�cf_default_root_objectr� r� r' r' r' r( �Options� s r� c C s4 t t� �}g }| D ] }|�t|��}|�|� q|S rc )r� r r� r rz )�argsr� r� �argZurisr' r' r( � _parse_args� s zCmd._parse_argsc C s t t� �}| s�|�� }|d jD ]�}d|jv rDt�|jd d �}n"d|jv rbd|jd d }nd}td|� td|�� � td |jd � d |jv r�td d � |jd �� td |jd � td|jd � t d� q �n*t � | �}|D �]}|� |�}|d }|jd }d|jv �r.t�|jd d �}n$d|jv �rNd|jd d }nd}td|� td|�� � td |jd � d |jv �r�td d � |jd �� td |jd � td|jd � td|jd � td|jd � td|jd �p�d� td|d d � q�d S )Nr� rZ r[ r� z http://%s/z <unknown>�Origin�DistId� DomainNamer7 �CNAMEs�, r� r5 rT ry rL rS ZDfltRootObjectrU rW ZDisabled�Etagr� r� )r� r r� rH r r �httpurl_to_s3urir, r? r� r) r� r� r� )r� r� r� r� �originr� r� r� r' r' r( r � sL zCmd.infoc C sh t t� �}g }| D ]P}t|�}|jdkr4td| ��|�� rHtd| ��|�� sXtd��|�|� q|sptd��|D ]�}td| � |j |t j j t j j t j jt j jd�}|d }|jd }td � td t�|jd d �� td|�� � td|jd � tdd�|jd �� td|jd � td|jd � td|jd � td|jd � td|d d � qtd S )Nr� z@Distribution can only be created from a s3:// URI instead of: %sz4Use s3:// URI with a bucket name only instead of: %sz3CloudFront can only handle lowercase-named buckets.zNo valid bucket names foundz Creating distribution from: %s)r� r� r� r� ry rL zDistribution created:r� rZ r[ r� r� r� r� r7 rS r� r5 rU r� r� r� )r� r r r9 r ra Zis_dns_compatiblerJ r r� r� r� r� r� r� r� r) r, r r� r? r� )r� r� Zbucketsr� r? r� r� r� r' r' r( �create� s@ � z Cmd.createc C sX t t� �}t�| �}|D ]:}|�|�}|d dkrFtd||d f � td| � qd S )Nr� � z(Distribution %s could not be deleted: %sr� zDistribution %s deleted)r� r r� r� r� r r) )r� r� r� r� r� r' r' r( �delete� s z Cmd.deletec C sh t t� �}t| �dkr td��zt�| �d }W n tyJ td��Y n0 |j|tjj tjj tjj tjj tjj tjjd�}|d dkr�td||d f � td | � |�|�}|d }|jd }td t�|jd d �� td|�� � td|jd � td|jd � tdd�|jd �� td|jd � td|jd � td|jd � td|d d � d S ) Nr z7Too many parameters. Modify one Distribution at a time.r z No valid Distribution URI found.)r� r� r� r� r� r� r� r� z)Distribution %s could not be modified: %sr� zDistribution modified: %sry rL r� rZ r[ r� r� r� r� r� r7 rS r5 rU r� r� r� )r� r r~ r r� r� � IndexErrorr� r� r� r� r� r� r� r� r r) r� r r, r r� r? r� )r� r� r� r� r� r� r' r' r( �modify� s< � z Cmd.modifyc C s, t t� �}t�| �}g }|D ]t}|�� r8|�t|�� q |�|�}z6|d jd D ]"}|�d� d|� � |d g�� qRW q t y� Y q Y q 0 q |D ]�}t |�}|� |�}|d j} | d d } t| t�r�t| �nd } td t|�� td | d � td | d � td| � td| d d � td� q�d S )Nr� ZInvalidationSummaryr| zcf:/r< r� rr r} r �URIr� �CreatedZ CreateTime� Nr of pathsZ Referencer\ rT )r� r r� r� r� rJ r_ r� r r� r� r� r r� � isinstancer: r~ r, r) ) r� r� r� Zrequestsr� r� �iZreqr� �strw Z nr_of_pathsr' r' r( � invalinfo s0 $ z Cmd.invalinfoc s8 t � }t|�}t|�}tt�}| D ]D}t|�}|�� }|s@d}n|d dkrT|d7 }||�� �|� q"t }g } |� � D ]�\� } td� �} t t |� | ���} d } |js�|jr�|�| |j�}|r�|d } | s�d } |jr�� fdd�| D �}td| � qx| �� | | | | f� qx|j�r td � t S d }d }| D ]�\� } } } } |�sJtd � nd }|�| | | |j|j�}| �� }tdt| �� td|� tdt| �� |D ]d}|d }|dk�r�tdd| � t}�q�|d }|d7 }tdd� td|� tdd||f � �q�|t k�r,|j�r,t d� �q �q,|t k�r4|�r4t }|S ) N�*���r| zs3://%sZindex_documentc s g | ]}t �� |��qS r' )r Z compose_uri)rO r �r` r' r( rQ [ rR z"Cmd.invalidate.<locals>.<listcomp>z [--dry-run] Would invalidate %rz Exiting now because of --dry-runr TrT Fr r� r r� r� r� z Failed: %dr� r r Z RequestIdZInfoz,Check progress with: s3cmd cfinvalinfo %s/%sz&Exiting now because of --stop-on-error) r r� r r r: r ra r` rJ r �items�next�iterr� r� r� Z website_infoZbucket_location�dry_runr) r r� r� r, r_ r~ r Z stop_on_errorr r )r� Zcfgr� r� Z bucket_pathsr� r? Zuobject�ret�paramsrw Zbase_urir� r� Z info_responseZ fulluri_pathsZ nb_success�first�resultsr� �resultZ result_coder� r' r r( � invalidate9 s� � � zCmd.invalidateN)rA rB rC �__doc__ra r� r� � staticmethodr� r r� r� r� r r r' r' r' r( r� � s" + ! r� )>Z __future__r r# r� rv � collectionsr r r� r r r r Zxml.etree.ElementTreeZetreeZ ElementTreer] � ImportErrorZelementtree.ElementTreer r Z Exceptionsr r Z ExitCodesr r r Z BaseUtilsr r r r r r r� r r r r ZCryptor r r r r � version_inforj rl r� r) r, ra r- rD rK rL rm rq rr r� r� r' r' r' r( �<module> sH T 1 @
SIMPAN
[ BATAL ]