Server : Apache/2.4.62 (Unix) OpenSSL/1.0.2k-fips System : Linux server1.richineiserver.com 3.10.0-1160.119.1.el7.x86_64 #1 SMP Tue Jun 4 14:43:51 UTC 2024 x86_64 User : fdshops ( 1003) PHP Version : 8.2.21 Disable Function : NONE Directory : /lib/python2.7/site-packages/requests_toolbelt/ |
�
ӵ Yc @ s\ d Z d d l m Z d d l m Z m Z d e f d � � YZ d e f d � � YZ d S(
s
requests_toolbelt.streaming_iterator
====================================
This holds the implementation details for the :class:`StreamingIterator`. It
is designed for the case where you, the user, know the size of the upload but
need to provide the data as an iterator. This class will allow you to specify
the size and stream the data without using a chunked transfer-encoding.
i����( t super_leni ( t
CustomBytesIOt encode_witht StreamingIteratorc B s& e Z d Z d d � Z d d � Z RS( s
This class provides a way of allowing iterators with a known size to be
streamed instead of chunked.
In requests, if you pass in an iterator it assumes you want to use
chunked transfer-encoding to upload the data, which not all servers
support well. Additionally, you may want to set the content-length
yourself to avoid this but that will not work. The only way to preempt
requests using a chunked transfer-encoding and forcing it to stream the
uploads is to mimic a very specific interace. Instead of having to know
these details you can instead just use this class. You simply provide the
size and iterator and pass the instance of StreamingIterator to requests
via the data parameter like so:
.. code-block:: python
from requests_toolbelt import StreamingIterator
import requests
# Let iterator be some generator that you already have and size be
# the size of the data produced by the iterator
r = requests.post(url, data=StreamingIterator(size, iterator))
You can also pass file-like objects to :py:class:`StreamingIterator` in
case requests can't determize the filesize itself. This is the case with
streaming file objects like ``stdin`` or any sockets. Wrapping e.g. files
that are on disk with ``StreamingIterator`` is unnecessary, because
requests can determine the filesize itself.
Naturally, you should also set the `Content-Type` of your upload
appropriately because the toolbelt will not attempt to guess that for you.
s utf-8c C s| t | � | _ | j d k r- t d � � n | j | _ | | _ | | _ t | d � rf | | _ n t | | � | _ d S( Ni s1 The size of the upload must be a positive integert read( t intt sizet
ValueErrort lent encodingt iteratort hasattrt _filet _IteratorAsBinaryFile( t selfR R
R ( ( sH /usr/lib/python2.7/site-packages/requests_toolbelt/streaming_iterator.pyt __init__7 s i����c C s t | j j | � | j � S( N( R R R R ( R R ( ( sH /usr/lib/python2.7/site-packages/requests_toolbelt/streaming_iterator.pyR O s ( t __name__t
__module__t __doc__R R ( ( ( sH /usr/lib/python2.7/site-packages/requests_toolbelt/streaming_iterator.pyR s # R
c B s2 e Z d d � Z d � Z d � Z d d � Z RS( s utf-8c C s" | | _ | | _ t � | _ d S( N( R
R R t _buffer( R R
R ( ( sH /usr/lib/python2.7/site-packages/requests_toolbelt/streaming_iterator.pyR T s c C s6 y t t | j � | j � SWn t k
r1 d SXd S( Nt ( R t nextR
R t
StopIteration( R ( ( sH /usr/lib/python2.7/site-packages/requests_toolbelt/streaming_iterator.pyt
_get_bytes_ s
c C se | j j � | t | j � } t } x8 | d k r` | r` | j � } | | j j | � 8} q) Wd S( Ni ( R t smart_truncateR t TrueR t append( R R t amount_to_loadt bytes_to_append( ( sH /usr/lib/python2.7/site-packages/requests_toolbelt/streaming_iterator.pyt _load_bytese s
i����c C sE t | � } | d k r( d j | j � S| j | � | j j | � S( Ni����R ( R t joinR
R R R ( R R ( ( sH /usr/lib/python2.7/site-packages/requests_toolbelt/streaming_iterator.pyR n s
( R R R R R R ( ( ( sH /usr/lib/python2.7/site-packages/requests_toolbelt/streaming_iterator.pyR
S s N( R t requests.utilsR t multipart.encoderR R t objectR R
( ( ( sH /usr/lib/python2.7/site-packages/requests_toolbelt/streaming_iterator.pyt <module> s A