Akka-Stream 使用分区阶段

Question

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

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

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

但首先我如何使用分区。我必须构建一个 GraphBuilder 吗？

请帮忙

Answer 1

Partition的使用示例可以在here找到。

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

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