Разъем Alpakka S3 не предоставляет полный файл - PullRequest
Новая
       32

Разъем Alpakka S3 не предоставляет полный файл

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

Загрузка файла из хранилища S3 с использованием соединителя Alpakka S3 не обеспечивает весь файл, только его часть. Предполагая, что настройки и атрибуты верны, так как загрузка работает нормально, мне интересно, в чем может быть причина. 

val s3File: Source[Option[(Source[ByteString, NotUsed], ObjectMetadata)], NotUsed] = 
    S3.download(bucketName, fileName).withAttributes(attributes)

s3File.runWith(Sink.head)(materializer) flatMap {
    case Some(result) =>
        result._1.runWith(Sink.head)(materializer) map { data =>
          Right(data.toArray)
        }
    case _ => Future.successful(Left("error"))
}

Регистрация метаданных объектов result все выглядит правильно и данные возвращаются, но только частьчто ожидается.

...