(self, bucket, key, filename, extra_args, callback)
| 866 | raise RetriesExceededError(last_exception) |
| 867 | |
| 868 | def _do_get_object(self, bucket, key, filename, extra_args, callback): |
| 869 | response = self._client.get_object( |
| 870 | Bucket=bucket, Key=key, **extra_args |
| 871 | ) |
| 872 | streaming_body = StreamReaderProgress(response['Body'], callback) |
| 873 | with self._osutil.open(filename, 'wb') as f: |
| 874 | for chunk in iter(lambda: streaming_body.read(8192), b''): |
| 875 | f.write(chunk) |
| 876 | |
| 877 | def _object_size(self, bucket, key, extra_args): |
| 878 | return self._client.head_object(Bucket=bucket, Key=key, **extra_args)[ |
no test coverage detected