部署及訂閱事件重播管道 - Amazon Simple Notification Service

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

部署及訂閱事件重播管道

本教學課程說明如何部署事件重播管道,並讓管道訂閱 Amazon SNS 主題。此程序會自動將與管道相關聯的 AWS SAM 範本轉換為 AWS CloudFormation 堆疊,然後將堆疊部署到您的 AWS 帳戶 帳戶。此程序還會建立和設定一組資源 (構成事件重播管道),包括 Amazon SQS 佇列和 Lambda 函數。

如需有關篩選事件的詳細資訊,請參閱本指南中的Amazon SNS 訂閱篩選政策

  1. 登入 AWS Lambda 主控台

  2. 在導覽面板上,選擇 Functions (函數),然後選擇 Create function (建立函數)

  3. Create function (建立函數) 頁面上,執行下列動作:

    1. 選擇瀏覽無伺服器應用程式存放庫公有應用程式顯示建立自訂 IAM 角色或資源政策的應用程式

    2. 搜尋 fork-event-replay-pipeline,然後選擇應用程式。

  4. fork-event-replay-pipeline頁面上,執行下列動作:

    1. Application settings (應用程式設定) 區段中,輸入 Application name (應用程式名稱) (例如,my-app-replay)。

      注意

      對於每個部署,應用程式名稱必須是唯一的。如果您重複使用應用程式名稱,部署只會更新先前已部署的 AWS CloudFormation 堆疊 (而不是建立新的堆疊)。

    2. (選擇性) 輸入下列其中一項LogLevel設定,以執行應用程式的 Lambda 函數:

      • DEBUG

      • ERROR

      • INFO (default)

      • WARNING

    3. (選擇性) 對於 ReplayQueueRetentionPeriodInSeconds,輸入 Amazon SQS 重新顯示佇列保留訊息的時間長度 (以秒為單位)。如果您不輸入值,則會使用 1,209,600 秒 (14 天)。

    4. 在中 TopicArn,輸入要訂閱此分叉管道執行個體的 Amazon SNS 主題的 ARN。

    5. 在中 DestinationQueueName,輸入 Amazon SQS 佇列的名稱,Lambda 重新顯示函數會將訊息轉寄至該佇列。

    6. (選擇性) 在中 SubscriptionFilterPolicy,輸入 Amazon SNS 訂閱篩選政策 (採用 JSON 格式),以用於篩選傳入事件。篩選政策決定緩衝哪些事件來重播。如果您不輸入值,則不會使用篩選 (緩衝所有事件來重播)。

    7. 選擇 I acknowledge that this app creates custom IAM roles, resource policies and deploys nested applications. (我了解此應用程式會建立自訂 IAM 角色、資源政策及部署巢狀應用程式。),然後選擇 Deploy (部署)

my-app-replay頁面的部署狀態上,Lambda 會顯示您的應用程式正在部署中的狀態。

Resources (資源) 區段中,AWS CloudFormation 會開始建立堆疊,並顯示每個資源為 CREATE_IN_PROGRESS 狀態。程序完成後,AWS CloudFormation 會顯示 CREATE_COMPLETE 狀態。

當部署完成時,Lambda 會顯示 Your application has been deployed (您的應用程式已經完成部署) 狀態。

發佈到 Amazon SNS 主題的訊息會在由事件重播管道佈建的 Amazon SQS 佇列中自動緩衝以重播。

注意

在預設情況下會停用重播。若要啟用重播,請導覽到 Lambda 主控台的函數頁面,展開 Designer (設計工具) 區段,選擇 SQS 圖磚,然後在 SQS 區段中,選擇 Enabled (已啟用)。