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");
}