本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
為您的 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。

架構圖包含下列元件:
-
Step Functions 用作無伺服器協調服務,以集中管理與 SP- 整合的工作流程API。
-
Selling Partner API for Reports
(Reports API) 支援通知,以自動化報告工作流程。為此,您可以使用 SP API通知 Lambda 函數將應用程式訂閱至 REPORT_PROCESSING_FINISHED
通知類型。 -
若要呼叫 SP-API,您可以使用 Authentication Lambda 函數來取得使用 Amazon (LWA) 登入存取權杖。
-
來自身分驗證函數的LWA存取權杖會傳遞給 Report creator Lambda 函數。此函數會使用LWA存取權杖和區域端點、市集 IDs和報告儲存在 參數存放區中的組態資料,對 SP-API 進行
createReport
呼叫。 -
SP-API 會產生報告。完成後,
REPORT_PROCESSING_FINISHED
通知事件會傳送至 Amazon Simple Queue Service (Amazon SQS) 佇列,該佇列會在報告處理為CANCELLED
、DONE
或 時提供資訊FATAL
。這會觸發通知處理 Lambda 函數來處理事件。如果通知事件的狀態為DONE
,reportDocumentId
則會包含 。 -
通知事件會傳遞至 Step Functions 工作流程中的資料處理 Lambda 函數。此函數會使用
reportDocumentId
來getReportDocument
呼叫 SP-API。如果已壓縮報告文件內容,SP-API 會傳回報告文件URL位置的預先簽署和使用的壓縮演算法。 -
此回應會傳遞至 Storage Lambda 函數,該函數會下載報告文件、解壓縮報告文件 (如適用),並將報告文件儲存在 Amazon S3 中。
-
AWS Key Management Service (AWS KMS) 用於集中管理加密金鑰,可用於加密 中的秘密AWS Secrets Manager。資料儲存在 Amazon S3 和 參數存放區中。
-
SP-API 請求受到使用權杖儲存貯體演算法的限制。因此,建議API用戶端進行速率限制。
-
AWS CloudTrail 和 Amazon CloudWatch 用於跨 監控和記錄 AWS 服務。這些日誌提供可追蹤性。