如何从Akka Streams Sink抛出的异常中恢复？

文章/答案/技术大牛

发布

1回答

java、scala、akka、akka-stream

如何从Akka Streams的Sink中抛出的异常中恢复？<code>A0</code><code>A1</code> 如何处理异常并从源代码转到下一个元素？

浏览 14提问于2020-03-16得票数 1

回答已采纳

1回答

如何应对akka流程中的异常(上游故障)

scala、akka、akka-stream、akka-http

我有一个akka Flow[I, O]，它不在我的控制范围之内，因为它来自一些第三方代码。每当输入元素没有生成输出元素时(例如，因为在流的某些部分抛出了异常)，我就需要做出反应。为此，我需要产生失败的input元素。我在流上找不到任何允许我注册处理程序或以任何方式对其做出反应的API。我该怎么做呢？

浏览 34提问于2020-10-06得票数 2

1回答

Akka似乎没有在故障期间重新启动

scala、akka、akka-stream

我在用可重新启动的源和接收器处理akka流中的错误。object Main extends App { implicit val system: ActorSystem = ActorSystem("akka-streams-system")但是似乎接收器中的错误被抛出了，只有源失败被重新尝试，所以源最终被重新启动并重新处理从0开始的事件。我是在模仿这样一个场景:我想从一个源

浏览 8提问于2022-01-10得票数 1

回答已采纳

1回答

使用akka流时的事件顺序

scala、akka-stream、akka-actor

阅读akka的文档，我不太清楚消息的顺序，以及是否可以强制执行。让我用我为聊天服务器编写的一小部分代码来设置我问题的上下文。在终端中打印的事件顺序是完全不确定的。我也不知道该怎么解决。这是我得到的输出-- [INFO] [11/10/2017 17:42:20.431] [akka-streams-akka.actor.default-dispatcher-5]

浏览 4提问于2017-11-11得票数 0

回答已采纳

1回答

在Play 2.6中将多个地图函数应用于流式数据库

scala、akka-stream、anorm

我有一个很大的查询，它似乎是的首选。def outer(converter1[String, Int},

浏览 1提问于2018-08-01得票数 0

1回答

使用Akka流的一个源到多个Sink

rx-java、akka-stream

我正在为我的一个已经使用Rx Scala的项目尝试使用Akka流的一些东西。我很想看看Akka流是如何适合取代Rx Scala库的。有一件事，我不可能看到的阿克卡流，是有可能有一个源头和许多沉没。比如说，在这个例子中，直接从Akka Streams文档中提取出来：val sink = Sink</

浏览 4提问于2016-04-26得票数 2

回答已采纳

1回答

如何使用akka类型化解决akka.stream.Graph接收器错误akka流

scala、akka、akka-stream、akka-typed

我是akka streams的新手，akka输入了我的代码，与经典的akka一起工作很好，这就是我要做的。replyTo} stream.run() 在输出中，当我从</e

浏览 3提问于2020-06-16得票数 1

回答已采纳

4回答

使用Akka* Streams读取CSV文件*

scala、akka、akka-stream

我使用Akka Streams来做这件事，这样我就可以创建一个在每一行上执行的动作图。我已经启动并运行了下面的玩具示例。ActorSystem("MyAkkaSystem")

浏览 0提问于2016-10-25得票数 15

1回答

具有并行性、背压和ActorRef的Akka.net流

akka-stream、akka.net

学习如何使用Akka.net Streams并行处理来自Source.Queue的项目，并在执行元中完成处理。我已经能够让它在使用Sink.ForEachParallel调用函数的情况下工作，并且它可以像预期的那样工作。是否有可能与Sink.ActorRefWithAck并行处理项目(我更希望它利用背压)？

浏览 2提问于2018-12-17得票数 1

1回答

为什么使用Sink.asPublisher创建的发布者在被BroadcastHub使用时不能工作？

java、akka-stream

我们有一个多组分应用程序，它提供了组件之间的反应性流API。一些组件使用Akka流实现，另一些组件使用例如反应堆。 Source<String, NotUsed> allMessagesAPI，而不是Akka Streams API)。此发布者是

浏览 0提问于2019-04-05得票数 1

回答已采纳

1回答

了解Akka如何提供背压

solr、cassandra、akka、akka-stream、reactive

因此，我们在我们的生产系统中有一个用例，我们可能会使用Akka streams。为了了解Akka streams究竟是如何提供背压的，我想更深入地了解我们的需求。这可以转换成一个问题，可以使用Akka streams来解决，其中来自/sql处理程序的Solr流将是akka Source，而Cassandra存储将是Sink，而介于两者之间的</e

浏览 18提问于2020-09-20得票数 0

1回答

Akka.Net文件IO -只处理文件的前n个字节

akka-stream、akka.net

= Sink.Last<ByteString>(); [DEBUG][17/05/2018 13:55:16][Thre

浏览 0提问于2018-05-17得票数 0

1回答

如何持续使用来自Apache Pulsar的消息？

scala、akka-stream、apache-pulsar

如何使用Akka Streams持续使用Apache Pulsar中的消息并打印每条消息？ .to(sink

浏览 7提问于2020-05-22得票数 0

1回答

如何从反应兔库中以编程方式终止io.scalac.amqp.Connection

scala、rabbitmq、reactive-programming、akka-stream

我正在结合使用akka streams和reactive-rabbit库来构建一个脚本，该脚本将一些信息推送到我本地rabbitmq服务器上的一个交换。package prototype import akka.actor.ActorS

浏览 0提问于2015-03-12得票数 4

4回答

在C#中以小块下载大文件

asp.net、c#-4.0、httpwebrequest、websocket

我需要下载一些大于25MB的文件，但我的网络只允许请求25MB的文件。

浏览 5提问于2012-11-26得票数 3

回答已采纳

1回答

Java Akka执行元和流

java、akka、akka-stream

我开始从学习阿卡语Akka流是如何与Actor生命周期相关的？

浏览 0提问于2020-05-15得票数 0

1回答

请求流处理失败-连接发生了什么？

scala、akka-stream、akka-http

akka-http的文档解释说，完全使用请求流是很重要的，因为没有被提取的字节将被解释为背压()。当您事先知道流可以被忽略时，您应该使用discardEntityBytes，或者以其他方式完全读取它。还可以通过将流附加到Sink.cancelled来关闭连接。流是排水了还是连接关闭了？还是实现的责任是从错误中恢复，或者耗尽或关闭连接？如果是这样的话，什么是好的

浏览 0提问于2019-01-24得票数 1

1回答

Akka Stream的Keep right/left/both如何产生不同的输出？

scala、akka、akka-stream

我正在尝试理解Keep在Akka streams中是如何工作的。阅读What does Keep in akka stream mean中的答案，我理解它有助于控制我们从物化器的左侧/右侧/两侧获得结果。ActorMaterializer() "Materialized values are confusing m

浏览 17提问于2020-07-02得票数 0

回答已采纳

1回答

卡夫卡给websocket的消息

websocket、akka-stream、akka-http

我试图写一个卡夫卡消费者到websocket流使用反应性- Kafka，akka-http和akka-流。mainFlow(): Route = { handleWebSocketMessages(Flow.fromSinkAndSource(Sink.ignore, commandSource)) } 从kafka使用者(此处略去)，我做了一个publisherActor !但是

浏览 1提问于2016-04-01得票数 6

1回答

如何调试akka* streams流？*

debugging、akka-stream

当我将断点放在方法processLine中的某个地方时，调试器不会在该行停止。它的执行好像没有任何断点，.Is调试akka streams的流程有点不一样，我该如何解决这个问题呢？runWith(Sink)

浏览 2提问于2015-11-17得票数 2

点击加载更多