akka-http

0熱度

1回答

如何使用Multipart.FormData上傳HttpEntity.Chunked與阿卡的HTTP客戶端

當試圖在多部分組成一個大文件上傳到服務器chunked entity： val chunked = HttpEntity.Chunked.fromData(mimeType, sourceOfByteString) Multipart.FormData( Multipart.FormData.BodyPart("downloadPath", HttpEntity(fileResour

0熱度

1回答

akka流與火花流：消息不傳遞給演員;得到死信

我是新來的阿卡流。我從github運行下面的例子。但是，向「Helloer」actor發送的消息不會在輸出控制檯中接收和顯示。 StreamingApp.scala import _root_.akka.actor.{ Actor, Props } import org.apache.spark._ import org.apache.spark.streaming._ import org

4熱度

2回答

呼籲減少對阿卡HTTP路線名單產生編譯錯誤（參數沒有隱含價值加入）

鑑於以下途徑 val route1: PathMatcher[Unit] = PathMatcher("app") val route2: PathMatcher1[String] = PathMatchers.Segment val route3: PathMatcher[Unit] = PathMatcher("lastSegment") 我可以很容易地定義 val resulting

1熱度

1回答

如何在Scala或Java中模擬或存根AWS SDK S3存儲桶調用？

我使用Akka HTTP框架和Scala創建了一個應用程序，該應用程序使用SDK將文件發送到我的S3存儲桶。我正在嘗試編寫代碼的單元和集成測試，我不確定如何模擬或存根這些外部調用，因爲它看起來不像SDK做任何明顯的HTTP或WS調用。是否有一個庫可以模擬或存根S3存儲桶調用，它也與Scala或Java兼容？

3熱度

1回答

無法使用Akka-Http驗證OAuth2

您好有使用Akka-Http開發的服務。我必須添加OAuth並根據documentation，我正在使用authenticateOAuth2。然而代碼不編譯和給出誤差作爲類型不匹配，預期：（L）=> server.Route，實際：（OauthInfo）=> server.Route 我無法找到解決此問題的適當解決方案。我甚至在文檔中嘗試了example中提到的確切代碼，但它仍然會引發類似

5熱度

1回答

阿卡HTTP不處理與美元符號正確的參數？

我已經（OData的）查詢參數在我的路線定義，像這樣： parameters(('$top.as[Int].?, '$skip.as[Int].?)) { (top, skip) => 我有以下的拒絕處理程序來處理所有無效的參數（handleAll）： RejectionHandler.newBuilder() .handleAll[MalformedQueryParamReject

1熱度

1回答

如何在AKKA-HTTP中驗證完成

我想驗證我的API的完整功能的結果，當它無法將字符串轉換爲Json類型時，Response會生成一個null，我不希望它生成null但說：「沒有發現」，這是我的路線： val route = pathPrefix("auth") { path("signIn") { pathEndOrSingleSlash { post { entity(as[Lo

4熱度

1回答

Akka流保持空閒，而不是拋出異常

我是Akka/Scala的新手，正在嘗試調試下面的代碼。當resultSetParser有一個例外時，它不會拋出它。相反，使用此代碼的服務只是永遠閒置。如何讓我的服務拋出異常，而不僅僅是在流中等待？在Akka中有沒有類似watchException()的函數，我可以在watchTermination()之後調用它，使它在處理流時看到異常？ val chunkSource: Source[Chun

1熱度

1回答

轉化油滑流數據，並使用阿卡的Http

目的是從數據庫流數據，在這個組塊數據的執行一些計算（該計算返回一些情況下類的未來）發送分塊響應，併發送該數據作爲分塊的響應給用戶。目前，我能夠流式傳輸數據併發送響應，而無需執行任何計算。但是，我無法執行此計算，然後傳輸結果。這是我實施的路線。 def streamingDB1 = path("streaming-db1") { get { val src = Source.

0熱度

1回答

在Mac OS Docker上運行REST應用程序時的空響應

我使用SBT創建了一個簡單的scala應用程序（akka-http REST服務）。這是應用程序的主類： object UserApiWebService extends App { override def main(args: Array[String]): Unit = { implicit val system: ActorSystem = ActorSystem