(self)
| 65 | @requires_crt() |
| 66 | class TestCRTTransferManager(unittest.TestCase): |
| 67 | def setUp(self): |
| 68 | self.region = 'us-west-2' |
| 69 | self.bucket = "test_bucket" |
| 70 | self.s3express_bucket = 's3expressbucket--usw2-az5--x-s3' |
| 71 | self.mrap_accesspoint = ( |
| 72 | 'arn:aws:s3::123456789012:accesspoint/mfzwi23gnjvgw.mrap' |
| 73 | ) |
| 74 | self.mrap_bucket = 'mfzwi23gnjvgw.mrap' |
| 75 | self.key = "test_key" |
| 76 | self.expected_content = b'my content' |
| 77 | self.expected_download_content = b'new content' |
| 78 | self.files = FileCreator() |
| 79 | self.filename = self.files.create_file( |
| 80 | 'myfile', self.expected_content, mode='wb' |
| 81 | ) |
| 82 | self.expected_path = "/" + self.bucket + "/" + self.key |
| 83 | self.expected_host = f"s3.{self.region}.amazonaws.com" |
| 84 | self.expected_s3express_host = f'{self.s3express_bucket}.s3express-usw2-az5.us-west-2.amazonaws.com' |
| 85 | self.expected_s3express_path = f'/{self.key}' |
| 86 | self.expected_mrap_host = ( |
| 87 | f'{self.mrap_bucket}.accesspoint.s3-global.amazonaws.com' |
| 88 | ) |
| 89 | self.expected_mrap_path = f"/{self.key}" |
| 90 | self.s3_request = mock.Mock(awscrt.s3.S3Request) |
| 91 | self.s3_crt_client = mock.Mock(awscrt.s3.S3Client) |
| 92 | self.s3_crt_client.make_request.side_effect = ( |
| 93 | self._simulate_make_request_side_effect |
| 94 | ) |
| 95 | self.session = Session() |
| 96 | self.session.set_config_variable('region', self.region) |
| 97 | self.request_serializer = s3transfer.crt.BotocoreCRTRequestSerializer( |
| 98 | self.session |
| 99 | ) |
| 100 | self.transfer_manager = s3transfer.crt.CRTTransferManager( |
| 101 | crt_s3_client=self.s3_crt_client, |
| 102 | crt_request_serializer=self.request_serializer, |
| 103 | ) |
| 104 | self.record_subscriber = RecordingSubscriber() |
| 105 | |
| 106 | def tearDown(self): |
| 107 | self.files.remove_all() |
nothing calls this directly
no test coverage detected