Amazon Marketing Streamのリファレンス実装

このリファレンス実装は、AWS CDKを使用して構築されたPythonベースのアプリケーションです。GitHubですべての開発者が利用できます。

警告

これはリファレンス実装であり、Amazon Marketing Streamデータを利用するための唯一の決定的な方法ではありません。この実装は変更される可能性があり、将来のリリースには下位互換性がなくなる可能性があります。

リファレンス実装の目的は何ですか？

このリファレンス実装は、オンボーディングガイドのステップ1、2、および4をプログラムで実行します。このパッケージは、CLIを使用してStreamデータセットを登録する機能（ステップ3）もサポートしています。

CLIやPythonに慣れていない場合は、AWS SQS UIまたはCloudFormationテンプレートを使用してオンボーディングプロセスを実行することもできます。

AWSに精通している開発者は、Stream統合の基盤として、このリファレンス実装を使用できます。

リファレンスアプリケーションは、Streamで使用するために多数のAWSリソースをプロビジョニングします。Stream統合に関連するAWSの料金は、すべてお客様の負担となります。料金に基づいた最適化の詳細については、SQSに関するベストプラクティスを参照してください。

このアプリケーションは、PythonとAWS Cloud Development Kit（CDK）を使用して開発されています。

Streamのリファレンス実装アーキテクチャ図

アプリケーションは、データセットと地域の組み合わせごとに、次のAWSインフラストラクチャコンポーネントをプロビジョニングします。

Streamから最初のメッセージを受信するSQSキュー（StreamIngressQueue）。
メッセージに登録の詳細情報またはデータが含まれているかどうかを判別するlambda（StreamFanoutLambda）。
登録を確認する2つ目のlambda（SubscriptionconfirmationLambda）に、登録確認メッセージを転送する2つ目のSQSキュー（SubscriptionconfirmationQueue）。
KinesisDateFirehouse（StreamStorageFirehose）を通じて、データが保存されているS3バケット（StreamStorageBucket）にデータを転送するSNSトピック（StreamFanoutDataTopic）。

注：各SQSキューのプロビジョニングには、関連するdead-letterキューも含まれます。

GitHubのREADMEで、前提条件とインストールの詳細をご覧ください。