in dotnet/datastax-v3/connection-lambda/src/keyspaces-lambda-csharp/KeyspacesSession.cs [29:54]
private void establishConnection()
{
if (session != null)
return;
string region = Environment.GetEnvironmentVariable("AWS_REGION");
string serviceUserName = Environment.GetEnvironmentVariable("SERVICE_USER_NAME");
string servicePassword = Environment.GetEnvironmentVariable("SERVICE_PASSWORD");
string certPath = Environment.GetEnvironmentVariable("CERTIFICATE_PATH");
LambdaLogger.Log("Region: " + region + ", Username: " + serviceUserName + ", Certificate Path: " + certPath);
X509Certificate2Collection certCollection = new X509Certificate2Collection();
X509Certificate2 amazoncert = new X509Certificate2(@"" + certPath + "/AmazonRootCA1.pem");
certCollection.Add(amazoncert);
string awsEndpoint = "cassandra." + region + ".amazonaws.com";
var cluster = Cluster.Builder()
.AddContactPoints(awsEndpoint)
.WithPort(9142)
.WithAuthProvider(new PlainTextAuthProvider(serviceUserName, servicePassword))
.WithSSL(new SSLOptions().SetCertificateCollection(certCollection))
.Build();
session = (Session) cluster.Connect();
}