為您的 Amazon 銷售合作夥伴資料建立資料擷取管道 - AWS 方案指引

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

為您的 Amazon 銷售合作夥伴資料建立資料擷取管道

本節提供策略,將 Amazon 廠商和賣方資料從 Amazon Selling Partner API(SP-API) 擷取到 中的資料湖 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. Selling Partner API for Reports (Reports API) 支援通知,以自動化報告工作流程。為此,您可以使用 SP API通知 Lambda 函數將應用程式訂閱至REPORT_PROCESSING_FINISHED通知類型。

  3. 若要呼叫 SP-API,您可以使用 Authentication Lambda 函數來取得使用 Amazon (LWA) 登入存取權杖。

  4. 來自身分驗證函數的LWA存取權杖會傳遞給 Report creator Lambda 函數。此函數會使用LWA存取權杖和區域端點、市集 IDs和報告儲存在 參數存放區中的組態資料,對 SP-API 進行createReport呼叫。

  5. SP-API 會產生報告。完成後,REPORT_PROCESSING_FINISHED通知事件會傳送至 Amazon Simple Queue Service (Amazon SQS) 佇列,該佇列會在報告處理為 CANCELLEDDONE或 時提供資訊FATAL。這會觸發通知處理 Lambda 函數來處理事件。如果通知事件的狀態為 DONEreportDocumentId則會包含 。

  6. 通知事件會傳遞至 Step Functions 工作流程中的資料處理 Lambda 函數。此函數會使用 reportDocumentIdgetReportDocument呼叫 SP-API。如果已壓縮報告文件內容,SP-API 會傳回報告文件URL位置的預先簽署和使用的壓縮演算法。

  7. 此回應會傳遞至 Storage Lambda 函數,該函數會下載報告文件、解壓縮報告文件 (如適用),並將報告文件儲存在 Amazon S3 中。

  8. AWS Key Management Service (AWS KMS) 用於集中管理加密金鑰,可用於加密 中的秘密AWS Secrets Manager。資料儲存在 Amazon S3 和 參數存放區中。

  9. SP-API 請求受到使用權杖儲存貯體演算法的限制。因此,建議API用戶端進行速率限制。

  10. AWS CloudTrailAmazon CloudWatch 用於跨 監控和記錄 AWS 服務。這些日誌提供可追蹤性。