Akka HTTP：ByteString 作为表单数据请求中的文件有效负载答案

【问题标题】：Akka HTTP: ByteString as a file payload in a form-data requestAkka HTTP：ByteString 作为表单数据请求中的文件有效负载
【发布时间】：2018-05-21 17:46:16
【问题描述】：

在我的previous questions 之一中，我询问如何使用 Akka HTTP 表示表单数据请求？根据答案，我创建了一个工作示例，但面临“可扩展性”问题 - 当表单数据请求的数量很高时，我需要处理文件系统中的大量文件。

我很好奇，是否可以在表单数据请求中将ByteString 作为文件负载发送？

case class FBSingleChunkUpload(accessToken: String, 
        sessionId: String,
        from: Long, 
        to: Long, 
        file: ByteString) //this property is received from S3 as array of bytes

我创建了以下示例：

def defaultEntity(content: String) =
  HttpEntity.Default(
    ContentTypes.`text/plain(UTF-8)`,
    content.length, Source(ByteString(content) :: Nil)
  )

def chunkEntity(chunk: ByteString) =
  HttpEntity.Strict(
    ContentType(MediaTypes.`application/octet-stream`),
    chunk
  )

val formData = Multipart.FormData(
  Source(
    Multipart.FormData.BodyPart("access_token", defaultEntity(upload.fbUploadSession.fbId.accessToken)) ::
    Multipart.FormData.BodyPart("upload_phase", defaultEntity("transfer")) ::
    Multipart.FormData.BodyPart("start_offset", defaultEntity(upload.fbUploadSession.from.toString)) ::
    Multipart.FormData.BodyPart("upload_session_id", defaultEntity(upload.fbUploadSession.uploadSessionId)) ::
    Multipart.FormData.BodyPart("video_file_chunk", chunkEntity(upload.chunk)) :: Nil
  )
)
val req = HttpRequest(
  HttpMethods.POST,
  s"/v2.3/${upload.fbUploadSession.fbId.pageId}/videos",
  Nil,
  formData.toEntity()
)

在这种情况下，Facebook 会给我发回一条消息：

您的视频上传在完成之前超时。这是可能是因为网络连接速度慢或视频您尝试上传的文件太大

但如果我发送与File 相同的ByteString，它就可以正常工作。

这可能是什么原因？我已经尝试在chunkEntity 中使用MediaTypes.multipart/form-data，但它的行为方式相同。

【问题讨论】：

标签： scala facebook-graph-api akka akka-http

【解决方案1】：

要将ByteString 作为表单数据文件发送，您需要使用以下BodyPart：

def fileEntity(chunk: ByteString) = Multipart.FormData.BodyPart.Strict("video_file_chunk",
    HttpEntity(ContentType(MediaTypes.`application/octet-stream`), chunk), Map("fileName" -> "video_chunk"))

特别注意Map("fileName" -> "video_chunk")这个参数是强制性的，以便正确地构造一个表单数据HTTP请求。

因此，不要使用问题中的chunkEntity，而是使用此答案中的fileEntity :)

【讨论】：