scala – 使用喷雾客户端进行多次请求时的akka??超时

使用喷雾1.3.2和akka 2.3.6. (akka仅用于喷雾).
我需要读取大文件,并为每一行发出一个http请求.
我用迭代器逐行读取文件,并为每个项目发出请求.
它成功运行了一些线路,但有时它开始失败：
akka.pattern.AskTimeoutException：在[60000 ms]之后询问[Actor [akka：// default / user / IO-HTTP#-35162984]]的超时时间.
我首先想到我重载了服务,所以我将“spray.can.host-connector.max-connections”设置为1.它运行得慢得多,但我得到了同样的错误.
这里的代码：

import spray.http.MediaTypes._
val EdnType = register(
MediaType.custom(
  mainType = "application",subType = "edn",compressible = true,binary = false,fileExtensions = Seq("edn")))

val pipeline = (
  addHeader("Accept","application/json")
  ~> sendReceive
  ~> unmarshal[PipelineResponse])

def postData(data: String) = {
  val request = Post(pipelineUrl).withEntity(HttpEntity.apply(EdnType,data))
  val responseFuture: Future[PipelineResponse] = pipeline(request)
  responseFuture
}

dataLines.map { d =>
  val f = postData(d)
  f.onFailure { case e => println("Error - "+e)} // This is where the errors are display
  f.map { p => someMoreLogic(d,p) }
}

aggrigateResults(dataLines)

我是这样做的,因为我不需要整个数据,只需要一些聚合.

我怎样才能解决这个问题并保持完全异步？