← Back
Editing: appengine.pyc
� �Rec @@ sx d Z d d l m Z d d l Z d d l Z d d l Z d d l m Z d d l m Z m Z m Z m Z m Z m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z y d d l m Z Wn e k r� d Z n Xe j e � Z d e f d � � YZ d e f d � � YZ! d e f d � � YZ" e j# Z# e j$ Z$ e j% Z% e j& Z& e j' Z' d S( s[ This module provides a pool manager that uses Google App Engine's `URLFetch Service <https://cloud.google.com/appengine/docs/python/urlfetch>`_. Example usage:: from pip._vendor.urllib3 import PoolManager from pip._vendor.urllib3.contrib.appengine import AppEngineManager, is_appengine_sandbox if is_appengine_sandbox(): # AppEngineManager uses AppEngine's URLFetch API behind the scenes http = AppEngineManager() else: # PoolManager uses a socket-level API behind the scenes http = PoolManager() r = http.request('GET', 'https://google.com/') There are `limitations <https://cloud.google.com/appengine/docs/python/urlfetch/#Python_Quotas_and_limits>`_ to the URLFetch service and it may not be the best choice for your application. There are three options for using urllib3 on Google App Engine: 1. You can use :class:`AppEngineManager` with URLFetch. URLFetch is cost-effective in many circumstances as long as your usage is within the limitations. 2. You can use a normal :class:`~urllib3.PoolManager` by enabling sockets. Sockets also have `limitations and restrictions <https://cloud.google.com/appengine/docs/python/sockets/ #limitations-and-restrictions>`_ and have a lower free quota than URLFetch. To use sockets, be sure to specify the following in your ``app.yaml``:: env_variables: GAE_USE_SOCKETS_HTTPLIB : 'true' 3. If you are using `App Engine Flexible <https://cloud.google.com/appengine/docs/flexible/>`_, you can use the standard :class:`PoolManager` without any configuration or special environment variables. i ( t absolute_importNi ( t urljoin( t HTTPErrort HTTPWarningt MaxRetryErrort ProtocolErrort TimeoutErrort SSLError( t RequestMethods( t HTTPResponse( t Timeout( t Retryi ( t _appengine_environ( t urlfetcht AppEnginePlatformWarningc B@ s e Z RS( ( t __name__t __module__( ( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyR G s t AppEnginePlatformErrorc B@ s e Z RS( ( R R ( ( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyR K s t AppEngineManagerc B@ sk e Z d Z d d e e d � Z d � Z d � Z d d d e e j d � Z d � Z d � Z d � Z RS( s Connection manager for Google App Engine sandbox applications. This manager uses the URLFetch service directly instead of using the emulated httplib, and is subject to URLFetch limitations as described in the App Engine documentation `here <https://cloud.google.com/appengine/docs/python/urlfetch>`_. Notably it will raise an :class:`AppEnginePlatformError` if: * URLFetch is not available. * If you attempt to use this on App Engine Flexible, as full socket support is available. * If a request size is more than 10 megabytes. * If a response size is more than 32 megabtyes. * If you use an unsupported request method such as OPTIONS. Beyond those cases, it will raise normal urllib3 errors. c C@ s] t s t d � � n t j d t � t j | | � | | _ | | _ | pS t j | _ d S( Ns. URLFetch is not available in this environment.s� urllib3 is using URLFetch on Google App Engine sandbox instead of sockets. To use sockets directly instead of URLFetch see https://urllib3.readthedocs.io/en/latest/reference/urllib3.contrib.html.( R R t warningst warnR R t __init__t validate_certificatet urlfetch_retriesR t DEFAULTt retries( t selft headersR R R ( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyR c s c C@ s | S( N( ( R ( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyt __enter__| s c C@ s t S( N( t False( R t exc_typet exc_valt exc_tb( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyt __exit__ s c K@ sk | j | | � } yv | o0 | j d k o0 | j } t j | d | d | d | pT i d t d | j oi | d | j | � d | j �} Wn"t j k r� } t | | � � n� t j k r� } d t | � k r� t d | � � n t | � � n� t j k r?} d t | � k r0t | | d | �� n t | � � nn t j k rc} t d | � � nJ t j k r�} t | � � n) t j k r�} t d | | � � n X| j | d | | �} | o�| j � } | r�| j r| j rt | | d � � q�| j d k r d } n y" | j | | d | d | �} Wn0 t k rp| j rlt | | d � � n | SX| j | � t j d | | � t | | � } | j | | | | d | d | d | | �Sn t | j d � � } | j! | | j | � rg| j | | d | d | �} t j d | � | j" | � | j | | d | d | d | d | d | | �S| S( Ni t payloadt methodR t allow_truncatedt follow_redirectst deadlineR s too largesO URLFetch request too large, URLFetch only supports requests up to 10mb in size.s Too many redirectst reasonsP URLFetch response too large, URLFetch only supportsresponses up to 32mb in size.s$ URLFetch does not support method: %sR s too many redirectsi/ t GETt responset _pools Redirecting %s -> %st redirectt timeouts Retry-Afters Retry: %st body(# t _get_retriesR+ t totalR t fetchR R t _get_absolute_timeoutR t DeadlineExceededErrorR t InvalidURLErrort strR R t DownloadErrorR t ResponseTooLargeErrort SSLCertificateErrorR t InvalidMethodErrort# _urlfetch_response_to_http_responset get_redirect_locationt raise_on_redirectt statust incrementt sleep_for_retryt logt debugR t urlopent boolt getheadert is_retryt sleep( R R# t urlR- R R R+ R, t response_kwR% R) t et http_responset redirect_locationt redirect_urlt has_retry_after( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyRA � s� c K@ s� t � r7 | j j d � } | d k r7 | j d =q7 n | j j d � } | d k r� | j d � } | j d � d j | � | j d <n t d t j | j � d | j d | j d | j | � } t d t j | j � d | j d | j d | | � S( Ns content-encodingt deflates transfer-encodingt chunkedt ,R- t msgR R< t original_response( t is_prod_appengineR t gett splitt removet joinR t iot BytesIOt contentt header_msgt status_code( R t urlfetch_respRG t content_encodingt transfer_encodingt encodingsRQ ( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyR9 � s* c C@ s^ | t j k r d St | t � rZ | j d k s@ | j d k rS t j d t � n | j S| S( Nsd URLFetch does not support granular timeout settings, reverting to total or default URLFetch timeout.( R t DEFAULT_TIMEOUTt Nonet isinstancet _readt _connectR R R R/ ( R R, ( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyR1 s c C@ sb t | t � s0 t j | d | d | j �} n | j sK | j sK | j r^ t j d t � n | S( NR+ t defaultsh URLFetch only supports total retries and does not recognize connect, read, or redirect retry parameters.( Rb R t from_intR t connectt readR+ R R R ( R R R+ ( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyR. & s ! N( R R t __doc__Ra t TrueR R R! R R` RA R9 R1 R. ( ( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyR O s j $ (( Ri t __future__R RW t loggingR t packages.six.moves.urllib.parseR t exceptionsR R R R R R t requestR R) R t util.timeoutR t util.retryR t R t google.appengine.apiR t ImportErrorRa t getLoggerR R? R R R t is_appenginet is_appengine_sandboxt is_local_appengineRR t is_prod_appengine_mvms( ( ( s� /builddir/build/BUILDROOT/alt-python27-pip-20.2.4-5.el8.x86_64/opt/alt/python27/lib/python2.7/site-packages/pip/_vendor/urllib3/contrib/appengine.pyt <module>' s0 . �
Save File
Cancel