如何减缓Akka-Streams中的生产者

Question

4

我正在尝试解决一个Akka Streams的问题。我希望我的初始生产者能够在配置的时间间隔内不断地获取队列/ MongoDB集合。实现这一目标通常采用哪种方法？

- λ Allquantor λ

1

编辑：看起来 Source.tick 是解决这个问题的合法方法。它允许使用指定的间隔定期发出输入。可以在 akka.stream.scaladsl.Source.tick(..) 中找到它。 - λ Allquantor λ

2个回答

2

此外，还有一个叫做“节流”的概念。可以按照以下方式使用：

Source(...).throttle(50, 1.second, 1, ThrottleMode.Shaping)

- λ Allquantor λ

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Rüdiger Klaehn · Accepted Answer

你是指在固定的时间间隔内吗？

可以使用Source.tick(...).map(loadFromMongo)开始实现?

通过加入丢弃计时信号来防止备下游处理不了的情况，如果你需要的话。