我正在编写一个小的Akka Streams示例，其中我想要将List的元素写入本地TXT文件implicit val actorSystemFileIO.toPath(Paths.get("~/Downloads/results.txt")))(Keep.right)
我在代码中设置的位置已经创建了该文件我不会终止参与者系统，因此它绝对有足够的时间将
浏览 2提问于2018-07-25得票数 0
回答已采纳
1回答
我在用可重新启动的源和接收器处理akka流中的错误。object Main extends App {上述共享代码的输出如下所示。0 sink2 sink
3 E
浏览 8提问于2022-01-10得票数 1
回答已采纳
我正在使用Akka Streams，我遇到了Sink.actorRefWithAck。据我所知，它会发送一条消息，并且仅在收到前一条消息的确认后才尝试从流中拉入另一个元素。有没有办法用这个接收器批量处理消息？示例:拉出五条消息，只有在前五条消息被确认后才拉出下五条消息。但这将需要接收器更改为使用序列，让我们假设这是不可能的。
浏览 16提问于2019-09-27得票数 0
2回答
我不知道如何立即停止akka stream Runnable Graph？如何使用killswitch来实现这一点？我创建akka streams才几天。在我的例子中，我从文件中读取行，并在flow中执行一些操作，然后写入接收器。我想要做的是，在我想要的时候立即停止读取文件，我希望这可能会停止整个运行的图形。任何关于这方面的想法都将非常感谢。
浏览 9提问于2016-08-03得票数 5
回答已采纳
1回答
我一直在尝试使用Akka Streams，产生了创建Flows并使用FlowGraphs将它们连接在一起的想法。我知道Akka的这一部分仍在开发中，所以有些事情可能还没有完成，一些其他的部分可能会改变，但有没有可能创建一个不“完整”的FlowGraph --也就是没有附加到Sink上--并将它传递到我的代码的不同部分
浏览 0提问于2014-12-07得票数 1
2回答
我对Akka streams中的扇出策略有点困惑，我读到Broadcast -(1个输入，N个输出)给每个输出一个输入元素，而Balance -(1个输入，N个输出)给定一个输入元素发射到它的一个输出端口“Balance”是否表示将输入流复制到一些输出分区中？
"balance“是什么意思？”balance“是指将图分开，复制多个下游订阅者的实例来处理卷？
浏览 3提问于2016-10-24得票数 4
回答已采纳
2回答
我有一个关于使用Akka Streams和Akka集群的问题。我正在尝试做一个使用Akka Streams和Akka Cluster的分布式字数统计版本。我想构建一个Akka Streams客户端，它将文本文件作为流I/O读取，并将单词流发送到远程集群。ByteString.fromString(" "), 256, FramingTruncation.ALLOW))
.map(i -> i
浏览 5提问于2018-11-10得票数 2
可以分别使用Source.actorPublisher()和Sink.actorSubscriber()方法从参与者创建源和接收器。但是从actor创建Flow是可能的吗？从概念上讲，似乎没有充分的理由不这样做，因为它同时实现了ActorPublisher和ActorSubscriber特征，但不幸的是，Flow对象没有任何方法来实现这一点。在优秀的博客文章中，它是在Akka Streams的早期版本中完成的，所以问题是在最新的(2.4.9)版本中是否也有可能。
浏览 1提问于2016-08-24得票数 24
回答已采纳
我有一个非常简单的流来处理一个文件--只是一个FileIO.FromFile源、一个通过流和一个Last接收器： var result = runnable.Run(Context.Materializer()).Result;
"First“状态的文档在接收到一个元素后”取消“，我认为这意味着接收器向流发出取消信号，这将关闭源。: Akka.Stre
浏览 0提问于2018-05-17得票数 0
我想将Akka流中的每个元素写入一个(不同的) FTP文件。使用Alpakka，我可以使用FTP接收器将每个元素写入同一个文件。但是，我似乎不知道如何将每个元素写入不同的文件。source.map(el -> /* to byte string */).to(Ftp.toPath("/file.xml", settings));
因此，每个el都应该在不同的文件中结束。
浏览 0提问于2017-11-22得票数 1
回答已采纳
我有一个处理一个大文件的图表。通过从输入流创建的迭代器访问该文件。Source .runForeach(println)(这里我使用ARM，但如果需要的话，我很乐意提交输入流管理因为runForeach不阻塞，所以它立即关闭。
如果我不使用ARM，什么时候应该手动关闭输入流？或者我不需要这样做，因为Akka会在到达EOF时这样做吗？
浏览 0提问于2018-06-30得票数 0
回答已采纳
我有以下情况:至少有10M个元素的流。但是有最小的1M，如果没有达到最小值，流肯定会失败。该流在Akka流中实现，如下所示：.runWith(Sink.ignore(),actorSystem);像Sink.seq()这样的接收器不是一个选择，因为我不希望在内存中有这么大的集合。我会期待任何流，当流结束时，它会对元素进行计数并验证计数。
浏览 1提问于2021-07-21得票数 0
因此，我目前有一个akka流来读取文件列表，还有一个接收器来连接它们，这就很好用了：虽然这对于一个简单的例子来说已经很好了，但是文件非常大一种
浏览 25提问于2018-01-13得票数 3
1回答
我很难理解卡夫卡流中的窗口是如何工作的。结果似乎与我迄今所读和理解的不一致。CREATE STREAM my_stream WITH (KAFKA_topic='my-stream-topic', VALUE_FORMAT='json', TIMESTAMP='recorded_timestamp') AS select <select list> PARTITION BY PARTITION_KEY;
“我的流-主题”中的记录按键(PARTIT
浏览 1提问于2018-05-31得票数 3
回答已采纳
1回答
我想写一个快速的http响应解析器。我不指望安装PECL，所以我自己做的头文件。HTML部分，我将使用DomDocument。标头将在关联数组中。问题是fwrite($response, shell_exec($request));似乎只将第一个响应行放入流中。
我认为streams是可以使用的东西，因为我想在阅读时逐行阅读。我的测试文件包含了我期望的所有头文件。一次调用stream_get_line()后，feof($response)返回1
浏览 1提问于2016-12-15得票数 0
1回答
下面是用于计算对象列表中数据流平均值的代码：import akka.actor.ActorSystem;import akka.stream.javadsl.Source;
import java.util.Arrays; .run(s
浏览 5提问于2021-05-29得票数 0
回答已采纳
2回答
我有一个找不到的类似文件的物体。特别是，它是来自HTTP请求的不确定大小的文件。重要的是，我不要使用太多的内存，因为其中一些文件可能是巨大的。出于同样的原因，我不想在磁盘上写任何东西。我不介意任何一个接收器由于另一个接收器慢而慢下来，只要S3最终获得整个文件，并且数据会同时到达两个接收器(相反，每个仍然需要它的接收器)。
在Python (3)中，最好的方法是什么？我知道我不能只将同一个文件对象传递给两个接收
浏览 0提问于2016-09-05得票数 6
回答已采纳
1回答
我正在尝试使用Akka Streams在Scala中读取一个文件，我想将结果放在一个列表中。我尝试了下面的代码，列表在接收器内部增加了新值，但在外部我得到了一个空列表。
浏览 26提问于2019-06-25得票数 0
回答已采纳
我过去曾成功地使用过Akka流，但是，我现在很难理解为什么在Akka中定义了客户端Websocket流，并像在中所显示的那样工作。由于WebSocket连接允许全双工通信，所以我预计这种连接是由Akka中的两个单独的流表示的，一个用于传入流量，一个用于传出流量。事实上，这些文件规定如下：
它进一步指出，传入消息由Sink表示，传出消息由Source表示。目前，我的猜测是，传入流的源和传出流的接收器对开发人员并没有多大用处
浏览 1提问于2017-07-17得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
