def get_file(self, fp, headers=None, cb=None, num_cb=10,
                 torrent=False, version_id=None, override_num_retries=None,
                 response_headers=None):
        """
        Retrieves a file from an S3 Key

        :type fp: file
        :param fp: File pointer to put the data into

        :type headers: string
        :param: headers to send when retrieving the files

        :type cb: function
        :param cb: a callback function that will be called to report
                   progress on the upload.  The callback should accept
                   two integer parameters, the first representing the
                   number of bytes that have been successfully
                   transmitted to S3 and the second representing the
                   size of the to be transmitted object.

        :type cb: int
        :param num_cb: (optional) If a callback is specified with
                       the cb parameter this parameter determines the
                       granularity of the callback by defining
                       the maximum number of times the callback will
                       be called during the file transfer.

        :type torrent: bool
        :param torrent: Flag for whether to get a torrent for the file

        :type override_num_retries: int
        :param override_num_retries: If not None will override configured
                                     num_retries parameter for underlying GET.

        :type response_headers: dict
        :param response_headers: A dictionary containing HTTP headers/values
                                 that will override any headers associated with
                                 the stored object in the response.
                                 See http://goo.gl/EWOPb for details.
        """
        save_debug = self.bucket.connection.debug
        if self.bucket.connection.debug == 1:
            self.bucket.connection.debug = 0

        query_args = []
        if torrent:
            query_args.append('torrent')
            m = None
        else:
            m = md5()
        # If a version_id is passed in, use that.  If not, check to see
        # if the Key object has an explicit version_id and, if so, use that.
        # Otherwise, don't pass a version_id query param.
        if version_id is None:
            version_id = self.version_id
        if version_id:
            query_args.append('versionId=%s' % version_id)
        if response_headers:
            for key in response_headers:
                query_args.append('%s=%s' % (key, urllib.quote(response_headers[key])))
        query_args = '&'.join(query_args)
        self.open('r', headers, query_args=query_args,
                  override_num_retries=override_num_retries)

        data_len = 0
        if cb:
            if self.size is None:
                cb_size = 0
            else:
                cb_size = self.size
            if self.size is None and num_cb != -1:
                # If size is not available due to chunked transfer for example,
                # we'll call the cb for every 1MB of data transferred.
                cb_count = (1024 * 1024)/self.BufferSize
            elif num_cb > 1:
                cb_count = int(math.ceil(cb_size/self.BufferSize/(num_cb-1.0)))
            elif num_cb < 0:
                cb_count = -1
            else:
                cb_count = 0
            i = 0
            cb(data_len, cb_size)
        for bytes in self:
            fp.write(bytes)
            data_len += len(bytes)
            if m:
                m.update(bytes)
            if cb:
                if cb_size > 0 and data_len >= cb_size:
                    break
                i += 1
                if i == cb_count or cb_count == -1:
                    cb(data_len, cb_size)
                    i = 0
        if cb and (cb_count <= 1 or i > 0) and data_len > 0:
            cb(data_len, cb_size)
        if m:
            self.md5 = m.hexdigest()
        if self.size is None and not torrent and not headers.has_key("Range"):
            self.size = data_len
        self.close()
        self.bucket.connection.debug = save_debug
def get_file ( self , fp , headers = None , cb = None , num_cb = 10 , torrent = False , version_id = None , override_num_retries = None , response_headers = None ) : save_debug = self . bucket . connection . debug if self . bucket . connection . debug == 1 : self . bucket . connection . debug = 0 query_args = [ ] if torrent : query_args . append ( 'torrent' ) m = None else : m = md5 ( ) if version_id is None : version_id = self . version_id if version_id : query_args . append ( 'versionId=%s' % version_id ) if response_headers : for key in response_headers : query_args . append ( '%s=%s' % ( key , urllib . quote ( response_headers [ key ] ) ) ) query_args = '&' . join ( query_args ) self . open ( 'r' , headers , query_args = query_args , override_num_retries = override_num_retries ) data_len = 0 if cb : if self . size is None : cb_size = 0 else : cb_size = self . size if self . size is None and num_cb != - 1 : cb_count = ( 1024 * 1024 ) / self . BufferSize elif num_cb > 1 : cb_count = int ( math . ceil ( cb_size / self . BufferSize / ( num_cb - 1.0 ) ) ) elif num_cb < 0 : cb_count = - 1 else : cb_count = 0 i = 0 cb ( data_len , cb_size ) for bytes in self : fp . write ( bytes ) data_len += len ( bytes ) if m : m . update ( bytes ) if cb : if cb_size > 0 and data_len >= cb_size : break i += 1 if i == cb_count or cb_count == - 1 : cb ( data_len , cb_size ) i = 0 if cb and ( cb_count <= 1 or i > 0 ) and data_len > 0 : cb ( data_len , cb_size ) if m : self . md5 = m . hexdigest ( ) if self . size is None and not torrent and not headers . has_key ( "Range" ) : self . size = data_len self . close ( ) self . bucket . connection . debug = save_debug
Retrieves a file from an S3 Key

        :type fp: file
        :param fp: File pointer to put the data into

        :type headers: string
        :param: headers to send when retrieving the files

        :type cb: function
        :param cb: a callback function that will be called to report
                   progress on the upload.  The callback should accept
                   two integer parameters, the first representing the
                   number of bytes that have been successfully
                   transmitted to S3 and the second representing the
                   size of the to be transmitted object.

        :type cb: int
        :param num_cb: (optional) If a callback is specified with
                       the cb parameter this parameter determines the
                       granularity of the callback by defining
                       the maximum number of times the callback will
                       be called during the file transfer.

        :type torrent: bool
        :param torrent: Flag for whether to get a torrent for the file

        :type override_num_retries: int
        :param override_num_retries: If not None will override configured
                                     num_retries parameter for underlying GET.

        :type response_headers: dict
        :param response_headers: A dictionary containing HTTP headers/values
                                 that will override any headers associated with
                                 the stored object in the response.
                                 See http://goo.gl/EWOPb for details.