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