Viewing File: /usr/lib/python2.7/site-packages/requestbuilder/service.pyc
ó
!»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@ sq | j | ƒ } t | ƒ } d g | D] } | j ƒ ^ q% k r\ t j | j ƒ j | d <n y<| j d }
|
d k s~ t ‚ 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 | | ƒ qmWt j j ƒ | _ y+ | j j | d
| j d | d t! ƒ} Wnƒ t j" j# k
rU|
|
k rO| j j d
d
t
ƒ| d k r7| j j d ƒ | j$ | ƒ qÖ qOt
| d ƒ sOqÖ qOn ‚ n X| j% d k rÖ PqÖ qÖ W| j% d k rs| d k rsd | j& k rs| 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
r2} | j* | ƒ St j" j/ k
rl} | j j d d
t
ƒt0 | ƒ ‚ 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 (1 RK R RL RM R RN R t AssertionErrort
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})( Rb R7 t string_typest ExceptionRB R Rd RŠ Rz 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 Rg R- R ( R R‚ ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyRx 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 hooksRg RQ RP Rb 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 bodyRm RV Rd 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‰ Rz Rx 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( NRp s response time: %i.%03i secondsiè i s response status: %is response header: %s: %s( Rd R¨ Rn Ro Rp Rg t secondst microsecondsRt t errorRj Rb RT R Rœ R RD Rm ( 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.pyRf 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œ Rn R• R¤ R t os.pathR¯ RÄ Rh t requests.exceptionsR5 R7 t six.moves.urllib_parset movest urllib_parseRM t requestbuilder.exceptionsR R R R t requestbuilder.mixinsR R R— Rf R® ( ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/service.pyt <module> s& "ÿ :
Back to Directory
File Manager