akka-http

5熱

3答えて

私はakka-httpを使用して、チャンク応答を返すhttpサービスにリクエストします。この場合にはJSON終了 - ----- {"data": ----- "some text"} ----- {"data": ----- "this is a longer ----- text"} ----- {"data": "txt"} ----- ... データの論

7熱

2答えて

アッカHTTPストリーミングJSONデシリアライズ

は、それが動的にがドメインオブジェクトにアッカのHTTPから、未知の長さで、ByteStringストリームを外部をデシリアライズすることは可能ですか？コンテキスト私は成長し続けてJSON Arrayを出力無限長いHTTPエンドポイントを呼び出します。 [ { "prop": true, "prop2": false, "prop3": 97, "prop4": "sample" },

11熱

1答えて

複数の（10k〜100k）リクエストに対してAkka HTTPクライアントを正しく呼び出す方法は？

私は、Akka HTTP 2.0-M2を使用してバッチデータをアップロードするためのツールを作成しようとしています。しかし、私は問題を特定しようとしましたが、ここにも失敗したサンプルコードでakka.stream.OverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value o

6熱

2答えて

サーバからのakka-http websocket接続を閉じる

私のシナリオでは、クライアントは「さようなら」websocketメッセージを送信し、以前に確立した接続をサーバ側で閉じる必要があります。アッカ-HTTP docsから：閉会の接続は、（Sink.cancelledとSource.emptyにその上流にその下流に接続することにより）、サーバー・ロジックからの着信接続の流れをキャンセルすることにより可能です。また、IncomingConnectio

5熱

2答えて

AkkaストリームのソースとしてSpark DStreamを使用する慣用句

Sparkクラスタで計算を開始し、結果のチャンクストリームで応答するREST APIを構築しています。 Sparkストリームに計算結果がある場合、Sparkからデータを送信するには、 dstream.foreachRDD() を使用できます。私は、アッカ-HTTPでチャンクHTTP応答を送信しています：簡単にするために val requestHandler: HttpRequest => Ht

11熱

2答えて

Akka HTTPで基本的なHTTP POST要求を作成するための慣用的な方法

Akka HTTPライブラリで基本的なHTTP POST要求を作成する方法を理解しようとしています。これは私が思いついたものです： val formData = Await.result(Marshal(FormData(combinedParams)).to[RequestEntity], Duration.Inf) val r = HttpRequest(POST, url, headers

9熱

2答えて

条件付きでakkaストリームを使用してフローをスキップします。

私はakkaストリームを使用しています。フローが特定の値を処理できないため、条件付きでスキップする必要があるグラフのセグメントがあります。具体的には、文字列を受け取りHTTPリクエストを行うフローがありますが、文字列が空の場合、サーバーはそのケースを処理できません。しかし、代わりに空の文字列を返す必要があります。失敗することを知ってhttpリクエストを通過することなくこれを行う方法はありますか？私