整合 DynamoDB 與 Amazon EventBridge

遵循《DynamoDB 開發人員指南》啟用串流 章節中的步驟，在來源資料表上啟用 DynamoDB Streams。如果來源資料表已啟用 DynamoDB Streams，請確認目前取用者少於兩個。取用者可以是 Lambda 函式、DynamoDB 全域資料表、Amazon DynamoDB 與 Amazon OpenSearch Service 的零 ETL 整合，或是直接從串流讀取的應用程式，例如透過 DynamoDB Streams Kinesis 轉接器讀取的應用程式。

按照《EventBridge 使用者指南》中建立 Amazon EventBridge 事件匯流排一節中的步驟建立 EventBridge 事件匯流排。

按照《EventBridge 使用者指南》中建立 Amazon EventBridge 管道一節中的步驟建立 EventBridge 管道。

將範例項目寫入來源 DynamoDB 資料表以觸發事件。這將讓 EventBridge 從範例項目推斷結構描述。此結構描述可用來建立路由事件的規則。例如若您要實作涉及超載屬性的設計模式，您可能需要根據排序索引鍵的值觸發不同規則。有關如何將項目寫入 DynamoDB 的詳細資訊，請參閱《DynamoDB 開發人員指南》中的使用項目和屬性一節。

依照《Lambda 開發人員指南》中使用 Python 建置 Lambda 函式一節中的步驟，建立範例 Python Lambda 函式作為目標。建立函式時，您可以使用下列範例程式碼來示範整合。調用時，函式會列印隨事件接收的 NewImage 及 OldImage，可在 CloudWatch Logs 中檢視。

import json

def lambda_handler(event, context):
    dynamodb = event.get('detail', {}).get('dynamodb', {})
    new_image = dynamodb.get('NewImage')
    old_image = dynamodb.get('OldImage')
    
    if new_image:
        print("NewImage:", json.dumps(new_image, indent=2))
    if old_image:
        print("OldImage:", json.dumps(old_image, indent=2))
    
    return {'statusCode': 200, 'body': json.dumps(event)}

依照《EventBridge 使用者指南》中回應事件的建立規則一節所述步驟，建立 EventBridge 規則以將事件路由至新的 Lambda 函式。

您現在可以依照《EventBridge 使用者指南》中在事件匯流排啟動或停止結構描述探索一節中的步驟，停止事件匯流排上的結構描述探索。

將第二個範例項目寫入來源 DynamoDB 資料表以觸發事件。驗證事件是否在每個步驟成功處理。