Viewing File: /usr/lib/python2.7/site-packages/requestbuilder/service.pyo
ó
!»3Xc @@ s
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 Z d d l
Z
d d l Z d d l Z
d d l Z d d l j j Z d d l m Z m Z m Z m Z d d l m Z d e f d „ ƒ YZ d „ Z d „ Z d „ Z d S(
i ( t absolute_importN( t ClientErrort ServerErrort ServiceInitErrort TimeoutError( t RegionConfigurableMixint BaseServicec B@ sã e Z d Z d Z d Z d Z d Z d Z d Z g Z
d d d d „ Z e d „ ƒ Z
d „ Z e d „ ƒ Z d „ Z d d d d d d d d „ Z d d d d d d d d
„ Z d „ Z d „ Z d
„ Z d „ Z d „ Z RS( t i i c K@ s | | _ | | _ d | _ t j | j j ƒ | _ | d k rN | | j _ n | | _
d | _ i | _ | | _
d | _ d S( N( t argst configt Nonet endpointt loggingt getLoggert __class__t __name__t logt levelt max_retriest region_namet session_argst timeoutt _session( t selfR t loglevelR R t kwargs( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt __init__0 s c K@ sž | j d | j j ƒ | j d | j ƒ | j d t | j ƒ ƒ | j d | j ƒ d | j k r~ | j d | j d ƒ n | | j | } | j ƒ | S( NR R R R t region(
t
setdefaultR R R t dictR R R R t configure( t clst otherR t new( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt
from_other> s
c C@ s) | j ƒ | j ƒ | j d k rb | j j d ƒ } | d k rS t | ƒ | _ qb | j | _ n | j d k r° | j j d ƒ } | d k r¡ t | ƒ | _ q° | j
| _ n | j j d t
ƒ | j j d ƒ } | d k rö | j j d ƒ } n | j j d | j j | d t ƒƒ | j ƒ d S( Ns max-retriesR t streams
verify-tlss
verify-sslt verifyt default( t update_config_viewt _BaseService__configure_endpointR R
R t get_global_optiont intt MAX_RETRIESR t floatt TIMEOUTR R t Truet get_region_optiont convert_to_boolt Falset validate_config( R t config_max_retriest config_timeoutt
verify_ssl( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyR J s&
c C@ s„ | j d k r} t j ƒ | _ x3 t j | j ƒ D] \ } } t | j | | ƒ q1 Wx& | j j j ƒ D] } d | _
qg Wn | j S( Ni ( R R
t requestst sessiont sixt iteritemsR t setattrt adapterst valuesR ( R t keyt valt adapter( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyR6 l s c C@ s¬ | j d k r¨ | j d k r“ d j | j ƒ } | j j | ƒ } t | ƒ d k r{ d j | j d j t | ƒ ƒ ƒ } q™ d j | j | ƒ } n d } t | ƒ ‚ n d S( Ns {0}-urli sW No {0} endpoint to connect to was given. Configured regions with {0} endpoints are: {1}s , sd No {0} endpoint to connect to was given. {0} endpoints may be specified in a config file with "{1}".s# No endpoint to connect to was given(
R R
t NAMEt formatR t get_all_region_optionst lent joint sortedR ( R t url_optt available_regionst msg( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyR1 w s t GETc C@ sŠ | j | ƒ } t | p i ƒ } d g | D] } | j ƒ ^ q+ k rb t j | j ƒ j | d <n | j | | | | | | | ƒ }
|
j S( Nt hostt Host( t _BaseService__get_url_for_pathR t lowert urlparseR t netloct% _BaseService__log_and_prepare_requestt url( R t methodt patht paramst headerst datat filest authRP t headert p_request( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt get_request_url‰ s % c
C@ s_ | j | ƒ } t | ƒ } d g | D] } | j ƒ ^ q% k r\ t j | j ƒ j | d <n y*| j d }
d } t | t ƒ rŸ t | d ƒ rŸ | j
ƒ } n d } xÝt r„xªt
t |
ƒ d ƒ D]“\ }
} | d k rÿ | j j d | ƒ t j | ƒ n | j j d |
|
ƒ | j | | | | | | | ƒ } t j j | ƒ } x6 t | j ƒ ƒ D]" \ } } | j j d | | ƒ q[Wt j j ƒ | _ y+ | j j | d
| j d | d t ƒ} Wnƒ t j! j" k
rC|
|
k r=| j j d
d
t ƒ| d k r%| j j d ƒ | j# | ƒ qÄ q=t | d ƒ s=qÄ q=n ‚ n X| j$ d k rÄ PqÄ qÄ W| j$ d k ra| d k rad | j% k ra| d 8} t j | j% d ƒ } t j | ƒ } g } x0 t& | | ƒ D] \ } } | j' | på| ƒ qÊWd | k r
| d | d <n t j( | ƒ } | j j d | | ƒ | d k r¨ | j j d ƒ | j# | ƒ q¨ q¨ n | j$ d k r€| j) | ƒ n | SWWnÒ t j! j" k
rÆ} | j j d
d
t ƒt* d | ƒ ‚ n• t j! j+ k
rþ} | j j d d
t ƒ| j, | ƒ St j! j- k
r } | j) | ƒ St j! j. k
rZ} | j j d d
t ƒt/ | ƒ ‚ n Xd S( NRI RJ i i t seeki s will retry after %.3f secondss" sending request (attempt %i of %i)s request proxy: %s=%sR t proxiest allow_redirectst exc_infos$ re-seeking body to beginning of filet telliô i÷ i- i. i3 i4 t Locations, redirecting to %s (%i redirect(s) remaining)i, s request timed outs connection errors
request error( iô i÷ ( i- i. i3 i4 (0 RK R RL RM R RN R t
isinstancet filet hasattrR_ R
R- t enumeratet _generate_delaysR t debugt timet sleept infoRO R5 t utilst get_environ_proxiesRD t itemst datetimet nowt
start_timeR6 t sendR R0 t
exceptionst TimeoutR[ t status_codeRT t zipt appendt
urlunparset handle_http_errorR t ConnectionErrort% _BaseService__handle_connection_errort HTTPErrort RequestExceptionR ( R RQ RR RS RT RU RV RW RP RX t max_triest redirects_leftt data_file_offsett
attempt_not delayRY R\ R< R= t responset
parsed_rdrt
parsed_urlt new_url_bitst rdr_bitt url_bitt exc( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt send_request• s %
c C@ sÇ t | t j ƒ r | } n“ t | t ƒ r¢ t | j ƒ d k r¢ t | j d d ƒ rh | j d j } q® t | j d t ƒ r’ | j | j d ƒ S| j d } n t d ƒ ‚ t d j
| ƒ ƒ ‚ d S( Ni t reasons connection errors connection error ({0})( Ra R7 t string_typest ExceptionRB R Rc R‰ Ry R R@ ( R t errRG ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt __handle_connection_errorô s $ c C@ s& | j j d d t ƒt | ƒ ‚ d S( Ns
HTTP errorR^ ( R Rf R- R ( R R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyRw s c C@ s@ | r5 | j j d ƒ r# | j | S| j d | Sn | j Sd S( Nt /( R t endswith( R RR ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt __get_url_for_path s
c C@ sl i t j t | j ƒ d 6} | r4 | j | ƒ } n d } t j d | d | d | d | d | d | d | ƒ }
| j j |
ƒ } i | d d 6| _
| j j d |
j ƒ | j j d
| j
ƒ t | j t t j f ƒ r=x] t t j | j ƒ ƒ D]@ \ } }
| j ƒ j d ƒ r d }
n | j j d
| |
ƒ qö Wn t |
j t t j f ƒ rÊxo t t j t j | j
ƒ j d t ƒƒ D]@ \ } }
| j ƒ j d ƒ rd }
n | j j d | |
ƒ qƒWn t |
j t t j f ƒ rät j | j j d ƒ p d ƒ \ } } | d k r9t j! t" j# | j$ ƒ | ƒ } n6 | d k rft t j | j$ d t ƒƒ } n |
j } xr t | j% ƒ ƒ D][ \ } }
| |
j& pi k r©q‚n | j ƒ j d ƒ rÇd }
n | j j d | |
ƒ q‚Wn t |
j& t t j f ƒ rhxf t t j |
j& ƒ ƒ D]I \ } }
t' |
d ƒ rKd j( t) |
ƒ ƒ }
n | j j d | |
ƒ qWn | S( NR RQ RP RS RU RV RT RW s request method: %ss request url: %st passwords
<redacted>s request header: %s: %st keep_blank_valuess request param: %s: %ss content-typeR s multipart/form-datas! application/x-www-form-urlencodeds request data: %s: %st __len__s <{0} bytes>s request file: %s: %s(* t functoolst partialt _log_response_dataR t bind_to_serviceR
R5 t RequestR6 t prepare_requestt hooksRf RQ RP Ra RT R t collectionst MappingRD R7 R8 RL R RS RM t parse_qslt queryR- RU t cgit parse_headert gett parse_multipartt iot BytesIOt bodyRl RV Rc R@ RB ( R RQ RP RS RU RV RT RW Rš t
bound_autht requestRY R< R= t content_typet content_type_params( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt __log_and_prepare_request sZ % ! % c C@ së | j j d ƒ r. t | j d ƒ \ } } n§ t j | j ƒ ra t t j | j ƒ ƒ \ } } nt | j rÕ | j j | j d ƒ \ } } | rÌ | j j d | ƒ } | d k rÒ | j d d ƒ d } qÒ qÕ d } n | | _ | | _
d S( NRP s -urlt namet :i iÿÿÿÿ( R R¡ t _parse_endpoint_urlt ost getenvt
URL_ENVVARR? R t get_region_option2R. R
t rsplitR R ( R RP R t section( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt __configure_endpointG s ! N( R t
__module__R
R? t DESCRIPTIONt API_VERSIONR* R, t
REGION_ENVVARR° t ARGSR t classmethodR" R t propertyR6 R1 RZ Rˆ Ry Rw RK RO R' ( ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyR $ s, " ^ 6c K@ sÞ t | j d ƒ rK t j j ƒ | j j } | j d | j | j d ƒ n | j d k rp | j d | j ƒ n | j
d | j ƒ t | j t
t j f ƒ rÚ x9 t | j j ƒ ƒ D] \ } } | j d | | ƒ q´ Wn d S( NRo s response time: %i.%03i secondsiè i s response status: %is response header: %s: %s( Rc R§ Rm Rn Ro Rf t secondst microsecondsRs t errorRi Ra RT R R› Rœ RD Rl ( t loggerR t _t durationR< R= ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyR– ] s "c c@ s_ | d k r[ d VxG t d | ƒ D]3 } t j ƒ d d | d } t | d f ƒ Vq! Wn d S( Ni i i i ( t ranget randomt min( R| t retry_not
next_delay( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyRe k s
c C@ s= d | k r' | j d d ƒ \ } } n d } | } | | f S( s
If given a URL, return the URL and None. If given a URL with a string and
"::" prepended to it, return the URL and the prepended string. This is
meant to give one a means to supply a region name via arguments and
variables that normally only accept URLs.
s ::i N( t splitR
( t urlishR RP ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyR s s
( t
__future__R RŸ R› Rm R” R£ R t os.pathR® RÃ Rg t requests.exceptionsR5 R7 t six.moves.urllib_parset movest urllib_parseRM t requestbuilder.exceptionsR R R R t requestbuilder.mixinsR R R– Re R ( ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt <module> s& "ÿ :
Back to Directory
File Manager