关于 akka 流的聚合指标

Question

在我的应用程序中，我有一个源，我正在为客户端调用多路复用。

类似：

val source: RunnableGraph[Source[...]] = ...

def foo() = source.run().log("sending user something").map(...)

如果我有 1000 个客户端调用 foo 并且每秒 foo 滴答声，就会有数百万条毫无意义的日志消息。所以我想摆脱上面的单个日志，并将其替换为一条聚合消息，例如：

“向 X 客户发送了一些东西”。

我看过 Kamon 和肉桂，所以我很欣赏这可能与这些有关，但理想情况下，这样的东西有更轻量级的东西吗？

Answer 1

我认为如果您将在像这样https://softwaremill.com/windowing-data-in-akka-streams/ 的小窗口中聚合数据是可能的 或者您可以拥有 Map[ClientId, Monoid[YourCallMetrics]] 并通过可运行图组合它