| 34 | |
| 35 | |
| 36 | class ClientFactory: |
| 37 | def __init__(self, session): |
| 38 | self._session = session |
| 39 | |
| 40 | def create_client(self, params, is_source_client=False): |
| 41 | create_client_kwargs = {'verify': params['verify_ssl']} |
| 42 | if params.get('sse') == 'aws:kms': |
| 43 | create_client_kwargs['config'] = Config(signature_version='s3v4') |
| 44 | region = params['region'] |
| 45 | endpoint_url = params['endpoint_url'] |
| 46 | if is_source_client and params['source_region']: |
| 47 | if params['paths_type'] == 's3s3': |
| 48 | region = params['source_region'] |
| 49 | endpoint_url = None |
| 50 | |
| 51 | create_client_kwargs['region_name'] = region |
| 52 | create_client_kwargs['endpoint_url'] = endpoint_url |
| 53 | return self._session.create_client('s3', **create_client_kwargs) |
| 54 | |
| 55 | |
| 56 | class TransferManagerFactory: |
no outgoing calls