Мы транслируем файл из S3 и обрабатываем его, после завершения процесса мы загружаем файл обратно в S3 как файл ошибок / архив, при потоковой передаче файла из S3 он передает данные и между ними останавливает обработку с ошибкой как «akka.http.scaladsl»..model.EntityStreamException: усечение потока объекта ", Не уверен, зависит ли это от размера файла потока из S3 или поврежденного файла?
val source = s3Client.download(baseConfig.bucketName.get,
content.key)._1.via(Gzip.decoderFlow).
via(Framing.delimiter(ByteString("\n"), 256,
byeFormatterFlag).map(_.utf8String))
val flow = flowDefintion(list)
val resp = source.via(flow).runWith(Sink.seq)
akka {
loglevel = "INFO"
stdout-loglevel = "INFO"
logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
http {
routing {
decode-max-size = 25m
}
parsing {
max-to-strict-bytes = 20m
max-content-length = 20m
max-chunk-size=10m
}
}}