我的任务是从mongo db (使用akka streams)读取一个集合，并为每个元素(文档)调用一些google api，并使用google的结果丰富元素数据。google将api调用限制在每秒50次，所以我使用了这样的throttle： def processSuppliers()(implicit m: Materializer): Future[DoneActorAttributes.
浏览 23提问于2019-01-09得票数 0
1回答
使用EventStream创建源
、、、、
我正在使用PlayFramework 2.5.3，并希望从akka.event.EventStream创建一个akka.stream.scaladsl.Source ( eventstream是参与者系统的一部分事件流将从特定类型生成事件，因此我需要订阅该特定类型的事件并使用play.api.mvc.Results.chunked推送它们。有什么简单的方法可以使用Akka Streams 2.4.5创建这样的
浏览 5提问于2016-05-19得票数 6
1回答
我试图在Akka Actor中使用来自PlayFramework的PlayFramework，但是当我试图用chrome或firefox调用它时，它不起作用：我的主计长的<
浏览 1提问于2015-12-19得票数 2
回答已采纳
1回答
我有一个示例下载代码，如果没有压缩文件，它可以正常工作，因为我知道文件的长度，当我提供的时候，我认为当流播放时，不一定要把整个文件放在内存中，而且它可以工作。application/zip"))).withHeaders("Content-Disposition" -> s"attachment; filename=backup")我不知道上述情况下的流如何处理磁盘读取之间的速度差异(这比网络<em
浏览 3提问于2017-09-12得票数 2
1回答
考虑到TCP提供本机流控制，我正在研究为什么某些系统实现应用程序级的背压。仅仅是为了从网络和TCP协议中抽象出异步通信的思想吗？其他更确切的问题是：
反应性流是否通过简单地让TCP处理它来实现TCP之上的应用层背压？
浏览 1提问于2018-03-27得票数 4
我们有一个多组分应用程序，它提供了组件之间的反应性流API。一些组件使用Akka流实现，另一些组件使用例如反应堆。
在一个组件中，我们注意到流没有处理任何消息，尽管提供的发布者提供了记录。使用的是反应性流API，而不是Akka Streams API)。此发布者是从另一个Akka Streams Source创建的，并使用Sin
浏览 0提问于2019-04-05得票数 1
回答已采纳
举个例子：两个用户都使用相同的端点/api/ticker/AMD?我现在唯一能想到的是：
实现在HttpRequest管道中注入的某种类型的中间件，该中间件包含一个工厂，该工厂将检查正在调用哪个端点，从而运行特定的代码来限制请求、限制数据输出或任何其他业务规则。移到基于参与者<em
浏览 0提问于2019-12-31得票数 2
1回答
我正在为akka集群中两个单独的akka微服务/有界上下文之间的通信进行适当的设计。这两种微型服务都以akka为基础。显然，在特定的有限制的上下文中的通信将通过从参与者发送消息到参与者或者从node1上的参与者发送到node2上的参与者(如果有必要的话)来处理。Q:，但是在单独的akka</
浏览 0提问于2018-05-11得票数 1
我正在构建一个应用程序，在该应用程序中，我接受用户的请求，调用REST以获取一些数据，然后基于该响应进行另一个HTTP调用，等等。基本上，我正在处理一个数据树，树中的每个节点都要求我递归地调用这个API，如下所示： / \ / \ \我使用Akka HTTP与Akka流一起构建应用程序，所以我使用它的流<em
浏览 2提问于2021-07-06得票数 0
回答已采纳
() )，因为否则Akka HTTP (和底层流基础设施)将理解实体消耗作为背压信号的不足，并停止从底层TCP连接中读取！当使用singleHttpRequest获取Future[HttpResponse]时，有时我使用的是使用Unmarshaller.strict创建的解封送处理程序。当使用Unmarhsaller[HttpEntity, T]时，
查看akka源代码，似乎在使用了使用获得的封送器之后，我们应该<e
浏览 3提问于2017-08-24得票数 3
BigQuery存储API有一个6小时的会话超时。当读取1k最大允许流的数据的TBs的10秒时，6h不足以读取所有数据。考虑到这些限制，我想知道是否有一种可伸缩的方法，可以通过烧烤存储API从BQ读取大型数据集？如果不是的话，有没有其他的方法可以用来读取BQ中的大型数据集？
浏览 3提问于2022-08-12得票数 0
3回答
在使用Akka和Play时，我正在阅读非阻塞I/O，就我所能读到的情况而言，如果在这种情况下可以避免的话，阻塞是个坏主意，但我无法让它与我的用例一起工作：
读取文件中的每一行，这是一个基于位置的平面文
浏览 2提问于2012-12-06得票数 3
回答已采纳
1回答
最近，我将我编写的一个程序从Scala2.9改为2.11。在这个过程中，我将我原来的scala代码移到使用Akka演员。不幸的是，我以前用来限制程序消耗的资源的代码现在不再起作用了。相反，现在我的程序似乎占用了系统上所有可用的处理器。我知道我可以编写和捆绑一个自定义配置文件，以设置与Akka默认值不同的线程数。但是，是否有一种编程方法可以告诉Akka使用多少个线程
浏览 3提问于2014-06-19得票数 0
回答已采纳
1回答
我用的是喷罐1.2.1。connection !MessageChunk(data).withAck(ChunkSent)
connection是由喷雾和Akka提供的IO演员，那么我可以在发送下一个块之前等待一个ChunkSent。好的。我在努力复制同样的行为，有着巨大的反应
浏览 2提问于2014-03-19得票数 4
回答已采纳
我们有一个使用PlayFramework 2.5.4和MongoDB的Play-Project。我们想每天更新我们的数据库。现在，我们每次收到请求时都会检查，如果一天过去了，我们会进行更新。因此，我已经找到了AKKA和旧的堆栈溢出问题(如)的文档。但是解决办法已经行不通了。Akka.system().scheduler()system.scheduler()
给出编译错误()，我不知道是否缺少导入或其他什么。我知道您应该从
浏览 2提问于2016-06-30得票数 6
回答已采纳
，并且订阅方调用Subscription.next(n)。")不幸的是，这似乎立即开始从我的我知道Source只是对象的可修改源的一种模板(我的理解是它就像Publisher的工厂)，并且它只有在实现之后才会转换为一个具体的活动源。因此，如果我正确
浏览 13提问于2021-09-27得票数 1
回答已采纳
我的安排是这个IdentityServer4认证服务器当某人第一次访问客户端网站时，就会使用IdentityServer流调用clientCredentials。这允许用户(名称:来宾，user_id= null)限制对API的访问(包括将项添加到篮中)。当用户登录时，他们会从IdentityServer获得一个新的</e
浏览 2提问于2018-08-23得票数 0
我使用Akka 2.4.7读取web资源，它本质上是一个JSON对象流，用换行符分隔。这条河的大小实际上是无限的。当消耗了大约8MB时，我得到了一个例外：
[error] (run-main-0) EntityStreamSizeException: actual entity size (None) exceededYou can configure this by setting `akka.http.无论如何，在进行客户端编程时，HttpEnti
浏览 7提问于2016-06-13得票数 4
回答已采纳
1回答
我正在通过Twitter阅读DM，每次我检查它们时都会使用速率限制，即使我没有检索任何消息。我已经看到通过流API读取DM是可能的，我想知道这是否不消耗速率限制，或者至少在实现之前是一个单独的限制，因为这样做需要一些时间。另外，它是快速获得新的DM，还是它有某种形式的延迟，因为它是流？因此，简而言之：
难道流媒体API没有消耗我的GET
浏览 0提问于2012-05-24得票数 4
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
