Method _multipart_upload_to_s3

awscli/customizations/codedeploy/push.py:212–245

(self, params, bundle, size_remaining)

        return size

    def _multipart_upload_to_s3(self, params, bundle, size_remaining):
        create_response = self.s3.create_multipart_upload(
            Bucket=params.bucket, Key=params.key
        )
        upload_id = create_response['UploadId']
        try:
            part_num = 1
            multipart_list = []
            bundle.seek(0)
            while size_remaining > 0:
                data = bundle.read(MULTIPART_LIMIT)
                upload_response = self.s3.upload_part(
                    Bucket=params.bucket,
                    Key=params.key,
                    UploadId=upload_id,
                    PartNumber=part_num,
                    Body=BytesIO(data),
                )
                multipart_list.append(
                    {'PartNumber': part_num, 'ETag': upload_response['ETag']}
                )
                part_num += 1
                size_remaining -= len(data)
            return self.s3.complete_multipart_upload(
                Bucket=params.bucket,
                Key=params.key,
                UploadId=upload_id,
                MultipartUpload={'Parts': multipart_list},
            )
        except ClientError as e:
            self.s3.abort_multipart_upload(
                Bucket=params.bucket, Key=params.key, UploadId=upload_id
            )
            raise e

    def _register_revision(self, params):
        revision = {