static AmazonTimestreamWrite get()

in aws-timestream-database/src/main/java/software/amazon/timestream/database/TimestreamClientFactory.java [30:71]

• 23 lines of code
• 4 McCabe index (conditional complexity)

    static AmazonTimestreamWrite get(final AmazonWebServicesClientProxy proxy, final Logger logger) {
        /*
         * From CFN team, it is recommended to use the production environment for all stages of resource handlers.
         *
         * Actually there is no way to distinguish prod and non-prod in resource lambda handlers during runtime
         * https://issues.amazon.com/issues/ULURU-1178. As done by most of the other teams, should simply use the
         * prod stage/region when creating client.
         *
         */
        String region = System.getenv("AWS_REGION");
        if (region == null) {
            region = DEFAULT_AWS_REGION;
        }
        logger.log("Creating AmazonTimestreamWriteClient in region " + region + "\n");

        /*
         * 1. Create a client and describe the endpoints. The credentials from users will be used and
         *   injected to the request. Note here the credentials from users should be used for discovering endpoints
         *   (instead of the credentials of the lambda handlers)
         */
        final DescribeEndpointsResult result;
        final DescribeEndpointsRequest discoveryRequest = new DescribeEndpointsRequest();
        try {
            final AmazonTimestreamWrite timestreamClient = buildWriteClientWithDisco(region);
            result = proxy.injectCredentialsAndInvoke(discoveryRequest, timestreamClient::describeEndpoints);
        } catch (final InternalServerException ex) {
            throw new CfnInternalFailureException(ex);
        } catch (final ValidationException ex) {
            throw new CfnInvalidRequestException(discoveryRequest.toString(), ex);
        }

        final String endpoint = result.getEndpoints().get(0).getAddress();
        logger.log("Creating AmazonTimestreamWriteClient with endpoint " + endpoint + "\n");

        /*
         * 2. Create the actual client to use with the endpoint obtained
         */
        return AmazonTimestreamWriteClient.builder()
                .withEndpointConfiguration(
                        new AwsClientBuilder.EndpointConfiguration(endpoint, region))
                .build();
    }