本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
為您的 Amazon 銷售合作夥伴資料建置資料擷取管道
本節提供策略,將 Amazon 廠商和賣方資料從 Amazon Selling Partner API (SP-API) 擷取到您 中的資料湖 AWS 帳戶。此資料管道架構專為敏捷性而設計。在您的帳戶中提供資料後,您可以實作分析和生成式 AI 功能,從此資料中取得進階商業洞見。此資料可協助您跨所有市場大規模了解您的業務、庫存詳細資訊和分析。
下列架構圖顯示如何在 AWS Step Functions工作流程中使用 AWS Lambda函數,以便將 SP-API 中的資料擷取至 中的資料湖 AWS 帳戶。資料存放在 Amazon Simple Storage Service (Amazon S3) 和 參數存放區中,這是 的功能 AWS Systems Manager。
架構圖包含下列元件:
-
Step Functions 用作無伺服器協同運作服務,以集中管理與 SP-API 整合的工作流程。
-
銷售合作夥伴 API for Reports
(報告 API) 支援通知,以自動化報告工作流程。為此,您可以使用 SP-API 通知 Lambda 函數將應用程式訂閱至 REPORT_PROCESSING_FINISHED通知類型。 -
若要呼叫 SP-API,您可以使用 Authentication Lambda 函數來取得 Login with Amazon (LWA) 存取字符。
-
來自身分驗證函數的 LWA 存取字符會傳遞至報告建立者 Lambda 函數。此函數會使用 LWA 存取權杖和區域端點、市集 IDs 和報告儲存在參數存放區中的組態資料,來
createReport呼叫 SP-API。 -
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 服務。這些日誌提供可追蹤性。