private void establishConnection()

in java/datastax-v4/connection-lambda/src/main/java/example/KeyspacesSSCSession.java [46:91]


    private void establishConnection(LambdaLogger logger) throws Exception {
        if (session != null) {
            return;
        }

        logger.log("AWS_ACCESS_ID: " + System.getenv("AWS_ACCESS_KEY_ID"));
        String region = System.getenv("AWS_REGION");
        logger.log("AWS_REGION: " + region);

        String sscUserName = System.getenv("SSC_USER_NAME");
        logger.log("SSC USER NAME: " + sscUserName);

        String sscUserPassword= System.getenv("SSC_PASSWORD");
        if (StringUtils.isNullOrEmpty(sscUserName)) {
            logger.log("SSC Password: not found");
        } else {
            logger.log("SSC Password: found");
        }

        String SSL_TRUSTSTORE_PASSWORD= System.getenv("SSL_TRUSTSTORE_PASSWORD");
        if (StringUtils.isNullOrEmpty(SSL_TRUSTSTORE_PASSWORD)) {
            logger.log("SSL_TRUSTSTORE_PASSWORD_PROPERTY_NAME: not found");
        } else {
            logger.log("SSL_TRUSTSTORE_PASSWORD_PROPERTY_NAME: found");
        }

        File trustStore = getTrustStoreFile(SSL_TRUSTSTORE_FILENAME);


        System.setProperty(SSL_TRUSTSTORE_PROPERTY_NAME, trustStore.getAbsolutePath());
        System.setProperty(SSL_TRUSTSTORE_PASSWORD_PROPERTY_NAME, SSL_TRUSTSTORE_PASSWORD);

        SSLContext context = SSLContext.getDefault();
        logger.log("Preparing to build session");

        String contactPoint = "cassandra." + region + ".amazonaws.com";
        this.session = CqlSession.builder()
                                 .withSslContext(context)
                                 .withAuthCredentials(sscUserName,sscUserPassword)
                                 .addContactPoint(new InetSocketAddress(contactPoint, 9142))
                                 .withLocalDatacenter(region)
                                 .build();

        logger.log("Finished building session");

    }