ó
¡ôXc @ sö d d l Z d d l Z d d l Z d d l Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l
Z
d d l Z d d l m
Z
d d l m Z d e j j f d „ ƒ YZ d e j j f d „ ƒ YZ d „ Z d
„ Z d S( iÿÿÿÿN( t Arg( t Euca2ools( t AWSErrort S3c B sY e Z d Z d Z d Z d Z e d d d d d d
ƒg Z d „ Z d „ Z d
„ Z
RS( t s3s Object storage servicet EUCA_DEFAULT_REGIONt AWS_DEFAULT_REGIONt S3_URLs -Us --urlt metavart URLt helps# object storage service endpoint URLc C s t | ƒ ‚ d S( N( R ( t selft response( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyt handle_http_error5 s c C s2 t j j j j | ƒ } | j s@ t j j j j d | ƒ } n t j j j j | j ƒ } | j | | ƒ \ } } | r‰ | j | | f S| j j
d ƒ } x{ | j ƒ D]m \ } } t j j j j | ƒ } | j | | ƒ \ } } | r¨ | j j d d | ƒ}
|
p | | | f Sq¨ Wt
d j | ƒ ƒ ‚ d S( sÆ
Given a URL, try to return its associated region, bucket, and
key names based on this object's endpoint info as well as all
S3 endpoints given in the configuration.
s http://s s3-urlt namet regionsg URL '{0}' matches no known object storage endpoints. Supply one via the command line or configuration.N( t sixt movest urllibt parset urlparset schemet endpointt _S3__match_patht region_namet configt get_all_region_optionst itemst get_region_optiont
ValueErrort format( R t urlt
parsed_urlt parsed_own_urlt buckett keyt s3_urlst sectiont conf_urlt parsed_conf_urlR ( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyt resolve_url_to_location9 s" c
C sg | j | j k r¥ | j } | j d ƒ s7 | d 7} n | j j | d ƒ d } | j d d ƒ \ } } | j j d | j | j | j | j | j | j | | ƒ n¸ | j j | j ƒ rQ| j j d | j d ƒ d } | j d ƒ } | j j d ƒ r | j d } n | j } | j j d | j | j | j | j | j | j | | ƒ n d } d } | | f S( Nt /i s/ URL path match: %s://%s%s + %s://%s%s -> %s/%st .i s0 URL vhost match: %s://%s%s + %s://%s%s -> %s/%s( t netloct patht endswitht splitt logt debugR t rsplitt lstript
startswitht None( R t givent servicet service_patht cpathR" R# ( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyt __match_pathT s.
( R R ( t __name__t
__module__t NAMEt DESCRIPTIONt
REGION_ENVVARt
URL_ENVVARR t ARGSR
R( R ( ( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyR + s t S3Requestc B sP e Z e Z e Z e j j j Z
d „ Z d „ Z d „ Z
d „ Z d „ Z RS( c K s# t j j j | | d | _ d S( Ni ( t requestbuildert requestt BaseRequestt __init__t redirects_left( R t kwargs( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyRE w s c C sd t j j j | ƒ | j ƒ r` | j j d ƒ t j j j j
| j ƒ } | j ƒ | | _ n d S( Ns switching to HmacV4Auth( RB RC RD t configuret _S3Request__should_use_sigv4R/ t infot autht awst
HmacV4Autht
from_other( R RK ( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyRH { s
c C s | j j | j j d ƒ ƒ S( Ns s3-force-sigv4( R t convert_to_boolR ( R ( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyt __should_use_sigv4… s c C s | j ƒ | j ƒ r@ t j j j j | j d | d d ƒ} n! t j j j j | j d | ƒ} | j j d | j
d | j d | j d | ƒ S( sm
Get a pre-signed URL for this request that expires after a given
number of seconds.
t timeoutt payload_hashs UNSIGNED-PAYLOADt methodR, t paramsRK (
t
preprocessRI RB RK RL t QueryHmacV4AuthRN t QueryHmacV1AuthR6 t get_request_urlRS R, RT ( R RQ RK ( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyt get_presigned_url2‰ s
c C sG | j d k r-| j j d d i t d 6ƒ| j j | j j d i t d 6ƒ| j j d ƒ | j j d ƒ d } d | j k r¡ | d j | j d ƒ 7} n | j j | d
t ƒd | j k rß d j | j d ƒ } n d
} t j
j j j
| j j ƒ } d j | | j ƒ } t j j | ƒ ‚ n t j j j | | ƒ Sd S( Ni- s -- response content --
t extrat appends -- end of response content --s result: inter-region redirects% Aborting due to inter-region redirectt Endpoints to {0}t exc_infot Buckets "{0}" t su Bucket {0}is not available from endpoint "{1}". Ensure the object storage service URL matches the bucket's location.( t status_codeR/ R0 t TrueR t textt errort elementsR R R R R R R6 R R+ RB t
exceptionst ClientErrorRC RD t handle_server_error( R t errt msgR" t parsed( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyRg › s& # ( R: R; R t SUITER t
SERVICE_CLASSRB RK RL t
HmacV1Autht
AUTH_CLASSRE RH RI RY Rg ( ( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyRA r s
c C s‰ t | ƒ d k r! t d ƒ ‚ n t | ƒ d k rB t d ƒ ‚ n x@ | D]8 } | t j t j d k rI t d j | ƒ ƒ ‚ qI qI Wd S( Ni s name is too shortiÿ s name is too longs .-_s invalid character '{0}'( t lenR t stringt
ascii_letterst digitsR ( R" t char( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyt validate_generic_bucket_nameµ s
c C sÑ t | ƒ d k r! t d ƒ ‚ n t | ƒ d k rB t d ƒ ‚ n | j d ƒ r` t d ƒ ‚ n | j d ƒ r~ t d ƒ ‚ n | j d ƒ } xÞ | D]Ö } t | ƒ d k r» t d ƒ ‚ n x@ | D]8 } | t j t j d
k r t d j | ƒ ƒ ‚ q q W| d t j t j k r4t d j | d ƒ ƒ ‚ n | d
t j t j k r” t d j | d
ƒ ƒ ‚ q” q” Wt | ƒ d k rÍy* g | j d ƒ D] } t | ƒ ^ q“Wn t k
r½qÍXt d ƒ ‚ n d S( Ni s name is too shorti? s name is too longR* s name may not start with '.'s name may not end with '.'i s name may not contain '..'t -s invalid character '{0}'s3 character '{0}' may not begin part of a bucket nameiÿÿÿÿs1 character '{0}' may not end part of a bucket namei s- name must not be formatted like an IP address(
Ro R R3 R- R. Rp t ascii_lowercaseRr R t int( R" t labelst labelRs t chunk( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyt validate_dns_bucket_name¿ s6
*
( t osRp t sysR RB R t requestbuilder.auth.awst requestbuilder.exceptionst requestbuilder.requestt requestbuilder.servicet requestsR t euca2ools.commandsR t euca2ools.exceptionsR R6 t BaseServiceR RC RD RA Rt R{ ( ( ( sB /usr/lib/python2.7/site-packages/euca2ools/commands/s3/__init__.pyt <module> s G C