ReW @ s d Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z m Z m
Z
m Z m Z d d l
m Z m Z m Z m Z d d l m Z m Z m Z d d
l m Z m Z d d l m Z m Z m Z d d l m Z m Z m Z m! Z! d d
l" m# Z# d d l$ m% Z% d d l m& Z& m' Z' m( Z( m) Z) m* Z* d d l+ m, Z, d d l m- Z- e d d Z. e d d Z/ Gd d d e0 Z1 Gd d d e1 Z2 d d Z3 d S) z
requests.session
~~~~~~~~~~~~~~~~
This module provides a Session object to manage and persist settings across
requests (cookies, auth, proxies).
N)Mapping)datetime )_basic_auth_str) cookielib OrderedDicturljoinurlparse builtin_str)cookiejar_from_dictextract_cookies_to_jarRequestsCookieJar
merge_cookies)RequestPreparedRequestDEFAULT_REDIRECT_LIMIT)
default_hooks
dispatch_hook)to_key_val_listdefault_headersto_native_string)TooManyRedirects
InvalidSchemaChunkedEncodingErrorContentDecodingError)CaseInsensitiveDict) HTTPAdapter) requote_uriget_environ_proxiesget_netrc_authshould_bypass_proxiesget_auth_from_url)codes)REDIRECT_STATIc C s | d k r | S| d k r | St | t o; t | t sB | S| t | } | j t | x0 | j D]" \ } } | d k rt | | =qt qt Wt d d | j D } | S)z
Determines appropriate setting for a given request, taking into account the
explicit setting on that request, and the setting in the session. If a
setting is a dictionary, they will be merged together using `dict_class`
Nc s s- | ]# \ } } | d k r | | f Vq d S)N ).0kvr$ r$ 8/tmp/pip-ztkk0jow-build/pip/_vendor/requests/sessions.py C s z merge_setting..)
isinstancer r updateitemsdict)request_settingsession_setting
dict_classmerged_settingr& r' r$ r$ r(
merge_setting' s r2 c C sZ | d k s! | j d g k r% | S| d k sF | j d g k rJ | St | | | S)z
Properly merges both requests and session hooks.
This is necessary because when request_hooks == {'response': []}, the
merge breaks Session hooks entirely.
Nresponse)getr2 )
request_hooks
session_hooksr0 r$ r$ r( merge_hooksH s
!!r7 c @ sC e Z d Z d d d d d d d Z d d Z d d Z d S)
SessionRedirectMixinFNTc c s d } x| j r| j } y | j Wn. t t t f k
rY | j j d d Yn X| | j k r t d | j n | j
| j d }
| j } |
j
d r t | j } d | j |
f }
n t |
}
|
j }
t |
j st | j t |
}
n t |
}
t |
| _ | j t j k rW| d k rWd } n | j t j k r~| d k r~d } n | j t j k r| d
k rd } n | | _ | j t j t j f k rd | j k r| j d =n d | _ n | j } y | d
=Wn t k
rYn Xt | j | | j | j j! | j" | j# | j | j$ | | } | j% | | | } | j& | d | d | d | d | d | d d } t | j" | | j | d 7} | Vq Wd S)z6Receives a Response. Returns a generator of Responses.r decode_contentFzExceeded %s redirects.locationz//z%s:%sHEADGETPOSTzContent-LengthNCookiestreamtimeoutverifycertproxiesallow_redirectsr )' is_redirectcopycontentr r RuntimeErrorrawread
max_redirectsr closeheadersmethod
startswithr urlschemegeturlnetlocr r r status_coder" see_otherfoundmoved temporaryresumebodyKeyErrorr _cookiesr+ cookiesprepare_cookiesrebuild_proxies rebuild_authsend)selfrespreqr? r@ rA rB rC iprepared_requestrP rN parsed_rurlparsedrM r$ r$ r( resolve_redirectsY sn
z&SessionRedirectMixin.resolve_redirectsc C s | j } | j } d | k r[ t | j j } t | } | j | j k r[ | d =q[ n | j rp t | n d } | d k r | j | n d S)z
When being redirected we may want to strip authentication from the
request to avoid leaking credentials. This method intelligently removes
and reapplies authentication where possible to avoid credential loss.
AuthorizationN)rM rP r requesthostname trust_envr prepare_auth)rb rf r3 rM rP original_parsedredirect_parsednew_authr$ r$ r( r` s
z!SessionRedirectMixin.rebuild_authc C s | j } | j } t | j } | d k r9 | j n i } | j r t | r t | } | j | } | r | j | | | q n d | k r | d =n y t
| | \ } }
Wn t k
r d \ } }
Yn X| r|
rt | |
| d >> import requests
>>> s = requests.Session()
>>> s.get('http://httpbin.org/get')
200
rM r] authr@ rC hooksparamsrA rB prefetchadaptersr? rm rK c C s t | _ d | _ i | _ t | _ i | _ d | _ d | _ d | _ t
| _ d | _ t
i | _ t | _ | j d t | j d t d S)NFTzhttps://zhttp://)r rM r| rC r r} r~ r? rA rB r rK rm r r] r r mountr )rb r$ r$ r( __init__ s zSession.__init__c C s | S)Nr$ )rb r$ r$ r( __enter__? s zSession.__enter__c G s | j d S)N)rL )rb argsr$ r$ r( __exit__B s zSession.__exit__c C s! | j p i } t | t j s0 t | } n t t t | j | } | j } | j r | r | j r t | j
} n t } | j d | j
j d | j
d | j d | j d t | j | j d t d t | j | j d t | | j d | d
t | j | j | S) ab Constructs a :class:`PreparedRequest ` for
transmission and returns it. The :class:`PreparedRequest` has settings
merged from the :class:`Request ` instance and those of the
:class:`Session`.
:param request: :class:`Request` instance to prepare with this
session's settings.
rN rP filesdatarM r0 r~ r| r] r} )r] r* r CookieJarr r r
r| rm r rP r preparerN upperr r r2 rM r r~ r7 r} )rb rk r] merged_cookiesr| pr$ r$ r( prepare_requestE s( zSession.prepare_requestNTc C s t | } t d | j d | d | d | d | p9 i d | pE i d | d | d | } | j | } | pu i } | j rt | p i } x* | j D] \ } } | j | | q W| r | d
k r t j j
d } n | r| d
k rt j j
d } qn t | | j } t |
| j
}
t | | j } t | | j } i |
d
6| d 6| d 6| d 6| d 6|
d 6} | j | | } | S)a4 Constructs a :class:`Request `, prepares it and sends it.
Returns :class:`Response ` object.
:param method: method for the new :class:`Request` object.
:param url: URL for the new :class:`Request` object.
:param params: (optional) Dictionary or bytes to be sent in the query
string for the :class:`Request`.
:param data: (optional) Dictionary or bytes to send in the body of the
:class:`Request`.
:param headers: (optional) Dictionary of HTTP Headers to send with the
:class:`Request`.
:param cookies: (optional) Dict or CookieJar object to send with the
:class:`Request`.
:param files: (optional) Dictionary of 'filename': file-like-objects
for multipart encoding upload.
:param auth: (optional) Auth tuple or callable to enable
Basic/Digest/Custom HTTP Auth.
:param timeout: (optional) Float describing the timeout of the
request in seconds.
:param allow_redirects: (optional) Boolean. Set to True by default.
:param proxies: (optional) Dictionary mapping protocol to the URL of
the proxy.
:param stream: (optional) whether to immediately download the response
content. Defaults to ``False``.
:param verify: (optional) if ``True``, the SSL cert will be verified.
A CA_BUNDLE path can also be provided.
:param cert: (optional) if String, path to ssl client cert file (.pem).
If Tuple, ('cert', 'key') pair.
rN rP rM r r r~ r| r] r} FREQUESTS_CA_BUNDLECURL_CA_BUNDLEr? r@ rA rB rC rD )r
r r r rm r r, rr osenvironr4 r2 rC r? rA rB ra )rb rN rP r~ r rM r] r r| r@ rD rC r} r? rA rB rd prep env_proxiesr& r' send_kwargsrc r$ r$ r( rk l sD ,
zSession.requestc K s# | j d d | j d | | S)zSends a GET request. Returns :class:`Response` object.
:param url: URL for the new :class:`Request` object.
:param \*\*kwargs: Optional arguments that ``request`` takes.
rD Tr< )rr rk )rb rP kwargsr$ r$ r( r4 s z Session.getc K s# | j d d | j d | | S)zSends a OPTIONS request. Returns :class:`Response` object.
:param url: URL for the new :class:`Request` object.
:param \*\*kwargs: Optional arguments that ``request`` takes.
rD TOPTIONS)rr rk )rb rP r r$ r$ r( options s zSession.optionsc K s# | j d d | j d | | S)zSends a HEAD request. Returns :class:`Response` object.
:param url: URL for the new :class:`Request` object.
:param \*\*kwargs: Optional arguments that ``request`` takes.
rD Fr; )rr rk )rb rP r r$ r$ r( head s z Session.headc K s | j d | d | | S)a8 Sends a POST request. Returns :class:`Response` object.
:param url: URL for the new :class:`Request` object.
:param data: (optional) Dictionary, bytes, or file-like object to send in the body of the :class:`Request`.
:param \*\*kwargs: Optional arguments that ``request`` takes.
r= r )rk )rb rP r r r$ r$ r( post s z Session.postc K s | j d | d | | S)a7 Sends a PUT request. Returns :class:`Response` object.
:param url: URL for the new :class:`Request` object.
:param data: (optional) Dictionary, bytes, or file-like object to send in the body of the :class:`Request`.
:param \*\*kwargs: Optional arguments that ``request`` takes.
PUTr )rk )rb rP r r r$ r$ r( put s z Session.putc K s | j d | d | | S)a9 Sends a PATCH request. Returns :class:`Response` object.
:param url: URL for the new :class:`Request` object.
:param data: (optional) Dictionary, bytes, or file-like object to send in the body of the :class:`Request`.
:param \*\*kwargs: Optional arguments that ``request`` takes.
PATCHr )rk )rb rP r r r$ r$ r( patch s z
Session.patchc K s | j d | | S)zSends a DELETE request. Returns :class:`Response` object.
:param url: URL for the new :class:`Request` object.
:param \*\*kwargs: Optional arguments that ``request`` takes.
DELETE)rk )rb rP r r$ r$ r( delete s zSession.deletec
K s | j d | j | j d | j | j d | j | j d | j t | t sj t d n | j d d } | j d } | j d } | j d } | j d } | j d } | j
} | j d | j }
t
j } |
j | | } t
j | | _ t d
| | | } | j rdx- | j D] }
t | j |
j |
j q>Wn t | j | | j | j | | d | d | d | d | d | } | rd d | D n g } | r| j d
| | j } | | _ n | s| j n | S)z Send a given PreparedRequest.r? rA rB rC z#You can only send PreparedRequests.rD Tr@ rP r3 c S s g | ] } | q Sr$ r$ )r% rc r$ r$ r(
I s z Session.send..r )rr r? rA rB rC r* r
ValueErrorpopr4 r} get_adapterrP r utcnowra elapsedr historyr r] rk rI ri insertrG )rb rk r rD r? r@ rA rB rC r} adapterstartrrc genr r$ r$ r( ra sH
z Session.sendc C sM x6 | j j D]% \ } } | j j | r | Sq Wt d | d S)z>Returns the appropriate connnection adapter for the given URL.z*No connection adapters were found for '%s'N)r r, lowerrO r )rb rP prefixr r$ r$ r( r X s zSession.get_adapterc C s( x! | j j D] } | j q Wd S)z+Closes all adapters and as such the sessionN)r valuesrL )rb r' r$ r$ r( rL b s z
Session.closec sW | | j < f d d | j D } x' | D] } | j j | | j | .N)r r )rb r r keys_to_movekeyr$ )r r( r g s
z
Session.mountc s t f d d j D S)Nc 3 s' | ] } | t | d f Vq d S)N)getattr)r% attr)rb r$ r( r) s s z'Session.__getstate__..)r- __attrs__)rb r$ )rb r( __getstate__r s zSession.__getstate__c C s1 x* | j D] \ } } t | | | q
Wd S)N)r, setattr)rb stater valuer$ r$ r( __setstate__u s zSession.__setstate__)rx ry rz __doc__r r r r r rk r4 r r r r r r ra r rL r r r r$ r$ r$ r( r{ sD 3 (S
G
r{ c C s t S)z2Returns a :class:`Session` for context-management.)r{ r$ r$ r$ r( sessionz s r )4r r collectionsr r r| r compatr r r r r
r] r r r
r modelsr r r r} r r utilsr r r
exceptionsr r r r
structuresr r r r r r r r! status_codesr" r# r2 r7 objectr8 r{ r r$ r$ r$ r(
s* (" "(!