チュートリアル: 関数 URL を使用してレスポンスストリーミング Lambda 関数を作成する

AWS Identity and Access Management (IAM) コンソールの ロールページを開きます。

[ロールの作成] を選択してください。

次のプロパティでロールを作成します。

以下のコード例を index.js という名前のファイルにコピーします。この関数は、1 秒で区切られた 3 つのレスポンスをストリーミングします。

exports.handler = awslambda.streamifyResponse(
	async (event, responseStream, _context) => {
		// Metadata is a JSON serializable JS object. Its shape is not defined here.
		const metadata = {
		statusCode: 200,
		headers: {
			"Content-Type": "application/json",
			"CustomHeader": "outerspace"
		}
		};
	
		// Assign to the responseStream parameter to prevent accidental reuse of the non-wrapped stream.
		responseStream = awslambda.HttpResponseStream.from(responseStream, metadata);
	
		responseStream.write("Streaming with Helper \n");
		await new Promise(r => setTimeout(r, 1000));
		responseStream.write("Hello 0 \n");
		await new Promise(r => setTimeout(r, 1000));
		responseStream.write("Hello 1 \n");
		await new Promise(r => setTimeout(r, 1000));
		responseStream.write("Hello 2 \n");
		await new Promise(r => setTimeout(r, 1000));
		responseStream.end();
		await responseStream.finished();
	}
  );

デプロイパッケージを作成します。

zip function.zip index.js

create-function コマンドを使用して Lambda 関数を作成します。--role の値を、前のステップで書き留めたロールの ARN に置き換えます。このコマンドは、関数のタイムアウトを 10 秒に設定し、関数が 3 つのレスポンスをストリーミングできるようにします。

aws lambda create-function \
  --function-name my-streaming-function \
  --runtime nodejs22.x \
  --zip-file fileb://function.zip \
  --handler index.handler \
  --timeout 10 \
  --role arn:aws:iam::123456789012:role/response-streaming-role

lambda:InvokeFunctionUrl および lambda:InvokeFunction のアクセス許可を付与するリソースベースのポリシーを関数に追加します。各ステートメントは、個別のコマンドで追加する必要があります。--principal の値を AWS アカウント  ID に置き換えます。

aws lambda add-permission \
  --function-name my-streaming-function \
  --action lambda:InvokeFunctionUrl \
  --statement-id UrlPolicyInvokeURL \
  --principal 123456789012 \
  --function-url-auth-type AWS_IAM

aws lambda add-permission \
    --function-name my-streaming-function \
    --action lambda:InvokeFunction \
    --statement-id UrlPolicyInvokeFunction \
    --principal 123456789012

create-function-url-config コマンドを使用して、関数の URL エンドポイントを作成します。

aws lambda create-function-url-config \
  --function-name my-streaming-function \
  --auth-type AWS_IAM \
  --invoke-mode RESPONSE_STREAM

IAM コンソールの [ロール] ページを開きます。

作成した実行ロールを選択します。

[削除] を選択します。

テキスト入力フィールドにロールの名前を入力し、[削除] を選択します。

Lambda コンソールの [関数] ページを開きます。

作成した関数を選択します。

[アクション] で、[削除] を選択します。

テキスト入力フィールドに confirm と入力し、[Delete] (削除) を選択します。