Method _main

awscli/s3transfer/download.py:596–721

Downloads an object and places content into io queue :param client: The client to use when calling GetObject :param bucket: The bucket to download from :param key: The key to download from :param fileobj: The file handle to write content to :param exta_args:

(
        self,
        client,
        bucket,
        key,
        fileobj,
        extra_args,
        callbacks,
        max_attempts,
        download_output_manager,
        io_chunksize,
        start_index=0,
        part_index=0,
        bandwidth_limiter=None,
        checksum_combiner=None,
    )

class GetObjectTask(Task):
    def _main(
        self,
        client,
        bucket,
        key,
        fileobj,
        extra_args,
        callbacks,
        max_attempts,
        download_output_manager,
        io_chunksize,
        start_index=0,
        part_index=0,
        bandwidth_limiter=None,
        checksum_combiner=None,
    ):
        """Downloads an object and places content into io queue

        :param client: The client to use when calling GetObject
        :param bucket: The bucket to download from
        :param key: The key to download from
        :param fileobj: The file handle to write content to
        :param exta_args: Any extra arguments to include in GetObject request
        :param callbacks: List of progress callbacks to invoke on download
        :param max_attempts: The number of retries to do when downloading
        :param download_output_manager: The download output manager associated
            with the current download.
        :param io_chunksize: The size of each io chunk to read from the
            download stream and queue in the io queue.
        :param start_index: The location in the file to start writing the
            content of the key to.
        :param part_index: The part number for this ranged download.
        :param bandwidth_limiter: The bandwidth limiter to use when throttling
            the downloading of data in streams.
        :param checksum_combiner: Optional FullObjectChecksumCombiner for
            full object checksum validation on multipart downloads.
        """
        last_exception = None
        for i in range(max_attempts):
            try:
                current_index = start_index
                response = client.get_object(
                    Bucket=bucket, Key=key, **extra_args
                )
                self._validate_content_range(
                    extra_args.get('Range'),
                    response.get('ContentRange'),
                )
                # When doing full object checksum combining and botocore
                # hasn't already wrapped the body with a checksum
                # calculator, wrap it in StreamingChecksumBody ourselves
                # so the CRC is computed as data is read. We pass
                # expected=None since we validate at the full object
                # level, not per-part.
                body = response['Body']
                if checksum_combiner is not None and not hasattr(
                    body, 'checksum'
                ):