Amazon 販売パートナーデータのデータ取り込みパイプラインの構築 - AWS 規範ガイダンス

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Amazon 販売パートナーデータのデータ取り込みパイプラインの構築

このセクションでは、Amazon 販売パートナー API (SP-API) から 内のデータレイクに Amazon ベンダーおよび販売者データを取り込む戦略を示します AWS アカウント。このデータパイプラインアーキテクチャは、俊敏性を考慮して設計されています。アカウントでデータが利用可能になったら、分析機能と生成 AI 機能を実装して、このデータから高度なビジネスインサイトを取得できます。このデータは、すべてのマーケットプレイスでビジネス、インベントリの詳細、分析を大規模に把握するのに役立ちます。

次のアーキテクチャ図は、AWS Step FunctionsワークフローでAWS Lambda関数を使用して SP-API から のデータレイクにデータを取り込む方法を示しています AWS アカウント。データは Amazon Simple Storage Service (Amazon S3) と の一機能である Parameter Store に保存されます AWS Systems Manager。

SP-API からデータを取り込んでデータレイクに保存するサーバーレスアーキテクチャ。

アーキテクチャ図には、次のコンポーネントが含まれています。

  1. Step Functions は、SP- と統合するためのワークフローを一元管理するためのサーバーレスオーケストレーションサービスとして使用されますAPI。

  2. API レポート用販売パートナー (レポート API) は、レポートワークフローを自動化するための通知をサポートしています。そのためには、SP API通知 Lambda 関数を使用して、アプリケーションをREPORT_PROCESSING_FINISHED通知タイプにサブスクライブします。

  3. SP- を呼び出すにはAPI、Authentication Lambda 関数を使用して、Login with Amazon (LWA) アクセストークンを取得します。

  4. 認証関数からのLWAアクセストークンは、レポート作成者の Lambda 関数に渡されます。この関数は、 Parameter Store に保存されているLWAアクセストークンとリージョンエンドポイント、マーケットプレイス、レポート設定データを使用して IDsSP-API をcreateReport呼び出します。

  5. SP-API はレポートを生成します。完了すると、REPORT_PROCESSING_FINISHED通知イベントが Amazon Simple Queue Service (Amazon SQS） キューに送信され、レポート処理が CANCELLED、、DONEまたは の場合に情報が提供されますFATAL。これにより、通知処理 Lambda 関数がトリガーされ、イベントが処理されます。通知イベントのステータスが の場合DONE、 reportDocumentIdが含まれます。

  6. 通知イベントは、Step Functions ワークフローのデータ処理 Lambda 関数に渡されます。この関数はreportDocumentId、 を使用して SP- をgetReportDocument呼び出しますAPI。SP-API は、レポートドキュメントの内容が圧縮されている場合、レポートドキュメントの場所と使用される圧縮アルゴリズムURLの署名付きを返します。

  7. このレスポンスは Storage Lambda 関数に渡され、レポートドキュメントをダウンロードして解凍し (該当する場合）、そのレポートドキュメントを Amazon S3 に保存します。

  8. AWS Key Management Service （AWS KMS） は暗号化キーを一元管理するために使用され、 のシークレットを暗号化するために使用できますAWS Secrets Manager。データは Amazon S3 と Parameter Store に保存されます。

  9. SP-API リクエストは、トークンバケットアルゴリズムを使用して制限されます。したがって、レート制限にはAPIクライアントが推奨されます。

  10. AWS CloudTrail および Amazon CloudWatch は、 全体のモニタリングとログ記録に使用されます AWS のサービス。これらのログはトレーサビリティを提供します。