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

# Amazon 販売パートナーデータのデータ取り込みパイプラインの構築
<a name="ingestion-pipeline"></a>

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

次のアーキテクチャ図は、[AWS Step Functions](https://docs.aws.amazon.com/step-functions/latest/dg/welcome.html)ワークフローで [AWS Lambda](https://docs.aws.amazon.com/lambda/latest/dg/welcome.html)関数を使用して SP-API から のデータレイクにデータを取り込む方法を示しています AWS アカウント。データは、[Amazon Simple Storage Service (Amazon S3) ](https://docs.aws.amazon.com/AmazonS3/latest/userguide/Welcome.html)および の一機能である [Parameter Store](https://docs.aws.amazon.com/systems-manager/latest/userguide/systems-manager-parameter-store.html) に保存されます AWS Systems Manager。



![SP-API からデータを取り込んでデータレイクに保存するサーバーレスアーキテクチャ。](https://docs.aws.amazon.com/ja_jp/prescriptive-guidance/latest/strategy-gen-ai-selling-partner-api/images/ingestion-pipeline.png)


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

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

1. [レポート用販売パートナー API](https://developer-docs.amazon.com/sp-api/docs/reports-api-v2021-06-30-use-case-guide) (レポート API) は、レポートワークフローを自動化するための通知をサポートしています。そのためには、**SP-API 通知** Lambda 関数を使用して、アプリケーションを`REPORT_PROCESSING_FINISHED`通知タイプにサブスクライブします。

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

1. 認証関数からの LWA アクセストークンは、**レポート作成者**の Lambda 関数に渡されます。この関数は、LWA アクセストークンとリージョンエンドポイント、マーケットプレイス IDs SP-API を`createReport`呼び出します。

1. SP-API はレポートを生成します。完了すると、`REPORT_PROCESSING_FINISHED`通知イベントが [Amazon Simple Queue Service (Amazon SQS) ](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/welcome.html)キューに送信され、レポート処理が `CANCELLED`、、`DONE`または の場合に情報が提供されます`FATAL`。これにより、**通知処理** Lambda 関数がトリガーされ、イベントが処理されます。通知イベントのステータスが の場合`DONE`、 `reportDocumentId`が含まれます。

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

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

1. [AWS Key Management Service (AWS KMS)](https://docs.aws.amazon.com/kms/latest/developerguide/overview.html) は暗号化キーを一元管理するために使用され、 のシークレットを暗号化するために使用できます[AWS Secrets Manager](https://docs.aws.amazon.com/secretsmanager/latest/userguide/intro.html)。データは Amazon S3 と Parameter Store に保存されます。

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

1. [AWS CloudTrail](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-user-guide.html) と [Amazon CloudWatch](https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/WhatIsCloudWatch.html) は、 全体のモニタリングとログ記録に使用されます AWS のサービス。これらのログはトレーサビリティを提供します。