問題タブ [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.

201 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
172 参照

elasticsearch - ES で Alpakka インデックスを使用する Akka Streams: インデックス名は実行の開始時にのみ評価されます

Akka Streams と Alpakka を使用して、Amazon SQS から読み取り、Elasticsearch でイベントのインデックスを作成するコードをいくつか作成しました。すべてがスムーズに機能し、パフォーマンスは素晴らしいのですが、インデックス名に問題があります。私はこのコードを持っています:

問題は、フローを数日実行した後、インデックス名が変更されないことです。Akka Streams は内部で融合アクターを作成しindex、インデックス名を取得する関数は実行の開始時にのみ評価されると想像します。

現在の日付に従ってインデックス名を使用して ES のイベントにインデックスを付けるにはどうすればよいでしょうか?

0 投票する
1 に答える
97 参照

scala - 複数の取引所にサブスクライブするために AmqpSource を定義する方法は?

現在、私は以下を使用して単一の取引所に加入しています

複数の取引所に加入できるようにしたいです。誰でもこれで私を助けることができますか？


12345678910