レスポンスストリーミング関数のハンドラー記述は、一般的なハンドラーパターンとは異なります。ストリーミング関数の作成時は、必ず次の事項を確認してください。
ネイティブ Node.js ランタイムの
awslambda.streamifyResponse()デコレーターで関数をラップします。確実にすべてのデータ処理を完了させるため、ストリームを正常に終了させます。
ストリームレスポンスにハンドラー関数を設定する
Lambda が関数のレスポンスをストリーミングする必要があることをランタイムに示すには、関数を streamifyResponse() デコレーターでラップする必要があります。これにより、レスポンスをストリーミングするために適切なロジックパスを使用するようランタイムに指示し、関数がレスポンスをストリーミングできるようにします。
streamifyResponse() デコレーターは、次のパラメータを受けつける関数を受けつけます。
event— HTTP メソッド、クエリパラメータ、リクエスト本文など、関数 URL の呼び出しイベントに関する情報を提供します。responseStream— 書き込み可能なストリームを提供します。context– 呼び出し、関数、実行環境に関する情報を含むメソッドおよびプロパティを提供します。
responseStream オブジェクトは「Node.js writableStreampipeline() メソッドを使用する必要があります。
例 レスポンスストリーミング対応ハンドラー
const pipeline = require("util").promisify(require("stream").pipeline);
const { Readable } = require('stream');
exports.echo = awslambda.streamifyResponse(async (event, responseStream, _context) => {
// As an example, convert event to a readable stream.
const requestStream = Readable.from(Buffer.from(JSON.stringify(event)));
await pipeline(requestStream, responseStream);
});responseStream にはストリームに書き込む write() メソッドが用意されていますが、「pipeline()pipeline() を使用すると、書き込み可能なストリームが読み取り速度の速いストリームによって抑制されることがなくなります。
ストリームを終了する
ハンドラーが戻る前にストリームが適切に終了することを確認してください。pipeline() メソッドはこれを自動的に処理します。
他のユースケースでは、responseStream.end() メソッドを呼び出してストリームを適切に終了させます。このメソッドは、ストリームにこれ以上データを書き込む必要がないことを通知します。pipeline() または pipe() でストリームに書き込む場合、このメソッドは不要です。
例 pipeline() でストリームを終了する例
const pipeline = require("util").promisify(require("stream").pipeline);
exports.handler = awslambda.streamifyResponse(async (event, responseStream, _context) => {
await pipeline(requestStream, responseStream);
});例 pipeline() なしでストリームを終了する例
exports.handler = awslambda.streamifyResponse(async (event, responseStream, _context) => {
responseStream.write("Hello ");
responseStream.write("world ");
responseStream.write("from ");
responseStream.write("Lambda!");
responseStream.end();
});