SSLHandshakeException возникает во время загрузки файла в AWS S3 через Alpakka

Я пытаюсь настроить Alpakka S3 для загрузки файлов. Вот мои конфиги:

Альпакка s3 зависимость:

...
"com.lightbend.akka" %% "akka-stream-alpakka-s3" % "0.20"
...

Вот application.conf:

akka.stream.alpakka.s3 {
  buffer = "memory"
  proxy {
    host = ""
    port = 8000
    secure = true
  }
  aws {
    credentials {
      provider = default
    }
  }
  path-style-access = false
  list-bucket-api-version = 2
}

Пример кода загрузки файла:

private val awsCredentials = new BasicAWSCredentials("my_key", "my_secret_key")
private val awsCredentialsProvider = new AWSStaticCredentialsProvider(awsCredentials)
private val regionProvider = new AwsRegionProvider { def getRegion: String = "us-east-1" }
private val settings = new S3Settings(MemoryBufferType, None, awsCredentialsProvider, regionProvider, false, None, ListBucketVersion2)
private val s3Client = new S3Client(settings)(system, materializer)

val fileSource = Source.fromFuture(ByteString("ololo blabla bla"))
val fileName = UUID.randomUUID().toString

val s3Sink: Sink[ByteString, Future[MultipartUploadResult]] = s3Client.multipartUpload("my_basket", fileName)

fileSource.runWith(s3Sink)
  .map { 
    result => println(s"${result.location}") 
  } recover {
    case ex: Exception =>  println(s"$ex")
  }

Когда я запускаю этот код, я получаю:

javax.net.ssl.SSLHandshakeException: General SSLEngine problem

Что может быть причиной?


person Alex Fruzenshtein    schedule 15.08.2018    source источник


Ответы (1)


Проблема с сертификатом возникает для имен корзин, содержащих точки. Вы можете переключиться на akka.stream.alpakka.s3.path-style-access = true, чтобы избавиться от этого.

Мы рассматриваем вариант по умолчанию: https://github.com/akka/alpakka/issues/1152

person Enno    schedule 21.08.2018