Невозможно подключиться к S3 с использованием учетных данных сеанса AWS (STS) - PullRequest
Новая
       12

Невозможно подключиться к S3 с использованием учетных данных сеанса AWS (STS)

0 голосов
/ 01 октября 2019

Я пытаюсь подключиться к AWS S3 с помощью BasicSessionCredentials, но получаю исключение, например Caused by: com.amazonaws.services.s3.model.AmazonS3Exception: The AWS Access Key Id you provided does not exist in our records.

Я использую beam-sdks-java-io-amazon-web-services-2.13. 0.jar для подключения к S3. Ниже приведен пример кода, 

BasicSessionCredentials sessionCredentials = new 
BasicSessionCredentials(awsKeyId, awsSecretKey,sessionToken);

HadoopFileSystemOptions options = 
PipelineOptionsFactory.as(HadoopFileSystemOptions.class);
options.as(AwsOptions.class).setAwsCredentialsProvider(new 
AWSStaticCredentialsProvider(sessionCredentials));
options.as(AwsOptions.class).setRunner(SparkRunner.class);
options.as(AwsOptions.class).setAwsRegion("us-east-2");

Pipeline pipeline = Pipeline.create(options);

Вышеприведенный код генерирует,

Причина: java.io.IOException: com.amazonaws.services.s3.model.AmazonS3Exception: Идентификатор ключа доступа AWS, который вы указали, отсутствует в наших записях. (Service: Amazon S3, код состояния: 403; Код ошибки: InvalidAccessKeyId; Request ID: 53876BU86ED7F1; S3 Extended Request ID: bEV0s868U3kSCSVHaJjbuef97p98 / jksg3CC7UUUp1r3PNT7wPzbzPd1dn3yrfpAsYHMvp6NdWIY =), S3 Extended Request ID: bEV0s868U3kSCSVHaJjbuef97p98 / jksg3CC7UUUp1r3PNT7wPzbzPd1dn3yrfpAsYHMvp6NdWIYJV = в org.apache.beam.sdk. io.aws.s3.S3ReadableSeekableByteChannel.read (S3ReadableSeekableByteChannel.java:91) в org.apache.beam.sdk.io.TextSource $ TextBasedReader.tryToEnsureNumberOfBytesInBuffer (Text.ache.io.be.j.64) at.6464.jbTextSource $ TextBasedReader.findDelimiterBounds (TextSource.java:177) в org.apache.beam.sdk.io.TextSource $ TextBasedReader.startReading (TextSource.java:151) в org.apache.beam.sdk.io.FileBasedSource $ FileBasedReader. startImpl (FileBasedSource.java:476) в org.apache.beam.sdk.io.OffsetBasedSource $ OffsetBasedReader.start (OffsetBasedSource.java:249) в org.apache.beam.runners.spark.io.SourceRDD $ Ограниченный $ ReaderTo. seekNext (SourceRDD.java:213) at org.apache.beam.runners.spark.io.SourceRDD $ Bounded $ ReaderToIteratorAdapter.tryProduceNext (SourceRDD.java:186) ... еще 57

...