アッカのhttpでExcelファイルをアップロードする方法をマイクロサービス

Question

は、Excelシートをアップロードし、ローカルに保存するため、サーバ側で

def uploadFile(fileData: Multipart.FormData) = { 
println(" uploadFile ") 
// path("user"/"upload"/"file") { 
/* (post & entity(as[Multipart.FormData])) { fileData =>*/ 
complete { 
    val fileName = UUID.randomUUID().toString 
    val temp = System.getProperty("java.io.tmpdir") 
    val filePath = temp + "/" + fileName+".xls" 
    // var filePath = current.configuration.getString("upload.file.path").get + "/" + fileName 
    println(fileData.getParts() + " - " + fileData.getMediaType() + " filePath " + filePath + " fileName " + fileName) 
    val processingFileUpload = processFile(filePath, fileData) 
    /*val poResult = Await.result(processingFileUpload, 50 seconds) 
    println(" processFile " + poResult)*/ 
    processingFileUpload.map { fileSize => 
    HttpResponse(StatusCodes.OK, entity = s"File successfully uploaded. Fil size is $fileSize") 
    }.recover { 
    case ex: Exception => HttpResponse(StatusCodes.InternalServerError, entity = "Error in file uploading") 
    } 
    // } 
    // } 
} 
} 

をアッカのHTTPを使用していますし、私のprocessFileは

private def processFile(filePath: String, fileData: Multipart.FormData) = { 
    val fileOutput = new FileOutputStream(filePath) 
    println(" fileOutput " + fileOutput+" fileDatas "+fileData.parts.module) 
// fileData.parts.mapAsync(1) { bodyPart => 
    fileData.parts.mapAsyncUnordered(1) { bodyPart => 
    println(" bodyPartLog " + bodyPart) 
    def writeFileOnLocal(array: Array[Byte], byteString: ByteString): Array[Byte] = { 
     println(" arraysdss " + array) 
     val byteArray: Array[Byte] = byteString.toArray 
     fileOutput.write(byteArray) 
     println(" sdssasx " + byteArray) 
     array ++ byteArray 
    } 
    bodyPart.entity.dataBytes.runFold(Array[Byte]())(writeFileOnLocal) 
    }.runFold(0)(_ + _.length) 
} 

です私はmapAsyncとmapAsyncUnorderedの両方を尋ねました。ファイルをアップロードする際にエラーが発生しました。例外に直接ジャンプしました。サービスをアップロードして自分のサーバーにデータを書き込む方法を教えてください。

Answer 1

ファイルのアップロードに別の方法を使用しましたが、それも機能しています

(post & entity(as[Multipart.FormData])) { request => 
    extractRequestContext { 
    ctx => { 
     implicit val materializer = ctx.materializer 
     implicit val ec = ctx.executionContext 
     fileUpload("fileUpload") { 
     case (fileInfo, fileStream) => 

      val localPath = "c:\\test" 
      val sink = FileIO.toPath(Paths.get(localPath) resolve fileInfo.fileName) 
      val writeResult = fileStream.runWith(sink) 
      onSuccess(writeResult) { result => 
      result.status match { 
       case Success(_) => complete(s"Successfully written ${result.count} bytes") 
       case Failure(e) => throw e 
      } 
      } 
     } 
    } 
    } 
}