h|dZddlmZmZddlmZddlmZddlm Z m Z ddl m Z ddl mZmZdZd ZGd d e Zy ) aY requests_futures ~~~~~~~~~~~~~~~~ This module provides a small add-on for the requests http library. It makes use of python 3.3's concurrent.futures or the futures backport for previous releases of python. from requests_futures.sessions import FuturesSession session = FuturesSession() # request is run in the background future = session.get('http://httpbin.org/get') # ... do other stuff ... # wait for the request to complete, if it hasn't already response = future.result() print('response status: {0}'.format(response.status_code)) print(response.content) )ProcessPoolExecutorThreadPoolExecutor)partial) getLogger) PickleErrordumps)Session)DEFAULT_POOLSIZE HTTPAdapterc,||i|}|||xs|S)z6A global top-level is required for ProcessPoolExecutor)selfsupbackground_callbackargs_kwargs_resps c/var/www/betterdocs.net/sherlock_api/venv/lib/python3.12/site-packages/requests_futures/sessions.pywraprs#  ! !D tT * 2d2zsCannot pickle function. Refer to documentation: https://github.com/ross/requests-futures/#using-processpoolexecutorceZdZ d fd ZdZfdZfdZfdZfdZd fd Z d fd Z d fd Z fd Z xZ S)FuturesSessioncNi}tt| |i||du|_|)t |}|t kDr|j ||d|j |xsi|r6|jdtdi||jdtdi|||_ ||_ y)a*Creates a FuturesSession Notes ~~~~~ * `ProcessPoolExecutor` may be used with Python > 3.4; see README for more information. * If you provide both `executor` and `max_workers`, the latter is ignored and provided executor is used as is. N) max_workers)pool_connections pool_maxsizezhttps://zhttp://r ) superr__init___owned_executorrr updatemountr executorsession) rr"rr#adapter_kwargsargskwargs_adapter_kwargs __class__s rrzFuturesSession.__init__,s& nd,d=f='4/  )kBH--&&,7(3 ~34  JJz;#A#A B JJy+"@"@ A   rc|jr|jj}nttj|}|j dd}|rBt |j j}|jdtt|||}t|jtr t||jj$|g|i|S#ttf$rt!t"wxYw)apMaintains the existing api for Session.request. Used by all of the higher level methods, e.g. Session.get. The background_callback param allows you to do some processing on the response in the background, e.g. call resp.json() so that json parsing happens in the background thread. :rtype : concurrent.futures.Future rNzS`background_callback` is deprecated and will be removed in 1.0, use `hooks` instead)r#requestrr poprr(__name__warningr isinstancer"rr TypeErrorr RuntimeError PICKLE_ERRORsubmit)rr%r&funcrloggers rr*zFuturesSession.requestVs <<<<''D7??D1D$jj)>E t~~667F NN6 4t-@AD dmm%8 9 1d $t}}##D:4:6::{+ 1"<00 1s / CC9cxtt| |jr|jj yyN)rrcloserr"shutdown)rr(s rr7zFuturesSession.closeys. nd)+    MM " " $ rc ,tt| |fi|S)z Sends a GET request. Returns :class:`Future` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype : concurrent.futures.Future )rrgetrurlr&r(s rr:zFuturesSession.get~s^T.s=f==rc ,tt| |fi|S)zSends a OPTIONS request. Returns :class:`Future` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype : concurrent.futures.Future )rroptionsr;s rr>zFuturesSession.optionss^T23A&AArc ,tt| |fi|S)zSends a HEAD request. Returns :class:`Future` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype : concurrent.futures.Future )rrheadr;s rr@zFuturesSession.heads^T/>v>>rc 2tt| |f||d|S)aSends a POST request. Returns :class:`Future` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, list of tuples, bytes, or file-like object to send in the body of the :class:`Request`. :param json: (optional) json to send in the body of the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype : concurrent.futures.Future )datajson)rrpost)rr<rBrCr&r(s rrDzFuturesSession.posts.^T/   )/  rc 0tt| |fd|i|S)a|Sends a PUT request. Returns :class:`Future` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, list of tuples, bytes, or file-like object to send in the body of the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype : concurrent.futures.Future rB)rrputrr<rBr&r(s rrFzFuturesSession.puts!^T.sHHHHrc 0tt| |fd|i|S)a~Sends a PATCH request. Returns :class:`Future` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, list of tuples, bytes, or file-like object to send in the body of the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype : concurrent.futures.Future rB)rrpatchrGs rrIzFuturesSession.patchs!^T0J4J6JJrc ,tt| |fi|S)zSends a DELETE request. Returns :class:`Future` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype : concurrent.futures.Future )rrdeleter;s rrKzFuturesSession.deletes^T1#@@@r)NNN)NNr6)r, __module__ __qualname__rr*r7r:r>r@rDrFrIrK __classcell__)r(s@rrr+sO (T!;F% >B?   I KAArrN)__doc__concurrent.futuresrr functoolsrloggingrpicklerrrequestsr requests.adaptersr r rr1rr rrrWs?(G%;3B ZAWZAr