o ckF[3@sdZddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddl Z ddlZ ddlZ ddlZ ddl mZmZddlmZmZmZmZmZddlmZdd lmZdd lmZdd lmZdd lm Z dd l!m"Z"dZ#zddl$Z$ddl m%Z%e&e$drdZ#Wn e'yYnwzddl(Z(Wn e'yddl)Z(Ynwe*dddDZ+dddZ,ej-.ej-/ej-0e j1j2dZ3Gddde4Z5Gddde4Z6Gddde4Z7Gdd d ej8Z8Gd!d"d"e4Z9Gd#d$d$e9Z:dS)%z" Handles basic connections to AWS )datetimeN)auth) auth_handler)config UserAgent)six http_clienturlparsequote encodebytes)AWSConnectionError)BotoClientError)BotoServerError)PleaseRetryException)Provider) ResultSetF)https_connectionSSLErrorTccs|]}|tjvVqdSN)osenviron).0keyr1/usr/lib/python3/dist-packages/boto/connection.py Wsr) USER_IS_ADMINCURRENT_VERSION_IDAPPLICATION_IDP)TFz cacerts.txtc@sHeZdZdZddZddZddZdd Zd d Zd d Z ddZ dS)HostConnectionPoola A pool of connections for one remote (host,port,is_secure). When connections are added to the pool, they are put into a pending queue. The _mexe method returns connections to the pool before the response body has been read, so they connections aren't ready to send another request yet. They stay in the pending queue until they are ready for another request, at which point they are returned to the pool of ready connections. The pool of ready connections is an ordered list of (connection,time) pairs, where the time is the time the connection was returned from _mexe. After a certain period of time, connections are considered stale, and discarded rather than being reused. This saves having to wait for the connection to time out if AWS has decided to close it on the other end because of inactivity. Thread Safety: This class is used only from ConnectionPool while it's mutex is held. cCs g|_dSr)queueselfrrr__init__z zHostConnectionPool.__init__cCs t|jS)z Returns the number of connections in the pool for this host. Some of the connections may still be in use, and may not be ready to be returned by get(). )lenr"r#rrrsize}s zHostConnectionPool.sizecCs|j|tfdS)zZ Adds a connection to the pool, along with the time it was added. N)r"appendtime)r$connrrrputszHostConnectionPool.putcCsL|tt|jD]}|jd\}}||r|S||q dS)z Returns the next connection in this pool that is ready to be reused. Returns None if there aren't any. rN)cleanranger'r"pop _conn_readyr,)r$_r+rrrgets  zHostConnectionPool.getcCs$trdSt|dd}|dup|S)aZ There is a nice state diagram at the top of http_client.py. It indicates that once the response headers have been read (which _mexe does before adding the connection to the pool), a response is attached to the connection, and it stays there until it's done reading. This isn't entirely true: even after the client is done reading, the response may be closed, but not removed from the connection yet. This is ugly, reading a private instance variable, but the state we care about isn't available in any public methods. F_HTTPConnection__responseN) ON_APP_ENGINEgetattrisclosed)r$r+responserrrr0s  zHostConnectionPool._conn_readycCsXt|jdkr&||jdr*|jdt|jdkr(||jdsdSdSdSdS)z/ Get rid of stale connections. rN)r'r" _pair_staler/r#rrrr-s .zHostConnectionPool.cleancCs|\}}t}|tj|kS)z[ Returns true of the (connection,time) pair is too old to be used. )r*ConnectionPoolSTALE_DURATION)r$pair_conn return_timenowrrrr8szHostConnectionPool._pair_staleN) __name__ __module__ __qualname____doc__r%r(r,r2r0r-r8rrrrr!`s r!c@sPeZdZdZdZdZddZddZdd Zd d Z d d Z ddZ ddZ dS)r9z A connection pool that expires connections after a fixed period of time. This saves time spent waiting for a connection that AWS has timed out on the other end. This class is thread-safe. g@gN@cCs,i|_d|_t|_tddtjt_dS)NgBotoconnection_stale_duration) host_to_poollast_clean_time threadingLockmutexrgetfloatr9r:r#rrrr%s zConnectionPool.__init__cCst|j}i|d<|d=|S)NrErI)copy__dict__)r$ pickled_dictrrr __getstate__s zConnectionPool.__getstate__cCs |dSr)r%)r$dctrrr __setstate__ zConnectionPool.__setstate__cCstdd|jDS)z@ Returns the number of connections in the pool. css|]}|VqdSr)r()rpoolrrrrsz&ConnectionPool.size..)sumrEvaluesr#rrrr(szConnectionPool.sizecCsf||j"|||f}||jvr WddS|j|WdS1s,wYdS)z Gets a connection from the pool for the named host. Returns None if there is no connection that can be reused. It's the caller's responsibility to call close() on the connection when it's no longer needed. N)r-rIrEr2)r$hostport is_securerrrrget_http_connections   $z"ConnectionPool.get_http_connectioncCs\|j!|||f}||jvrt|j|<|j||WddS1s'wYdS)zm Adds a connection to the pool of connections that can be reused for the named host. N)rIrEr!r,)r$rUrVrWr+rrrrput_http_connections    "z"ConnectionPool.put_http_connectioncCs|jDt}|j|j|kr?g}|jD]\}}||dkr*||q|D]}|j|=q-||_WddSWddS1sJwYdS)a+ Clean up the stale connections in all of the pools, and then get rid of empty pools. Pools clean themselves every time a connection is fetched; this cleaning takes care of pools that aren't being used any more, so nothing is being gotten from them. rN) rIr*rFCLEAN_INTERVALrEitemsr-r(r))r$r> to_removerUrRrrrr-s   "zConnectionPool.cleanN) r?r@rArBrZr:r%rNrPr(rXrYr-rrrrr9s    r9c@s$eZdZddZddZddZdS) HTTPRequestc Cs|||_||_||_||_||_|dur|}||_||_|r6d|vr6|ddkr6|jdkr6||_|jd=n||_| |_ dS)ayRepresents an HTTP request. :type method: string :param method: The HTTP method name, 'GET', 'POST', 'PUT' etc. :type protocol: string :param protocol: The http protocol used, 'http' or 'https'. :type host: string :param host: Host to which the request is addressed. eg. abc.com :type port: int :param port: port on which the request is being sent. Zero means unset, in which case default port will be chosen. :type path: string :param path: URL path that is being accessed. :type auth_path: string :param path: The part of the URL path used when creating the authentication string. :type params: dict :param params: HTTP url query parameters, with key as name of the param, and value as value of param. :type headers: dict :param headers: HTTP headers, with key as name of the header and value as value of header. :type body: string :param body: Body of the HTTP request. If not present, will be None or empty string (''). NTransfer-EncodingchunkedPUT) methodprotocolrUrVpath auth_pathparamsrKheadersbody) r$rarbrUrVrcrdrerfrgrrrr%1s $      zHTTPRequest.__init__c Cs(d|j|j|j|j|j|j|j|jfS)NzTmethod:(%s) protocol:(%s) host(%s) port(%s) path(%s) params(%s) headers(%s) body(%s))rarbrUrVrcrerfrgr#rrr__str__hs zHTTPRequest.__str__cKst|dds*|jD]}|j|}t|tjr#d}t|d||j|<q t|ddt|jd<|j j |fi|d|jvrVd|jvsJ|jdd krXt t |j |jd<dSdSdS) N_headers_quotedFz!"#$%&'()*+,/:;<=>?@[\]^`{|}~ utf-8Tz User-AgentzContent-Lengthr^r_)r5rf isinstancer text_typer encodesetattrr _auth_handleradd_authstrr'rg)r$ connectionkwargsrvalsaferrr authorizens        zHTTPRequest.authorizeN)r?r@rAr%rhrvrrrrr]/s7 r]c@seZdZddZdddZdS) HTTPResponsecOs$tjj|g|Ri|d|_dS)N)rrwr%_cached_response)r$argsrsrrrr%s zHTTPResponse.__init__NcCs0|dur|jstj||_|jStj||S)a<Read the response. This method does not have the same behavior as http_client.HTTPResponse.read. Instead, if this method is called with no ``amt`` arg, then the response body will be cached. Subsequent calls to ``read()`` with no args **will return the cached response**. N)ryrrwread)r$amtrrrr{s  zHTTPResponse.readr)r?r@rAr%r{rrrrrwsrwc@s\eZdZ        d?ddZdd Zd d Zd d ZddZeeeZ ddZ ddZ ee e Z ddZ ee Z ddZeeZeZeZddZeeZeZeZddZeeZd@ddZdAddZd d!Zd"d#Zd$d%Zd&d'Zd(d)ZdBd*d+ZdAd,d-Zd.d/Zd0d1Zd2d3Z d4d5Z!  dCd6d7Z" dDd9d:Z#   dEd;d<Z$d=d>Z%dS)FAWSAuthConnectionNTr/awscCs*||_d|_tddrtdd}||_tdd||_|jr&ts&t dt ddt }|dkr3d}||_ |r<||_ nt||_ ||||| tjtjtjtjf|_g|_tr`|jtjtjf|_| durx| d |_|j| d 7_nd|_|rd |_nd |_||_ | |_!t"| t#j$sd } t%dd | |_&d|_'i|_(t)j*d t)j*d fdkrt%ddd|j(d<t"| t+r| |_,n | |_-t+|j-|||||_,|j,j r|j,j |_ |j,j r|j,j |_ |j,j'r|j,j'|_'t.|_/|j |j |jf|_0d|_1t23|t|j,|4|_5t6|dddur|j7|_8d|_9dS)a0 :type host: str :param host: The host to make the connection to :keyword str aws_access_key_id: Your AWS Access Key ID (provided by Amazon). If none is specified, the value in your ``AWS_ACCESS_KEY_ID`` environmental variable is used. :keyword str aws_secret_access_key: Your AWS Secret Access Key (provided by Amazon). If none is specified, the value in your ``AWS_SECRET_ACCESS_KEY`` environmental variable is used. :keyword str security_token: The security token associated with temporary credentials issued by STS. Optional unless using temporary credentials. If none is specified, the environment variable ``AWS_SECURITY_TOKEN`` is used if defined. :type is_secure: boolean :param is_secure: Whether the connection is over SSL :type https_connection_factory: list or tuple :param https_connection_factory: A pair of an HTTP connection factory and the exceptions to catch. The factory should have a similar interface to L{http_client.HTTPSConnection}. :param str proxy: Address/hostname for a proxy server :type proxy_port: int :param proxy_port: The port to use when connecting over a proxy :type proxy_user: str :param proxy_user: The username to connect with on the proxy :type proxy_pass: str :param proxy_pass: The password to use when connection over a proxy. :type port: int :param port: The port to use to connect :type suppress_consec_slashes: bool :param suppress_consec_slashes: If provided, controls whether consecutive slashes will be suppressed in key paths. :type validate_certs: bool :param validate_certs: Controls whether SSL certificates will be validated or not. Defaults to True. :type profile_name: str :param profile_name: Override usual Credentials section in config file to use a named set of keys instead. rCrWhttps_validate_certificateszSSL server certificate validation is enabled in boto configuration, but Python dependencies required to support this feature are not available. Certificate validation is only supported when running under Python 2.6 or later.ca_certificates_filesystemNrhttpshttpdebug)rhttp_socket_timeoutFtimeoutAuthServiceName):suppress_consec_slashes num_retriesr has_option getbooleanrWgetboolrHAVE_HTTPS_CONNECTIONr get_valueDEFAULT_CA_CERTS_FILErrVPORTS_BY_SECURITY handle_proxyr HTTPExceptionsocketerrorgaierror BadStatusLinehttp_exceptionshttp_unretryable_exceptionsr)rInvalidCertificateExceptionerrnoEINTRsocket_exception_valueshttps_connection_factoryrbrUrcrkr integer_typesgetintr host_headerhttp_connection_kwargssys version_inforprovider_provider_typer9_pool _connection_last_rsrget_auth_handler_required_auth_capabilityror5rauth_service_name request_hook)r$rUaws_access_key_idaws_secret_access_keyrWrVproxy proxy_port proxy_user proxy_passrrrcrsecurity_tokenrvalidate_certs profile_name certs_filerrrr%s9            zAWSAuthConnection.__init__cCsd|jj|jfS)Nz%s:%s) __class__r?rUr#rrr__repr__>szAWSAuthConnection.__repr__cCgSrrr#rrrrAz+AWSAuthConnection._required_auth_capabilitycC t|jdS)N service_namer5ror#rrr_get_auth_service_nameDrQz(AWSAuthConnection._get_auth_service_namecC ||j_dSr)rorr$valuerrr_set_auth_service_nameJrQz(AWSAuthConnection._set_auth_service_namecCr)N region_namerr#rrr_get_auth_region_nameNrQz'AWSAuthConnection._get_auth_region_namecCrr)rorrrrr_set_auth_region_nameQrQz'AWSAuthConnection._set_auth_region_namecCs |j|jSr)rXrr#rrrrrUrQzAWSAuthConnection.connectioncC|jjSr)r access_keyr#rrrrYz#AWSAuthConnection.aws_access_key_idcCrr)r secret_keyr#rrrr_rz'AWSAuthConnection.aws_secret_access_keycCrr)rrr#rrrrerzAWSAuthConnection.profile_namecCs|js |jtdd|S|d}|dkr#||d}|d|}nd}|ddkr.d}nd}|jd}||dd d |D}dd|}|ddkrX|rX|d7}|r^||}|S) Nz^(/*)/z\1?rr~TFcSsg|]}|r|qSrr)rprrr |sz.AWSAuthConnection.get_path..)rrcresubfindsplitextendjoin)r$rcposre need_trailing path_elementsrrrget_pathis&    zAWSAuthConnection.get_pathcCsh|s|j}|dkr|j}|Strtjdddks"tjdddvr+|dkr+|j}|Sd|j|f}|S)Nr z2.5)z2.6z2.7r%s:%d)rVrUr4rversion)r$rVsignature_hostrrr server_nameszAWSAuthConnection.server_namecCs||_||_||_||_dtjvr<|js[\w\-\.]+):(?P.*)@)?(?P[\w\-\.]+)(?::(?P\d+))?rUrVuserpassrCrrrrzFhttp_proxy environment variable does not specify a port, using defaultno_proxyrxNO_PROXY)rrrrrrrcompilematchgrouprrprintrVr2r use_proxy)r$rrrrpatternrrrrrs8     zAWSAuthConnection.handle_proxycCs*|j|||}|dur|S||||Sr)rrXnew_http_connection)r$rUrVrWr+rrrrXsz%AWSAuthConnection.get_http_connectioncCs^|jsdS|jdkr dS|}|dd}|jdD]}|r,||s)||r,dSqdS)NF*T:r,)rrendswith)r$rUhostonlynamerrr skip_proxys zAWSAuthConnection.skip_proxycCs`|dur|}tj|}|j}||d<|jr+|s+||s+|j}t |j |d<|rmtj d|||jrH||sH| ||rDdpEd}nC|jrQ||}n:|jrctrctj|fd|ji|}n(tj|fi|}ntj d||jr|j|fi|}n tj|fi|}|j dkr||j |dd |jkr||jkr|||f|_t|_|S) NrVz1establishing HTTPS connection: host=%s, kwargs=%srr ca_certsz'establishing HTTP connection: kwargs=%srrr)rbotoutils parse_hostrrKrrrintrlogr proxy_sslrrrrCertValidatingHTTPSConnectionrrHTTPSConnectionHTTPConnectionset_debuglevelrrUrWrrwresponse_class)r$rUrVrWrrrrrrrsh        z%AWSAuthConnection.new_http_connectioncCs|j||||dSr)rrY)r$rUrVrWrrrrrrY sz%AWSAuthConnection.put_http_connectioncCs |r |r d||f}nd|j|jf}|jd}|dur*t|jt|jf|}n t|jt|jf}t j d|| d|| dt |jrq|jrq|D] \}}| d||fqVtddd rp| d n| d tj|d |j d }||jd krtdd|j|j|j|jf|t|}|jrtrd} |jr| d|j7} n| d7} t j | |jdd} |jdd} tj || | tj!|jd} | "} |j#ddd}t$%| |st$&|| dnt'tdrtj(|} n t|dd} t)|| } | |_*|S)Nrrz'Proxy connection: CONNECT %s HTTP/1.0 zCONNECT %s HTTP/1.0 zUser-Agent: %s z%s: %s rC"send_crlf_after_proxy_auth_headersFz T)strict debugleveliz*Error talking to HTTP proxy %s:%s: %s (%s)z,wrapping ssl socket for proxied connection; zCA certificate file=%szusing system provided SSL certskey_file cert_file)keyfilecertfile cert_reqsrrrzhostname mismatchssl)+rUrVrr2rcreate_connectionrrrrrrsendallrrrget_proxy_auth_headerr[rrrrwbeginstatusrreasoncloserrrrr  wrap_socket CERT_REQUIRED getpeercertrrValidateCertificateHostnamerhasattr SSLSocket FakeSocketsock)r$rUrVrrkvresphmsgrrsslSockcerthostnamerrrrsv           zAWSAuthConnection.proxy_sslcCs|jd|p ||}|S)N://)rbr)r$rcrUrrrprefix_proxy_to_pathUsz&AWSAuthConnection.prefix_proxy_to_pathcCs t|jd|j}dd|iS)NrzProxy-AuthorizationzBasic %s)r rr)r$rrrrr Ys z'AWSAuthConnection.get_proxy_auth_headercCsZ|jsdS|js |jr|jrd|j|jf}nd|j}nd}d||jt|jp)|jfS)Nz%s:%s@z%s@rxzhttp://%s%s:%s)rrrrrqrrV)r$ login_inforrrget_proxy_url_with_auth^s  z)AWSAuthConnection.get_proxy_url_with_authcCsJz|j|j||jd<WdSty$|jddd|jd<YdSw)NHostrrr)rorrUrfAttributeErrorr)r$requestrrrset_host_headerls  z!AWSAuthConnection.set_host_headercCs ||_dSr)r)r$hookrrrset_request_hooksr&z"AWSAuthConnection.set_request_hookc Cstjd|jtjd|jtjd|jtjd|jtjd|jtjd|jtjd|j d}d}d}|durRt d d |j }n|}d } | |j|j|j} t|jtsst|jd rs|jd |_| |krGttd| tj d dd} zDtjd|jj|j|dd|vrt|dds|jds||tjd|jt|_t|r|| |j|j|j|j}n| |j|j|j|j| !}tjd|"|#d} |jdkrt|ddrd |_$t|r!||| | } | r!| \}} } |rtj|t%&| Wqs|j'dvrHd|j'}|d| 7}tj||(}t|trG|)d }n|j'dksW|j'd ksW| s|#d!}|d"krf| *n |+|j|j|j| |j,dur~|j,-|||WSt.| \}|_|_}}}|r|jd#|7_d$|jvr|j/d$d%\|_|_d&|d'}||j|j7}tj|| |j|j|d(k} d}WqsWnkt0y}ztjd)||1|j|j|j} |j2}|}WYd}~nFd}~w|j3y9}z4|j4D]}t||rtjd*|j5j6qtjd+|j5j6|1|j|j|j} |}WYd}~nd}~wwt%&| | d%7} | |ksx|j,durV|j,j-||d,d-|rat7|j'|j8||rf|d.}t9|)/a> mexe - Multi-execute inside a loop, retrying multiple times to handle transient Internet errors by simply trying again. Also handles redirects. This code was inspired by the S3Utils classes posted to the boto-users Google group by Larry Bates. Thanks! z Method: %szPath: %szData: %sz Headers: %szHost: %szPort: %sz Params: %sNrCrrrmrjrmax_retry_delay<z Token: %s)rrs3anonFr&zFinal headers: %szResponse headers: %slocationHEADr_)iiiizReceived %d response. zRetrying in %3.1f secondsi,irrrrrrzRedirecting: %sr"rz!encountered a retry exception: %sz0encountered unretryable %s exception, re-raisingz&encountered %s exception, reconnectingT)rz-Please report this exception as a Boto Issue!):rrrrarcrgrfrUrVrerrrrXrWrkbytesrrmminrandomr2rrrvrr5r)rr> start_timecallabler( getresponse getheaders getheaderr_r*sleeprr{decoderrYrhandle_request_datar rrrr7rrrr?rrr )r$r(senderoverride_num_retries retry_handlerr7rgexrirr next_sleepr0rrconn_header_valueschemerequeryfragmente unretryablerrr_mexevs                                      izAWSAuthConnection._mexerxc Cs||}|dur||}|duri}n|}|dur i}n|}|jr3tjd|s3|j|d<|p7|j}|jrZ||sZ|sD|}| ||}|j rZ|j rZ|j sZ| |t||j||j||||| S)NrU)rrKrrrfind_matching_headersrUrrr#rrrWupdater r]rbrV)r$rarcrdrerfdatarUrrrbuild_base_http_request s*      z)AWSAuthConnection.build_base_http_requestc Cs4| duri} ||||| |||} |j| ||| dS)z?Makes a request to the server, with stock multiple-retry logic.N)r?)rMrI) r$rarcrfrLrUrdr=r>rer? http_requestrrr make_request&s  zAWSAuthConnection.make_requestcCstjdd|_dS)z(Optional) Close any open HTTP connections. This is non-destructive, and making a new request will open a connection again.zclosing all HTTP connectionsN)rrrrr#rrrr1s  zAWSAuthConnection.close)NNTNNNNNrNr~rNTTN)r~r)NN)NNN)NNrxN)NrxNNNNNN)&r?r@rAr%rrrrpropertyrrrauth_region_namerrrgs_access_key_idrrgs_secret_access_keyrrrrrrXrrrYrr#r r%r)r+rIrMrOrrrrrr}sn     $9  F   r}cseZdZdZeZ     dfdd Zd d Zd d ZdddZ ddZ ddZ  dddZ  dddZ dddZZS)AWSQueryConnectionrxNTrr~rcs4tt|j| ||||||||| | | | |||ddS)N)rrrr)superrTr%)r$rrrWrVrrrrrUrrrcrrrrrrrr%>s  zAWSQueryConnection.__init__cCrrrr#rrrrNrz,AWSQueryConnection._required_auth_capabilitycCs tj|Sr)rrget_utf8_valuerrrrrWQrQz!AWSQueryConnection.get_utf8_valueGETc CsB|||d|id|j}|r||jd<|jr|j|jd<||S)NrxActionVersion)rMrUre APIVersionrI)r$actionrercverbrNrrrrOTs    zAWSQueryConnection.make_requestcCsFt|tjr |g}tdt|dD]}||d|d||f<qdS)Nrz%s.%d)rkr string_typesr.r')r$rer[labelrArrrbuild_list_params^s z$AWSQueryConnection.build_list_paramsc CsLt|dD]\}}d||f}t||D]\}} d||f} | || <qqdS)aSerialize a list of structures. For example:: items = [('foo', 'bar', 'baz'), ('foo2', 'bar2', 'baz2')] label = 'ParamName.member' names = ('One', 'Two', 'Three') self.build_complex_list_params(params, items, label, names) would result in the params dict being updated with these params:: ParamName.member.1.One = foo ParamName.member.1.Two = bar ParamName.member.1.Three = baz ParamName.member.2.One = foo2 ParamName.member.2.Two = bar2 ParamName.member.2.Three = baz2 :type params: dict :param params: The params dict. The complex list params will be added to this dict. :type items: list of tuples :param items: The list to serialize. :type label: string :param label: The prefix to apply to the parameter. :type names: tuple of strings :param names: The names associated with each tuple element. rz%s.%sN) enumeratezip) r$rer[r_namesrAitemcurrent_prefixrrfull_keyrrrbuild_complex_list_paramsds"   z,AWSQueryConnection.build_complex_list_paramsc Cs|s|}|||||}|}tj||s)tjd|||j|j||jdkrMt |} tj | |} t |t jrD|d}tj|| | Stjd|j|jftjd|||j|j|N Null body %srrj%s %s%s)rOr{rrrr ResponseErrorrrrhandler XmlHandlerrkrrlrmxmlsax parseString) r$r\remarkersrcparentr]r7rgrsrrrrget_list$    zAWSQueryConnection.get_listc Cs|s|}|||||}|}tj||s)tjd|||j|j||jdkrM||} tj | |} t |t j rD|d}tj|| | Stjd|j|jftjd|||j|j|rh)rOr{rrrrrlrrrmrnrkrrlrmrorprq) r$r\reclsrcrsr]r7rgobjrrrr get_objectrvzAWSQueryConnection.get_objectc Cs|s|}|||||}|}tj||s)tjd|||j|j||jdkrBt }tj ||} t j || |jStjd|j|jftjd|||j|j|)Nrirrjrk)rOr{rrrrrlrrrrmrnrorprq) r$r\rercrsr]r7rgrtrrrr get_statuss   zAWSQueryConnection.get_status)NNTNNNNNNrNr~NTNr)Nr~rX)r~NrX)r?r@rAr[rrlr%rrWrOr`rgruryrz __classcell__rrrVrrT9s*  *  rT);rBrrrr4rrrr*xml.saxrorKrrr boto.utils boto.handler boto.cacertsrr boto.compatrrr r r boto.exceptionr r rr boto.providerrboto.resultsetrrr rr ImportErrorrGdummy_threadingallr4rrcrdirnameabspathcacerts__file__robjectr!r9r]rwr}rTrrrrsp)               "jeT