Попытка преобразовать Java-файл в строку байтов для использования в потоке - PullRequest
Новая
       61

Попытка преобразовать Java-файл в строку байтов для использования в потоке

0 голосов
/ 19 ноября 2018

Я создаю API для отправки мне файлов, и я буду загружать их на S3, и я использую библиотеку akka-stream-alpakka-s3, чтобы сделать это с помощью потоков.

моя проблема в том, что в моем контроллере я могу преобразовать файл в файл Jave: 

  def uploadToS3() = Action(parse.multipartFormData) { request =>
    request.body.file("file").map { filePart =>
      val filename = Paths.get(filePart.filename).getFileName
      val file = Paths.get(s"/tmp/$filename").toFile // this is java file
      saveToS3(file, filename)
    }
    ...
  }

, а в моем сервисном сервисе s3 я рекомендую использовать только файл scala, так как он имеет "toByteArray"Мне нужен func для источника, он выглядит следующим образом: 

import scala.reflect.io.File

class S3Service @Inject()(mys3Client: S3Client,
                          configuration: Configuration,
                          implicit val executionContext: ExecutionContext,
                          implicit val actorSystem: ActorSystem) {

  implicit val materializer: ActorMaterializer = ActorMaterializer()
  val bucket: String = configuration.get[String]("my.aws.s3.bucket")

// func to save to s3
  def saveToS3(file: File, fileName: String): Future[AWSLocation] = {

// here im creating uuid so i to pass as directory so it will be possible to have files with the same name
    val fileNameUUID: String = s"${UUID.randomUUID()}-$fileName"
// this will be my sinc for the stream    
    val s3Sink: Sink[ByteString, Future[MultipartUploadResult]] = mys3Client.multipartUpload(s"$bucket/$fileNameUUID", fileName)

// here is my issue: i need to transform the file to bytstring so I can creat it as the source but the file im getting from the controller is Java file and the function to create byteString is of Scala file so had to use scala file in this func.
    Future.fromTry( Try{
      ByteString(file.toByteArray())
    }).flatMap { byteString =>
      Source.single(byteString).runWith(s3Sink) map { res =>
        AWSLocation(s"$bucket/$fileNameUUID", res.key)
      }
    }.recover {
      case ex: S3Exception =>
        logger.error("some message", ex)
        throw ex
      case ex: Throwable =>
        logger.error("some message", ex)
        throw ex
    }
  }
}

Каков наилучший способ выравнивания типов файлов, чтобы я мог передать файл bytestring в мой Source?

1 Ответ

0 голосов
/ 19 ноября 2018

Взгляните на FileIO.fromPath, который даст вам Source[ByteString, ...] от java.nio.file.Path.

...