Akka-Streamsでプロデューサを遅らせる方法

Question

akka-streamsの問題を解決しようとしています。私の最初のプロデューサがキュー/ mongodbコレクションを連続して取得し、設定された間隔内で実行したいと考えています。それを実現するには？

Answer 1

をあなたは一定の時間間隔で意味ですか？Source.tick(...).map(loadFromMongo)と

スタート！より頻繁に下流処理できるよりもデシベルを照会防ぐためにconflate that drops ticksに入れ

、それが何であれば一般的な方法あなたは欲しい。

Answer 2

さらに、スロットルという概念もあります。次のように使用できます。

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

たとえば、1秒あたり50アイテムを超えるようなフェッチ間隔を指定できます。例は、次のドキュメントにあります。http://doc.akka.io/docs/akka/current/scala/stream/stream-quickstart.html#Time-Based_Processing