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 provenant du partenaire de vente Amazon API (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 utiliser AWS Lambdales fonctions dans un AWS Step Functionsflux de travail afin d'ingérer des données du 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 du SP API et les stocke dans un lac de données.

Le schéma d'architecture comprend les éléments suivants :

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

  2. Le partenaire de vente API pour les rapports (rapportsAPI) prend en charge les notifications afin d'automatiser les flux de production de rapports. Pour cela, vous utilisez une fonction Lambda de APInotification SP 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 LWA d'accès de la fonction d'authentification est transmis à une fonction Lambda du créateur de rapports. Cette fonction createReport appelle le SP- en API utilisant le jeton d'LWAaccès et les données de configuration des points de terminaison régionauxIDs, du marché et des rapports stockées dans Parameter Store.

  5. Le 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 (AmazonSQS), qui fournit des informations lorsque le traitement du rapport est CANCELLEDDONE, ouFATAL. 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. Le SP- API renvoie un document pré-signé indiquant URL 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. Les API requêtes SP- sont limitées en utilisant l'algorithme Token Bucket. Par conséquent, il est recommandé de faire appel à un API client 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é.