Проблема аутентификации Java в AWS DAX
Я пытаюсь написать гибкий механизм аутентификации между использованием DAX и DynamoDB для тестирования производительности. Я смог заставить его работать нормально с DynamoDB во всех регионах, но он корректно работает только на us-west-1 в DAX.
if (this.useDax) {
try {
AWSCredentials credentials = new PropertiesCredentials(new File(credentialsFile));
ClientConfig daxConfig = new ClientConfig().withEndpoints(endpoint).withRegion(daxRegion)
.withCredentialsProvider(new AWSStaticCredentialsProvider(credentials));
daxDB = new ClusterDaxClient(daxConfig);
primaryKeyName = primaryKey;
LOGGER.info("dynamodb DAX connection created with " + this.endpoint);
} catch (Exception e1) {
LOGGER.error("DaxDBClient.init(): Could not initialize DaxDB client.", e1);
}
} else {
try {
AWSCredentials credentials = new PropertiesCredentials(new File(credentialsFile));
ClientConfiguration cconfig = new ClientConfiguration();
cconfig.setMaxConnections(maxConnects);
dynamoDB = new AmazonDynamoDBClient(credentials, cconfig);
dynamoDB.setEndpoint(this.endpoint);
primaryKeyName = primaryKey;
LOGGER.info("dynamodb connection created with " + this.endpoint);
} catch (Exception e1) {
LOGGER.error("DynamoDBClient.init(): Could not initialize DynamoDB client.", e1);
}
}
Я получаю ошибку:
com.amazon.dax.client.exceptions.DaxServiceException: [1.23.31.33] Соединение требует проверки подлинности (Служба: нулевая; Код состояния: -1; Код ошибки: нулевой; Идентификатор запроса: нулевой)
1 ответ
В итоге я использовал другой поставщик учетных данных (PropertiesFileCredentialsProvider), и он работал:
if (this.useDax) {
try {
ClientConfig daxConfig = new ClientConfig().withEndpoints(this.endpoint).withRegion(daxRegion)
.withCredentialsProvider(new PropertiesFileCredentialsProvider(credentialsFile));
daxDB = new ClusterDaxClient(daxConfig);
primaryKeyName = primaryKey;
LOGGER.info("dynamodb DAX connection created with " + this.endpoint);
} catch (Exception e1) {
LOGGER.error("DaxDBClient.init(): Could not initialize DaxDB client.", e1);
}
} else {
try {
AWSCredentials credentials = new PropertiesCredentials(new File(credentialsFile));
ClientConfiguration cconfig = new ClientConfiguration();
cconfig.setMaxConnections(maxConnects);
dynamoDB = new AmazonDynamoDBClient(credentials, cconfig);
dynamoDB.setEndpoint(this.endpoint);
primaryKeyName = primaryKey;
LOGGER.info("dynamodb connection created with " + this.endpoint);
} catch (Exception e1) {
LOGGER.error("DynamoDBClient.init(): Could not initialize DynamoDB client.", e1);
}
}