クラスターを作成する Secrets Manager でシークレットを作成するクラスターに接続する変更ストリームを有効にするインターフェイス VPC エンドポイントを作成する実行ロールを作成する Lambda 関数を作成する Lambda イベントソースマッピングを作成します。関数をテストするトラブルシューティングリソースのクリーンアップ

チュートリアル: Amazon DocumentDB を用いて AWS Lambda のストリームの使用

このチュートリアルでは、Amazon DocumentDB (MongoDB 互換) 変更ストリームからのイベントを処理する基本的な Lambda 関数を作成します。このチュートリアルは、以下の段階を通じて完了します。

Amazon DocumentDB クラスターをセットアップして接続し、そのクラスターで変更ストリームをアクティブ化します。
Lambda 関数を作成し、Amazon DocumentDB クラスターを関数のイベントソースとして設定します。
Amazon DocumentDB データベースにアイテムを挿入して、セットアップをテストします。

Amazon DocumentDB クラスターの作成

Amazon DocumentDB コンソールを開きます。[クラスタ] で [作成] を選択します。
次の設定でクラスターを作成します。
- [クラスタータイプ] で [インスタンスベースのクラスター] を選択します。これがデフォルトのオプションです。
- [クラスター設定] で、[エンジンバージョン] 5.0.0 が選択されていることを確認します。これがデフォルトのオプションです。
- [インスタンス設定] で次の設定を行なってください。
  - [DB インスタンスクラス] で、[メモリ最適化クラス] を選択します。これがデフォルトのオプションです。
  - [通常のレプリカインスタンスの数] には 1 を選択します。
  - [インスタンスクラス] にはデフォルトの選択を使用します。
- [認証] でプライマリユーザーのユーザー名を入力し、[セルフマネージド] を選択します。パスワードを入力して確認します。
- 他のデフォルト設定をすべて維持します。
[クラスターを作成] を選択します。

Secrets Manager でシークレットを作成する

Amazon DocumentDB がクラスターを作成している間に、データベースの認証情報を保存する AWS Secrets Manager シークレットを作成します。このシークレットは、後の手順で Lambda イベントソースマッピングを作成するときに指定します。

Secrets Manager でシークレットを保存するには

[Secrets Manager] コンソールを開き、[新しいシークレットを保存] を選択します。
[シークレットのタイプを選択] で、以下のいずれかのオプションを選択します。
- [基本情報] の下:
  - [シークレットタイプ]: Amazon DocumentDB データベース用の認証情報
  - [認証情報] で、Amazon DocumentDB クラスターの作成に使用したユーザー名およびパスワードを入力します。
  - [データベース]: ご使用の Amazon DocumentDB クラスターを選択します。
  - [次へ] を選択します。
[条件] は、以下のオプションから選択します。
- [シークレット名]DocumentDBSecret:
- [次へ] を選択します。
[次へ] を選択します。
[保存する] を選択します。
コンソールを更新して、DocumentDBSecret シークレットが正常に保存されたことを確認します。

[シークレット ARN] をメモしておきます。これは、後のステップで必要になります。

クラスターに接続する

AWS CloudShell を使用して Amazon DocumentDB クラスターに接続する

Amazon DocumentDB マネジメントコンソールの [クラスター] で、作成したクラスターを探します。クラスターの横にあるチェックボックスをクリックして選択します。
[クラスターに接続] を選択します。CloudShell の [Run コマンド] 画面が表示されます。
[新しい環境の名前] フィールドに、「test」などの一意の名前を入力し、[作成して実行する] を選択します。
プロンプトが表示されたら、パスワードを入力します。プロンプトが rs0 [direct: primary] <env-name>> に変わったら、Amazon DocumentDB クラスターに正常に接続できています。

変更ストリームを有効にする

本チュートリアルでは、Amazon DocumentDB クラスター内にある docdbdemo データベースの products コレクションへの変更を追跡します。これを行うには、[変更ストリーム] を有効にします。

クラスター内に新しいデータベースを作成するには

次のコマンドを実行し、docdbdemo と呼ばれる新しいデータベースを作成します。
```
use docdbdemo
```
ターミナルウィンドウで、次のコマンドを使用してレコードを docdbdemo に挿入します。
```
db.products.insertOne({"hello":"world"})
```
次のような出力が表示されます。
```
{
  acknowledged: true,
  insertedId: ObjectId('67f85066ca526410fd531d59')
}
```
次に、次のコマンドを使用して、docdbdemo データベースの products コレクションの変更ストリームを有効にします。
```
db.adminCommand({modifyChangeStreams: 1,
    database: "docdbdemo",
    collection: "products", 
    enable: true});
```
次のような出力が表示されます。
```
{ "ok" : 1, "operationTime" : Timestamp(1680126165, 1) }
```

インターフェイス VPC エンドポイントを作成する

次に、インターフェイス VPC エンドポイントを作成して、Lambda と Secrets Manager (後でクラスターアクセス認証情報を保存するために使用) がデフォルト VPC に接続できるようにします。

インターフェイス VPC エンドポイントを作成するには

[VPC] コンソールを開きます。左側のメニューの [仮想プライベートクラウド] で、[エンドポイント] を選択します。
[エンドポイントの作成] を選択します。次の構成でエンドポイントを作成します。
- [名前タグ] に「lambda-default-vpc」を入力します。
- [サービスカテゴリ] で、[AWS サービス] を選択します。
- サービスには、検索ボックスで「lambda」と入力します。フォーマット com.amazonaws.<region>.lambda のサービスを選択してください。
- [VPC] で、Amazon DocumentDB クラスターがある VPC を選択します。通常、これはデフォルト VPC になります。
- サブネット には、各アベイラビリティーゾーンの横にあるボックスをチェックします。それぞれのアベイラビリティゾーンに正しいサブネット ID を選択します。
- [IP アドレスの種類] には [IPv4] を選択します。
- [セキュリティグループ] で、Amazon DocumentDB クラスターが使用するセキュリティグループを選択します。通常、これは default セキュリティグループになります。
- 他のデフォルト設定をすべて維持します。
- [エンドポイントの作成] を選択します。
[エンドポイントの作成] を再び選択します。次の構成でエンドポイントを作成します。
- [名前タグ] に「secretsmanager-default-vpc」を入力します。
- [サービスカテゴリ] で、[AWS サービス] を選択します。
- サービスには、検索ボックスで「secretsmanager」と入力します。フォーマット com.amazonaws.<region>.secretsmanager のサービスを選択してください。
- [VPC] で、Amazon DocumentDB クラスターがある VPC を選択します。通常、これはデフォルト VPC になります。
- サブネット には、各アベイラビリティーゾーンの横にあるボックスをチェックします。それぞれのアベイラビリティゾーンに正しいサブネット ID を選択します。
- [IP アドレスの種類] には [IPv4] を選択します。
- [セキュリティグループ] で、Amazon DocumentDB クラスターが使用するセキュリティグループを選択します。通常、これは default セキュリティグループになります。
- 他のデフォルト設定をすべて維持します。
- [エンドポイントの作成] を選択します。

これで、このチュートリアルのクラスターセットアップの部分は完了です。

実行ロールを作成する

次のステップでは、Lambda 関数を作成します。まず、クラスターにアクセスするためのアクセス許可を関数に付与する実行ロールを作成する必要があります。これを行うには、最初に IAM ポリシーを作成してから、次にこのポリシーを IAM ロールにアタッチします。

IAM ポリシーを作成するには

IAM コンソールの [ポリシー] ページを開き、[ポリシーの作成] を選択します。

[JSON] タブを選択します。次のポリシーでは、ステートメントの最後の行にある Secrets Manager リソース ARN を以前のシークレット ARN で置き換え、ポリシーをエディタにコピーします。

[次へ: タグ]、[次へ: 確認] の順に選択します。
[Name] (名前) に AWSDocumentDBLambdaPolicy と入力します。
[ポリシーの作成] を選択します。

IAM ロールを作成するには

IAM コンソールの [ロール] ページを開いて、[ロールの作成] を選択します。
[信頼できるエンティティを選択] には、次のオプションを選択します。
- [信頼できるエンティティタイプ]: AWS サービス
- [サービスまたはユースケース]: Lambda
- [次へ] を選択します。
[アクセス権限の追加] では、作成したばかりの AWSDocumentDBLambdaPolicy ポリシーを選択し、AWSLambdaBasicExecutionRole と同様に関数に Amazon CloudWatch Logs への書き込み権限を付与します。
[次へ] を選択します。
[Role name] (ロール名) にAWSDocumentDBLambdaExecutionRoleと入力します。
[ロールの作成] を選択してください。

Lambda 関数を作成する

このチュートリアルでは Python 3.13 ランタイムを使用しますが、他のランタイム用のコードファイルの例も用意しています。次のボックスでタブを選択すると、関心のあるランタイムのコードが表示されます。

このコードは Amazon DocumentDB イベント入力を受け取り、そこに含まれるメッセージを処理します。

Lambda 関数を作成するには

Lambda コンソールの [関数] ページを開きます。
[関数の作成] を選択してください。
[一から作成] を選択します。
[基本的な情報] で、以下を実行します。
1. [関数名] に ProcessDocumentDBRecords と入力します。
2. [ランタイム] で [Python 3.13] を選択します。
3. [アーキテクチャ] で [x86_64] を選択します。
[デフォルトの実行ロールの変更] タブで、次の操作を行います。
1. タブを展開し、[既存のロールを使用する] を選択します。
2. 先ほど作成した AWSDocumentDBLambdaExecutionRole を選択します。
[関数の作成] を選択してください。

関数コードをデプロイするには

次のボックスで [Python] タブを選択し、コードをコピーします。

.NET

SDK for .NET

注記

GitHub には、その他のリソースもあります。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

.NET を使用した Lambda での Amazon DocumentDB イベントの消費。


using Amazon.Lambda.Core;
using System.Text.Json;
using System;
using System.Collections.Generic;
using System.Text.Json.Serialization;
//Assembly attribute to enable the Lambda function's JSON input to be converted into a .NET class.
[assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))]

namespace LambdaDocDb;

public class Function
{
    
     /// <summary>
    /// Lambda function entry point to process Amazon DocumentDB events.
    /// </summary>
    /// <param name="event">The Amazon DocumentDB event.</param>
    /// <param name="context">The Lambda context object.</param>
    /// <returns>A string to indicate successful processing.</returns>
    public string FunctionHandler(Event evnt, ILambdaContext context)
    {
        
        foreach (var record in evnt.Events)
        {
            ProcessDocumentDBEvent(record, context);
        }

        return "OK";
    }

     private void ProcessDocumentDBEvent(DocumentDBEventRecord record, ILambdaContext context)
    {
        
        var eventData = record.Event;
        var operationType = eventData.OperationType;
        var databaseName = eventData.Ns.Db;
        var collectionName = eventData.Ns.Coll;
        var fullDocument = JsonSerializer.Serialize(eventData.FullDocument, new JsonSerializerOptions { WriteIndented = true });

        context.Logger.LogLine($"Operation type: {operationType}");
        context.Logger.LogLine($"Database: {databaseName}");
        context.Logger.LogLine($"Collection: {collectionName}");
        context.Logger.LogLine($"Full document:\n{fullDocument}");
    }



    public class Event
    {
        [JsonPropertyName("eventSourceArn")]
        public string EventSourceArn { get; set; }

        [JsonPropertyName("events")]
        public List<DocumentDBEventRecord> Events { get; set; }

        [JsonPropertyName("eventSource")]
        public string EventSource { get; set; }
    }

    public class DocumentDBEventRecord
    {
        [JsonPropertyName("event")]
        public EventData Event { get; set; }
    }

    public class EventData
    {
        [JsonPropertyName("_id")]
        public IdData Id { get; set; }

        [JsonPropertyName("clusterTime")]
        public ClusterTime ClusterTime { get; set; }

        [JsonPropertyName("documentKey")]
        public DocumentKey DocumentKey { get; set; }

        [JsonPropertyName("fullDocument")]
        public Dictionary<string, object> FullDocument { get; set; }

        [JsonPropertyName("ns")]
        public Namespace Ns { get; set; }

        [JsonPropertyName("operationType")]
        public string OperationType { get; set; }
    }

    public class IdData
    {
        [JsonPropertyName("_data")]
        public string Data { get; set; }
    }

    public class ClusterTime
    {
        [JsonPropertyName("$timestamp")]
        public Timestamp Timestamp { get; set; }
    }

    public class Timestamp
    {
        [JsonPropertyName("t")]
        public long T { get; set; }

        [JsonPropertyName("i")]
        public int I { get; set; }
    }

    public class DocumentKey
    {
        [JsonPropertyName("_id")]
        public Id Id { get; set; }
    }

    public class Id
    {
        [JsonPropertyName("$oid")]
        public string Oid { get; set; }
    }

    public class Namespace
    {
        [JsonPropertyName("db")]
        public string Db { get; set; }

        [JsonPropertyName("coll")]
        public string Coll { get; set; }
    }
}

Go

SDK for Go V2

注記

GitHub には、その他のリソースもあります。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

Go を使用して Lambda で Amazon DocumentDB イベントの消費。



package main

import (
	"context"
	"encoding/json"
	"fmt"

	"github.com/aws/aws-lambda-go/lambda"
)

type Event struct {
	Events []Record `json:"events"`
}

type Record struct {
	Event struct {
		OperationType string `json:"operationType"`
		NS            struct {
			DB   string `json:"db"`
			Coll string `json:"coll"`
		} `json:"ns"`
		FullDocument interface{} `json:"fullDocument"`
	} `json:"event"`
}

func main() {
	lambda.Start(handler)
}

func handler(ctx context.Context, event Event) (string, error) {
	fmt.Println("Loading function")
	for _, record := range event.Events {
		logDocumentDBEvent(record)
	}

	return "OK", nil
}

func logDocumentDBEvent(record Record) {
	fmt.Printf("Operation type: %s\n", record.Event.OperationType)
	fmt.Printf("db: %s\n", record.Event.NS.DB)
	fmt.Printf("collection: %s\n", record.Event.NS.Coll)
	docBytes, _ := json.MarshalIndent(record.Event.FullDocument, "", "  ")
	fmt.Printf("Full document: %s\n", string(docBytes))
}

Java

SDK for Java 2.x

注記

GitHub には、その他のリソースもあります。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

Java を使用した Lambda での Amazon DocumentDB イベントの消費。


import java.util.List;
import java.util.Map;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;

public class Example implements RequestHandler<Map<String, Object>, String> {

    @SuppressWarnings("unchecked")
    @Override
    public String handleRequest(Map<String, Object> event, Context context) {
        List<Map<String, Object>> events = (List<Map<String, Object>>) event.get("events");
        for (Map<String, Object> record : events) {
            Map<String, Object> eventData = (Map<String, Object>) record.get("event");
            processEventData(eventData);
        }

        return "OK";
    }

    @SuppressWarnings("unchecked")
    private void processEventData(Map<String, Object> eventData) {
        String operationType = (String) eventData.get("operationType");
        System.out.println("operationType: %s".formatted(operationType));

        Map<String, Object> ns = (Map<String, Object>) eventData.get("ns");

        String db = (String) ns.get("db");
        System.out.println("db: %s".formatted(db));
        String coll = (String) ns.get("coll");
        System.out.println("coll: %s".formatted(coll));

        Map<String, Object> fullDocument = (Map<String, Object>) eventData.get("fullDocument");
        System.out.println("fullDocument: %s".formatted(fullDocument));
    }

}

JavaScript

SDK for JavaScript (v3)

注記

GitHub には、その他のリソースもあります。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

JavaScript を使用して Lambda で Amazon DocumentDB イベントの消費。


console.log('Loading function');
exports.handler = async (event, context) => {
    event.events.forEach(record => {
        logDocumentDBEvent(record);
    });
    return 'OK';
};

const logDocumentDBEvent = (record) => {
    console.log('Operation type: ' + record.event.operationType);
    console.log('db: ' + record.event.ns.db);
    console.log('collection: ' + record.event.ns.coll);
    console.log('Full document:', JSON.stringify(record.event.fullDocument, null, 2));
};

TypeScript を使用して Lambda で Amazon DocumentDB イベントの消費。


import { DocumentDBEventRecord, DocumentDBEventSubscriptionContext } from 'aws-lambda';

console.log('Loading function');

export const handler = async (
  event: DocumentDBEventSubscriptionContext,
  context: any
): Promise<string> => {
  event.events.forEach((record: DocumentDBEventRecord) => {
    logDocumentDBEvent(record);
  });
  return 'OK';
};

const logDocumentDBEvent = (record: DocumentDBEventRecord): void => {
  console.log('Operation type: ' + record.event.operationType);
  console.log('db: ' + record.event.ns.db);
  console.log('collection: ' + record.event.ns.coll);
  console.log('Full document:', JSON.stringify(record.event.fullDocument, null, 2));
};

PHP

SDK for PHP

注記

GitHub には、その他のリソースもあります。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

PHP を使用して Lambda で Amazon DocumentDB イベントの消費。


<?php

require __DIR__.'/vendor/autoload.php';

use Bref\Context\Context;
use Bref\Event\Handler;

class DocumentDBEventHandler implements Handler
{
    public function handle($event, Context $context): string
    {

        $events = $event['events'] ?? [];
        foreach ($events as $record) {
            $this->logDocumentDBEvent($record['event']);
        }
        return 'OK';
    }

    private function logDocumentDBEvent($event): void
    {
        // Extract information from the event record

        $operationType = $event['operationType'] ?? 'Unknown';
        $db = $event['ns']['db'] ?? 'Unknown';
        $collection = $event['ns']['coll'] ?? 'Unknown';
        $fullDocument = $event['fullDocument'] ?? [];

        // Log the event details

        echo "Operation type: $operationType\n";
        echo "Database: $db\n";
        echo "Collection: $collection\n";
        echo "Full document: " . json_encode($fullDocument, JSON_PRETTY_PRINT) . "\n";
    }
}
return new DocumentDBEventHandler();

Python

SDK for Python (Boto3)

注記

GitHub には、その他のリソースもあります。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

Python を使用して Lambda で Amazon DocumentDB イベントの消費。


import json

def lambda_handler(event, context):
    for record in event.get('events', []):
        log_document_db_event(record)
    return 'OK'

def log_document_db_event(record):
    event_data = record.get('event', {})
    operation_type = event_data.get('operationType', 'Unknown')
    db = event_data.get('ns', {}).get('db', 'Unknown')
    collection = event_data.get('ns', {}).get('coll', 'Unknown')
    full_document = event_data.get('fullDocument', {})

    print(f"Operation type: {operation_type}")
    print(f"db: {db}")
    print(f"collection: {collection}")
    print("Full document:", json.dumps(full_document, indent=2))

Ruby

SDK for Ruby

注記

GitHub には、その他のリソースもあります。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

Ruby を使用して Lambda で Amazon DocumentDB イベントの消費。


require 'json'

def lambda_handler(event:, context:)
  event['events'].each do |record|
    log_document_db_event(record)
  end
  'OK'
end

def log_document_db_event(record)
  event_data = record['event'] || {}
  operation_type = event_data['operationType'] || 'Unknown'
  db = event_data.dig('ns', 'db') || 'Unknown'
  collection = event_data.dig('ns', 'coll') || 'Unknown'
  full_document = event_data['fullDocument'] || {}

  puts "Operation type: #{operation_type}"
  puts "db: #{db}"
  puts "collection: #{collection}"
  puts "Full document: #{JSON.pretty_generate(full_document)}"
end

Rust

SDK for Rust

注記

GitHub には、その他のリソースもあります。サーバーレスサンプルリポジトリで完全な例を検索し、設定および実行の方法を確認してください。

Rust を使用して Lambda で Amazon DocumentDB イベントの消費。



use lambda_runtime::{service_fn, tracing, Error, LambdaEvent};
use aws_lambda_events::{
    event::documentdb::{DocumentDbEvent, DocumentDbInnerEvent},
   };


// Built with the following dependencies:
//lambda_runtime = "0.11.1"
//serde_json = "1.0"
//tokio = { version = "1", features = ["macros"] }
//tracing = { version = "0.1", features = ["log"] }
//tracing-subscriber = { version = "0.3", default-features = false, features = ["fmt"] }
//aws_lambda_events = "0.15.0"

async fn function_handler(event: LambdaEvent<DocumentDbEvent>) ->Result<(), Error> {
    
    tracing::info!("Event Source ARN: {:?}", event.payload.event_source_arn);
    tracing::info!("Event Source: {:?}", event.payload.event_source);
  
    let records = &event.payload.events;
   
    if records.is_empty() {
        tracing::info!("No records found. Exiting.");
        return Ok(());
    }

    for record in records{
        log_document_db_event(record);
    }

    tracing::info!("Document db records processed");

    // Prepare the response
    Ok(())

}

fn log_document_db_event(record: &DocumentDbInnerEvent)-> Result<(), Error>{
    tracing::info!("Change Event: {:?}", record.event);
    
    Ok(())

}

#[tokio::main]
async fn main() -> Result<(), Error> {
    tracing_subscriber::fmt()
    .with_max_level(tracing::Level::INFO)
    .with_target(false)
    .without_time()
    .init();

    let func = service_fn(function_handler);
    lambda_runtime::run(func).await?;
    Ok(())
    
}

Lambda コンソールの [コードソース] ペインで、コードをコードエディタに貼り付け、Lambda が作成したコードを置き換えます。
[DEPLOY] セクションで、[デプロイ] を選択して関数のコードを更新します。

Lambda イベントソースマッピングを作成します。

Amazon DocumentDB 変更ストリームを Lambda 関数と関連付けるイベントソースマッピングを作成します。このイベントソースマッピングを作成すると、AWS Lambda はストリームのポーリングをすぐに開始します。

イベントソースマッピングを作成するには

Lambda コンソールの [関数] ページを開きます。
先ほど作成した ProcessDocumentDBRecords 関数を選択します。
[設定] タブを選択し、左側のメニューで [トリガー] を選択します。
[トリガーを追加] を選択します。
[トリガー設定] で、[Amazon DocumentDB] をソースとして選択します。
イベントソースマッピングには、次の設定制限があります。
- [Amazon DocumentDB クラスター]: 先ほど作成したクラスターを選択します。
- [データベース名]: docdbdemo
- [コレクション名]: 製品
- [バッチサイズ]: 1
- [開始位置]: 最新
- [認証]: BASIC_AUTH
- [Secrets Manager キー]: Amazon DocumentDB クラスターのシークレットを選択します。rds!cluster-12345678-a6f0-52c0-b290-db4aga89274f のような名前になります。
- [バッチウィンドウ]: 1
- [フルドキュメント設定]: UpdateLookup
[Add] (追加) を選択します。イベントソースマッピングの作成には数分かかる場合があります。

関数をテストする

イベントソースマッピングが [有効] 状態になるまで待ちます。これには数分間かかる場合があります。次に、データベースレコードを挿入、更新、削除して、エンドツーエンドのセットアップをテストします。開始する前に、以下を確認してください。

CloudShell 環境で Amazon DocumentDB クラスターに再接続します。
次のコマンドを実行し、docdbdemo データベースを使用できているのを確認します。
```
use docdbdemo
```

docdbdemo データベースの products コレクションにレコードを挿入します。


db.products.insertOne({"name":"Pencil", "price": 1.00})

CloudWatch Logs をチェックして、関数がこのイベントを正常に処理したことを確認します。次のようなログエントリが表示されます。

次のコマンドを使用して挿入したレコードを更新します。


db.products.updateOne(
    { "name": "Pencil" },
    { $set: { "price": 0.50 }}
)

CloudWatch Logs をチェックして、関数がこのイベントを正常に処理したことを確認します。次のようなログエントリが表示されます。

次のコマンドを使用して更新したレコードを削除します。


db.products.deleteOne( { "name": "Pencil" } )

CloudWatch Logs をチェックして、関数がこのイベントを正常に処理したことを確認します。次のようなログエントリが表示されます。

トラブルシューティング

関数の CloudWatch ログにデータベースイベントが表示されない場合、次の内容を確認してください。

Lambda イベントソースマッピング (トリガーとも呼ばれる) が [有効] 状態になっていることを確認します。イベントソースマッピングは作成に数分かかる場合があります。
イベントソースマッピングが [有効] になっても CloudWatch にデータベースイベントが表示されない場合、次の内容を実行してください。
- イベントソースマッピングの [データベース名] が docdbdemo に設定されていることを確認します。
- イベントソースマッピングの [最終処理結果] フィールドに、次のメッセージがあるかどうか確認します。「問題: 接続エラー。VPC は Lambda および STS との接続に加え、認証が必要な場合は Secrets Manager にも接続できる必要があります」このエラーが表示された場合、Lambda および Secrets Manager VPC インターフェイスエンドポイントが作成されているか、またエンドポイントは Amazon DocumentDB クラスターが使用するのと同じ VPC およびサブネットを使用しているかを確認してください。