問題タブ [alpakka]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
scala - Akka Stream - 複数の SQS ソースからストリーミングする方法
これはAkka Stream - Select Sink based on Element in Flowの後続の投稿です。
ストリーミングしたい SQS キューが複数あるとします。AlpakkaのAWS SQS ConnectorSourceを使用して作成しています。
combineさて、ソースをマージしたいと思います。ただし、Source.combineメソッドはパラメーターとしてリストを渡すことをサポートしておらず、varargs のみをサポートしています。
もちろん、すべてのソース パラメータを指で入力できます。ただし、10 個のソース キューがある場合、パラメーターはかなり長くなります。
ソースのリストからソースを結合する方法はありますか?
[補足]
Ramon J Romero y Vigilが指摘したように、ストリームを "薄いベニア" に保つ方が良い方法です。ただし、この特定のケースでは、sqsClientすべてのSqsSource初期化に single を使用します。