Creazione della pipeline di acquisizione dei dati per i dati dei tuoi partner di vendita Amazon - AWS Guida prescrittiva

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Creazione della pipeline di acquisizione dei dati per i dati dei tuoi partner di vendita Amazon

Questa sezione fornisce una strategia per importare i dati di fornitori e venditori Amazon dall'Amazon Selling Partner API (SP-API) in un data lake del tuo. Account AWS Questa architettura di pipeline di dati è progettata per l'agilità. Una volta che i dati saranno disponibili nel tuo account, puoi implementare funzionalità di analisi e intelligenza artificiale generativa per ottenere informazioni aziendali avanzate da questi dati. Questi dati ti aiutano a comprendere la tua attività, i dettagli dell'inventario e le analisi su larga scala in tutti i mercati.

Il seguente diagramma di architettura mostra come si utilizzano AWS Lambdale funzioni in un AWS Step Functionsflusso di lavoro per importare i dati dall'SP- API in un data lake dell'azienda. Account AWS I dati vengono archiviati in Amazon Simple Storage Service (Amazon S3) e in Parameter Store, che è una funzionalità di. AWS Systems Manager

Architettura serverless che acquisisce i dati dall'SP API e li archivia in un data lake.

Il diagramma dell'architettura include i seguenti componenti:

  1. Step Functions viene utilizzato come servizio di orchestrazione senza server per gestire centralmente il flusso di lavoro per l'integrazione con l'SP-. API

  2. Il Selling Partner API for Reports (ReportsAPI) supporta le notifiche per automatizzare i flussi di lavoro relativi ai report. A tale scopo, si utilizza una funzione Lambda di APInotifica SP per sottoscrivere l'applicazione al tipo di REPORT_PROCESSING_FINISHED notifica.

  3. Per effettuare chiamate all'SP-API, utilizzi una funzione Authentication Lambda per ottenere un token di accesso Login with Amazon (LWA).

  4. Il token di LWA accesso della funzione di autenticazione viene passato a una funzione Lambda di Report creator. Questa funzione effettua una createReport chiamata all'SP- API utilizzando il token di LWA accesso e i dati di configurazione regionali degli endpoint, del marketplace IDs e dei report archiviati in Parameter Store.

  5. L'SP- API genera il report. Al termine, un evento di REPORT_PROCESSING_FINISHED notifica viene inviato a una coda Amazon Simple Queue Service (AmazonSQS), che fornisce informazioni quando l'elaborazione del report è CANCELLEDDONE, o. FATAL Ciò attiva una funzione Lambda di elaborazione delle notifiche per elaborare l'evento. Se l'evento di notifica ha lo stato diDONE, reportDocumentId viene incluso a.

  6. L'evento di notifica viene passato a una funzione Lambda di elaborazione dati nel flusso di lavoro Step Functions. Questa funzione utilizza il reportDocumentId per effettuare una getReportDocument chiamata all'SP-API. L'SP- API restituisce un prefirmato URL per la posizione del documento di rapporto e l'algoritmo di compressione utilizzato, se il contenuto del documento di rapporto è stato compresso.

  7. Questa risposta viene passata a una funzione Storage Lambda, che scarica il documento di report, lo decomprime (se applicabile) e lo archivia in Amazon S3.

  8. AWS Key Management Service (AWS KMS) viene utilizzato per gestire centralmente le chiavi di crittografia, che possono essere utilizzate per crittografare i segreti in. AWS Secrets Manager I dati vengono archiviati in Amazon S3 e Parameter Store.

  9. APILe richieste SP- sono limitate utilizzando l'algoritmo token bucket. Pertanto, si consiglia di utilizzare un API client per la limitazione della velocità.

  10. AWS CloudTraile Amazon CloudWatch vengono utilizzati per il monitoraggio e la registrazione in tutto il Servizi AWS. Questi registri garantiscono la tracciabilità.