View a markdown version of this page

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 関数に渡されます。この関数は、LWA アクセストークンとリージョンエンドポイント、マーケットプレイス IDs SP-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-API をgetReportDocument呼び出します。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 のサービス。これらのログはトレーサビリティを提供します。