問題タブ [spring-cloud-function]
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.
aws-lambda - AWS Lambda と SNS イベントを使用して Spring Cloud Functions で再試行をトリガーする方法
SNS イベントを処理する AWS Lambda で実行されている Spring Cloud Function があります。いくつかのエラー ケースでは、自動 Lambda 再試行をトリガーするか、SNS サービスの再試行機能をトリガーしたいと考えています。SNS 再試行ポリシーはデフォルト設定です。
{"statusCode":500} で JSON を返そうとしました。これは、aws コンソールでテスト呼び出しを行うときに機能しています。とにかく、このステータスを送信すると、関数の呼び出しの再試行はトリガーされません。
SpringBootRequestHandler を使用します
spring-integration - Spring WebFlux: WebClient サーバー送信イベントのテスト
実際、やりたいことを実行できるかどうかさえわかりませんEvent.class。Spring Integration を使用して Broker (MQTT) からイベント ストリーム ( ) を消費していて、そのストリームを別のマイクロサービスに転送したいと考えています。両方のサービスは、水平方向にスケーラブルであると想定されています。したがって、他のサービスには as body を除く POST エンドポイントがありますFlux<Event>(Spring Cloud Functions: を使用spring-cloud-starter-function-webflux)。転送サービスでリボンと を使いたいWebClient。
私がこれまでに持っているもの（簡略化）：
私の質問:
（1）これを一般的にテストする機会はありますか？どうすればいいですか？テストの内部スプリング ブート アプリケーションである OkHttp、WireMock については、/eventReceiverEndpointアサートするだけです。しかし、実際にはどこにも行きませんでした。実際にatmでもエラーは出ません。起動時にメモリーサーバーが存在しないため、4xxを期待していました。
(2) 2 つのretry()呼び出しは、両側で接続の問題を本当に再試行しますか? 切断された場合、メッセージは失われますか? どうすればそれをテストできますか？
(3) 接続が確立された後 (最終的な消費者の負荷が高くなった場合など)、リボンはこの長寿命の Flux と組み合わせて負荷分散を行うことができますか? Flux を別のインスタンスに自動的に再接続する必要があると思いますか?