Akka-Stream 使用分区阶段

Question

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

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

Grouped 或 GroupedWithin 有据可查，我已经成功地尝试过它们。但是，我看到的唯一可以并行执行的操作实际上是分区。我会随机分区，我不关心它是如何分区的。如果有类似循环分区程序的设施，我也想知道。

但最重要的是我如何使用分区。我必须构建一个 GraphBuilder 吗？

请帮忙

Answer 1

可以找到 Partition 的用法示例 here。

如果您正在寻找随机分区，Balance 阶段就是您所需要的。文档提供了一个示例 here.

在这两种情况下，您都需要使用 GraphDSL，记录在案 here。