View a markdown version of this page

Création du pipeline d'ingestion de données pour les données de vos partenaires commerciaux Amazon - AWS Conseils prescriptifs

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Création du pipeline d'ingestion de données pour les données de vos partenaires commerciaux Amazon

Cette section propose une stratégie pour intégrer les données des fournisseurs et vendeurs Amazon depuis l'API Amazon Selling Partner (SP-API) vers un lac de données situé dans votre Compte AWS. Cette architecture de pipeline de données est conçue pour être agile. Une fois les données disponibles dans votre compte, vous pouvez mettre en œuvre des fonctionnalités d'analyse et d'IA générative pour obtenir des informations commerciales avancées à partir de ces données. Ces données vous aident à comprendre votre activité, les détails de votre inventaire et les analyses à grande échelle sur tous les sites de vente.

Le schéma d'architecture suivant montre comment vous utilisez AWS Lambdales fonctions d'un AWS Step Functionsflux de travail afin d'ingérer des données SP-API dans un lac de données de votre Compte AWS. Les données sont stockées dans Amazon Simple Storage Service (Amazon S3) et dans Parameter Store, qui est une fonctionnalité de. AWS Systems Manager

Architecture sans serveur qui ingère les données d'un lac de données SP-API et les stocke dans un lac de données.

Le schéma d'architecture inclut les composants suivants :

  1. Step Functions est utilisé comme un service d'orchestration sans serveur pour gérer de manière centralisée le flux de travail en vue de l'intégration avec le. SP-API

  2. L'API Selling Partner pour les rapports (API des rapports) prend en charge les notifications afin d'automatiser les flux de production de rapports. Pour cela, vous utilisez une fonction Lambda de SP-APInotification pour abonner l'application au type de REPORT_PROCESSING_FINISHED notification.

  3. Pour appeler le SP-API, vous utilisez une fonction Authentication Lambda pour obtenir un jeton d'accès Login with Amazon (LWA).

  4. Le jeton d'accès LWA issu de la fonction d'authentification est transmis à une fonction Lambda du créateur de rapports. Cette fonction createReport appelle le en SP-API utilisant le jeton d'accès LWA, les points de terminaison régionaux, les identifiants du marché et les données de configuration des rapports stockées dans Parameter Store.

  5. SP-API Génère le rapport. À la fin, un événement de REPORT_PROCESSING_FINISHED notification est envoyé à une file d'attente Amazon Simple Queue Service (Amazon SQS), qui fournit des informations lorsque le traitement du rapport CANCELLED estDONE, ou. FATAL Cela déclenche une fonction Lambda de traitement des notifications pour traiter l'événement. Si l'événement de notification a le statut deDONE, a reportDocumentId est inclus.

  6. L'événement de notification est transmis à une fonction Lambda de traitement des données dans le flux de travail Step Functions. Cette fonction utilise le reportDocumentId pour getReportDocument appeler le SP-API. SP-API Renvoie une URL pré-signée indiquant l'emplacement du document de rapport et l'algorithme de compression utilisé, si le contenu du document de rapport a été compressé.

  7. Cette réponse est transmise à une fonction Storage Lambda, qui télécharge le document de rapport, le décompresse (le cas échéant) et stocke le document de rapport dans Amazon S3.

  8. AWS Key Management Service (AWS KMS) est utilisé pour gérer de manière centralisée les clés de chiffrement, qui peuvent être utilisées pour chiffrer les AWS Secrets Managersecrets. Les données sont stockées dans Amazon S3 et Parameter Store.

  9. SP-API les demandes sont limitées en utilisant l'algorithme Token Bucket. Par conséquent, il est recommandé d'utiliser un client API pour limiter le débit.

  10. AWS CloudTrailet Amazon CloudWatch sont utilisés pour la surveillance et la journalisation sur le Services AWS. Ces journaux assurent la traçabilité.