private void establishConnection()

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