將事件儲存和備份管道部署和訂閱至 Amazon SNS - Amazon Simple Notification Service

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

將事件儲存和備份管道部署和訂閱至 Amazon SNS

對於事件封存和分析，Amazon SNS 現在建議使用其與 Amazon Data Firehose 的原生整合。您可以將 Firehose 交付串流訂閱SNS主題，這可讓您將通知傳送至封存和分析端點，例如 Amazon Simple Storage Service （Amazon S3） 儲存貯體、Amazon Redshift 資料表、Amazon OpenSearch Service （OpenSearch Service） 等。將 Amazon SNS與 Firehose 交付串流搭配使用是完全受管且無程式碼的解決方案，不需要您使用 AWS Lambda 函數。如需詳細資訊，請參閱Fanout to Firehose 交付串流。

此頁面說明如何部署事件儲存和備份管道，並訂閱 Amazon SNS主題。此程序會自動將與管道相關聯的 AWS SAM 範本轉換為 AWS CloudFormation 堆疊，然後將堆疊部署到您的 AWS 帳戶。此程序還會建立和設定一組資源 (構成事件儲存和備份管道)，包括下列項目：

  • Amazon SQS佇列

  • Lambda 函數

  • Firehose 交付串流

  • Amazon S3 備份儲存貯體

如需使用 S3 儲存貯體作為目的地設定串流的詳細資訊，請參閱 Amazon Data Firehose 參考 S3DestinationConfiguration 中的 。 API

如需有關轉換事件和設定事件緩衝、事件壓縮和事件加密的詳細資訊，請參閱 Amazon Data Firehose 開發人員指南 中的建立 Amazon Data Firehose 交付串流。

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

  1. 登入 AWS Lambda 主控台。

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

  3. 在 Create function (建立函數) 頁面上，執行下列動作：

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

    2. 搜尋 fork-event-storage-backup-pipeline，然後選擇應用程式。

  4. 在 fork-event-storage-backup-pipeline 頁面上，執行下列動作：

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

      注意

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

    2. （選用） 針對 BucketArn，輸入載入傳入事件的 S3 儲存貯體ARN的 。如果您未輸入值，則會在 AWS 帳戶中建立新的 S3 儲存貯體。

    3. （選用） 針對 DataTransformationFunctionArn，輸入傳入事件轉換所透過ARN的 Lambda 函數的 。如果您不輸入值，資料轉換會停用。

    4. （選用） 輸入下列其中一項LogLevel設定，以執行應用程式的 Lambda 函數：

      • DEBUG

      • ERROR

      • INFO (default)

      • WARNING

    5. 對於 TopicArn，輸入要訂閱叉管道此執行個體ARN的 Amazon SNS主題的 。

    6. （選用） 對於 StreamBufferingIntervalInSeconds和 StreamBufferingSizeInMBs，輸入用於設定傳入事件緩衝的值。如果您不輸入任何值，則會使用 300 秒和 5 MB。

    7. （選用） 輸入下列其中一項StreamCompressionFormat設定來壓縮傳入事件：

      • GZIP

      • SNAPPY

      • UNCOMPRESSED (default)

      • ZIP

    8. （選用） 對於 StreamPrefix，輸入字串字首以命名存放在 S3 備份儲存貯體中的檔案。如果您不輸入值，則不會使用字首。

    9. （選用） 對於 SubscriptionFilterPolicy，輸入要用於篩選傳入事件的JSON格式的 Amazon SNS訂閱篩選條件政策。篩選條件政策會決定哪些事件在 OpenSearch 服務索引中編製索引。如果您不輸入值，則不會使用篩選 (所有事件都編製索引)。

    10. （選用） 對於 SubscriptionFilterPolicyScope，輸入字串 MessageBody或 MessageAttributes以啟用承載型或屬性型訊息篩選。

    11. 選擇 我確認此應用程式會建立自訂IAM角色、資源政策並部署巢狀應用程式。 然後選擇部署 。

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

在資源區段中， AWS CloudFormation 開始建立堆疊並顯示每個資源的 CREATE_IN_PROGRESS 狀態。程序完成時， AWS CloudFormation 會顯示 CREATE_COMPLETE 狀態。

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

發佈至 Amazon SNS主題的訊息會自動儲存在事件儲存和備份管道佈建的 S3 備份儲存貯體中。