代码之家 › 专栏 › 技术社区 › MaatDeamon

使用分区阶段的Akka流

akka-stream

MaatDeamon · 技术社区 · 8 年前

我试图找到一个例子来说明如何使用Akka流分区功能。我正在尝试优化写一个商店。为此,我想在我选择的一批项目中分组,并立即编写它们,然而,为了利用并行性,我想并行进行。因此,批处理和数据库中的写入将在8个并发线程上进行。

我可以在8个并行线程上一次更新30条记录。

但首先,我该如何使用分区。我必须构建GraphBuilder吗?

1 回复 | 直到 8 年前

Stefano Bonetti 8 年前

的使用示例 Partition 可以找到 here

Balance 舞台是你需要的。这些文件提供了一个示例 here .

在这两种情况下,您都需要使用GraphDSL here

推荐文章

Falk Schuetzenmeister · Akka:如何在一个图形阶段提取值并在下一个图形阶段使用

7 年前

Teyu11 · Akka HTTP多文件上传到S3

7 年前

xDs · Alpakka MongoDB-在MongoSource中指定类型

7 年前

Roma Gafiyatullin · 阿克卡河。组合物化值。需要绘制未来地图。要使用哪个ExecutionContext/Dispatcher?

7 年前

apflieger · 如何在播放测试中从基于InputStream的结果中获取内容

7 年前

Jatin · 在project reactor或akka streams中,sink和subscriber在概念上有什么区别?

7 年前

stan · Scala RestartSink未来

7 年前

Alexander Arendar · 不完全了解来源。延迟方法或akka流文档中存在错误

7 年前

user3294786 · 使用Akka Http转换流畅的流数据并发送分块响应

7 年前

vgkowski · Akka流从外部世界获取无限流的当前值

7 年前