Cookie の設定を選択する

当社は、当社のサイトおよびサービスを提供するために必要な必須 Cookie および類似のツールを使用しています。当社は、パフォーマンス Cookie を使用して匿名の統計情報を収集することで、お客様が当社のサイトをどのように利用しているかを把握し、改善に役立てています。必須 Cookie は無効化できませんが、[カスタマイズ] または [拒否] をクリックしてパフォーマンス Cookie を拒否することはできます。

お客様が同意した場合、AWS および承認された第三者は、Cookie を使用して便利なサイト機能を提供したり、お客様の選択を記憶したり、関連する広告を含む関連コンテンツを表示したりします。すべての必須ではない Cookie を受け入れるか拒否するには、[受け入れる] または [拒否] をクリックしてください。より詳細な選択を行うには、[カスタマイズ] をクリックしてください。

AWS Event Fork Pipelines のユースケースの例

フォーカスモード

このページの内容

AWS Event Fork Pipelines のユースケースの例 - Amazon Simple Notification Service

次のシナリオでは、AWS Event Fork Pipelines を使用するイベント駆動型のサーバーレス e コマースアプリケーションについて説明します。この e コマースアプリケーション例を AWS Serverless Application Repository で使用し、AWS Lambda コンソールを使用して AWS アカウント アカウントにデプロイし、そこでこの例をテストします。ソースコードは GitHub で確認できます。

AWS のサービス を統合するサーバーレス e コマースアプリケーションのアーキテクチャ。e コマースのユーザーによる API Gateway 経由での注文の実行から、注文の保存、検索分析、再生などのさまざまな処理パイプラインまでのフローを示しています。Amazon SNS、Lambda、Amazon SQS、DynamoDB、Kibana を介してイベントが管理され、分析されることを示しています。

この e コマースアプリケーションでは、API Gateway でホストされ、AWS Lambda 関数 CheckoutApiBackendFunction で支援された RESTful API を通じて購入者から注文を受けます。この関数は、すべての受注を CheckoutEventsTopic という名前の Amazon SNS トピックに発行します。このトピックでは、これらの受注を 4 つの異なるパイプラインにファンアウトします。

最初のパイプラインは、e コマースアプリケーションの所有者によって設計および実装された通常のチェックアウト処理パイプラインです。このパイプラインには、すべての受注をバッファ処理する Amazon SQS CheckoutQueue キュー 、キューをポーリングしてこれらの注文を処理する、CheckoutFunction という名前の AWS Lambda 関数、およびすべての受注を安全に保存する DynamoDB テーブル CheckoutTable があります。

AWS Event Fork Pipelines を適用する

e コマースアプリケーションのコンポーネントは、主要ビジネスロジックを処理します。ただし、e コマースアプリケーションの所有者は以下にも対処する必要があります。

  • コンプライアンス - 安全な、圧縮されたバックアップの保管時の暗号化と機密情報のサニタイズ

  • レジリエンス - フルフィルメントプロセスの中断が発生した場合の最新の注文の再生

  • 検索可能性 - 受注に対する分析の実行とメトリクスの生成

このイベント処理ロジックを実装する代わりに、アプリケーション所有者は AWS Event Fork Pipelines を CheckoutEventsTopic Amazon SNS トピックにサブスクライブできます。

  • イベントのストレージおよびバックアップパイプライン は、データを変換して、クレジットカードの詳細の削除、データの 60 秒間のバッファ処理、GZIP を使用した圧縮、Amazon S3 のデフォルトのカスタマーマネージドキーを使用した暗号化を行うように設定されています。このキーは、AWS によって管理され、AWS Key Management Service (AWS KMS) により動作します。

    詳細については、「Amazon Data Firehose デベロッパーガイド」の「送信先の Amazon S3 の選択」、「Amazon Data Firehose データ送信」、および「設定 」を参照してください。

  • イベントの検索および分析パイプライン には、30 秒間のインデックス再試行期間、検索ドメインでインデックスの作成に失敗した注文を保存するためのバケット、およびインデックスを作成した注文のセットを制限するためのフィルターポリシーが設定されています。

    詳細については、「Amazon Data Firehose デベロッパーガイド」の「宛先の OpenSearch Service の選択」を参照してください。

  • イベントの再生パイプライン には、e コマースアプリケーションの所有者によって設計および実装された通常の注文処理パイプラインの Amazon SQS キュー部分が設定されています。

    詳細については、『Amazon Simple Queue Service デベロッパーガイド』の「キーの名前と URL」を参照してください。

次の JSON フィルターポリシーは、イベントの検索および分析パイプラインの設定で設定されます。これは、合計金額が 100 USD 以上の受注とのみ一致します。詳細については、「Amazon SNS メッセージフィルター処理」を参照してください。

{ "amount": [{ "numeric": [ ">=", 100 ] }] }

AWS Event Fork Pipelines パターンを使用すると、e コマースアプリケーションの所有者は、イベント処理用の差別化につながらないロジックのコーディングに伴いがちな開発オーバーヘッドを回避できます。代わりに、所有者は AWS Event Fork Pipelines を AWS Serverless Application Repository から AWS アカウント 内に直接デプロイできます。

プライバシーサイト規約Cookie の設定
© 2025, Amazon Web Services, Inc. or its affiliates.All rights reserved.