Aufbau der Datenerfassungspipeline für Ihre Amazon-Verkaufspartnerdaten - AWS Präskriptive Leitlinien

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Aufbau der Datenerfassungspipeline für Ihre Amazon-Verkaufspartnerdaten

Dieser Abschnitt enthält eine Strategie zur Aufnahme von Amazon-Verkäufer- und Verkäuferdaten vom Amazon-Verkaufspartner API (SP-API) in einen Data Lake in Ihrem AWS-Konto. Diese Daten-Pipeline-Architektur ist auf Agilität ausgelegt. Sobald die Daten in Ihrem Konto verfügbar sind, können Sie Analysen und generative KI-Funktionen implementieren, um aus diesen Daten erweiterte Geschäftseinblicke zu gewinnen. Diese Daten helfen Ihnen dabei, Ihr Unternehmen, Ihre Inventardetails und Analysen in großem Umfang auf allen Marktplätzen zu verstehen.

Das folgende Architekturdiagramm zeigt, wie Sie AWS LambdaFunktionen in einem AWS Step FunctionsWorkflow verwenden, um Daten aus dem SP- API in einen Data Lake in Ihrem zu übernehmen. AWS-Konto Die Daten werden in Amazon Simple Storage Service (Amazon S3) und im Parameter Store gespeichert, was eine Funktion von ist AWS Systems Manager.

Serverlose Architektur, die Daten vom SP aufnimmt API und in einem Data Lake speichert.

Das Architekturdiagramm enthält die folgenden Komponenten:

  1. Step Functions wird als serverloser Orchestrierungsservice verwendet, um den Workflow für die Integration mit dem SP- zentral zu verwalten. API

  2. Der Vertriebspartner API für Berichte (BerichteAPI) unterstützt Benachrichtigungen zur Automatisierung der Berichtsworkflows. Dazu verwenden Sie eine Lambda-Funktion für APISP-Benachrichtigungen, um die Anwendung für den REPORT_PROCESSING_FINISHED Benachrichtigungstyp zu abonnieren.

  3. Um SP- aufzurufen, verwenden Sie eine Authentication Lambda-FunktionAPI, um ein Login with Amazon (LWA) -Zugriffstoken zu erhalten.

  4. Das LWA Zugriffstoken von der Authentifizierungsfunktion wird an eine Lambda-Funktion des Berichtserstellers übergeben. Diese Funktion createReport ruft den SP- auf, API indem sie das LWA Zugriffstoken und die regionalen Endpunkt-, Marketplace- und Berichtskonfigurationsdaten verwendetIDs, die im Parameter Store gespeichert sind.

  5. Der SP- API generiert den Bericht. Nach Abschluss wird ein REPORT_PROCESSING_FINISHED Benachrichtigungsereignis an eine Amazon Simple Queue Service (AmazonSQS) -Warteschlange gesendet, die Informationen bereitstellt, wenn die BerichtsverarbeitungCANCELLED,DONE, oder istFATAL. Dadurch wird eine Lambda-Funktion zur Verarbeitung von Benachrichtigungen ausgelöst, um das Ereignis zu verarbeiten. Wenn das Benachrichtigungsereignis den Status hatDONE, reportDocumentId ist a enthalten.

  6. Das Benachrichtigungsereignis wird an eine Lambda-Funktion zur Datenverarbeitung im Step Functions Functions-Workflow übergeben. Diese Funktion verwendet diereportDocumentId, um den SP- getReportDocument API aufzurufen. Der SP- API gibt ein URL für den Speicherort des Berichtsdokuments und den verwendeten Komprimierungsalgorithmus vorsigniertes Datum zurück, wenn der Inhalt des Berichtsdokuments komprimiert wurde.

  7. Diese Antwort wird an eine Storage Lambda-Funktion übergeben, die das Berichtsdokument herunterlädt, es dekomprimiert (falls zutreffend) und das Berichtsdokument in Amazon S3 speichert.

  8. AWS Key Management Service (AWS KMS) wird zur zentralen Verwaltung von Verschlüsselungsschlüsseln verwendet, mit denen die darin enthaltenen Geheimnisse verschlüsselt werden können. AWS Secrets Manager Die Daten werden in Amazon S3 und Parameter Store gespeichert.

  9. APISP-Anfragen werden mithilfe des Token-Bucket-Algorithmus begrenzt. Daher wird ein API Client für die Ratenbegrenzung empfohlen.

  10. AWS CloudTrailund Amazon CloudWatch werden für die Überwachung und Protokollierung auf der ganzen Welt verwendet AWS-Services. Diese Protokolle bieten Rückverfolgbarkeit.