

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

# Creando el canal de ingestión de datos para los datos de tus socios vendedores de Amazon
<a name="ingestion-pipeline"></a>

En esta sección, se proporciona una estrategia para transferir los datos de vendedores y vendedores de Amazon desde la API de socios vendedores de Amazon (SP-API) a un lago de datos interno. Cuenta de AWS Esta arquitectura de canalización de datos está diseñada para ofrecer agilidad. Una vez que los datos estén disponibles en su cuenta, podrá implementar capacidades de análisis e inteligencia artificial generativa para obtener información empresarial avanzada a partir de estos datos. Estos datos te ayudan a entender tu negocio, los detalles del inventario y los análisis a escala en todos los mercados.

El siguiente diagrama de arquitectura muestra cómo se utilizan [AWS Lambda](https://docs.aws.amazon.com/lambda/latest/dg/welcome.html)las funciones de un [AWS Step Functions](https://docs.aws.amazon.com/step-functions/latest/dg/welcome.html)flujo de trabajo para incorporar datos de él a un lago de datos interno. SP-API Cuenta de AWS Los datos se almacenan en [Amazon Simple Storage Service (Amazon S3)](https://docs.aws.amazon.com/AmazonS3/latest/userguide/Welcome.html) y [en Parameter](https://docs.aws.amazon.com/systems-manager/latest/userguide/systems-manager-parameter-store.html) Store, que es una capacidad de. AWS Systems Manager



![Arquitectura sin servidor que ingiere datos de un lago de datos SP-API y los almacena en él.](https://docs.aws.amazon.com/es_es/prescriptive-guidance/latest/strategy-gen-ai-selling-partner-api/images/ingestion-pipeline.png)


En el diagrama de arquitectura se incluyen los siguientes componentes:

1. Step Functions se utiliza como un servicio de orquestación sin servidor para gestionar de forma centralizada el flujo de trabajo e integrarlo con. SP-API

1. La [API de informes de Selling Partner](https://developer-docs.amazon.com/sp-api/docs/reports-api-v2021-06-30-use-case-guide) (API de informes) admite notificaciones para automatizar los flujos de trabajo de los informes. Para ello, utilice una función Lambda de **SP-APInotificación** para suscribir la aplicación al tipo de `REPORT_PROCESSING_FINISHED` notificación.

1. Para realizar llamadas al SP-API, utilice una función Lambda de **autenticación** para obtener un token de acceso de Login with Amazon (LWA).

1. El token de acceso a la LWA de la función de autenticación se pasa a una función Lambda **creadora de informes**. Esta función realiza una `createReport` llamada a la SP-API mediante el token de acceso de la LWA y los puntos finales regionales, los identificadores de mercado y los datos de configuración de los informes que se almacenan en el almacén de parámetros.

1.  SP-API Genera el informe. Al finalizar, se envía un evento de `REPORT_PROCESSING_FINISHED` notificación a una cola del [Amazon Simple Queue Service (Amazon SQS](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/welcome.html)), que proporciona información sobre cuándo se procesa el informe, o. `CANCELLED` `DONE` `FATAL` Esto activa una función Lambda **de procesamiento de notificaciones** para procesar el evento. Si el evento de notificación tiene el estado de a`DONE`, `reportDocumentId` se incluye a.

1. El evento de notificación se pasa a una función Lambda de **procesamiento de datos** en el flujo de trabajo de Step Functions. Esta función utiliza el `reportDocumentId` para realizar una `getReportDocument` llamada al SP-API. SP-API Devuelve una URL prefirmada para la ubicación del documento de informe y el algoritmo de compresión utilizado, si el contenido del documento de informe se ha comprimido.

1. Esta respuesta se pasa a una función de **Storage** Lambda, que descarga el documento de informe, lo descomprime (si corresponde) y lo almacena en Amazon S3.

1. [AWS Key Management Service (AWS KMS)](https://docs.aws.amazon.com/kms/latest/developerguide/overview.html) se usa para administrar de forma centralizada las claves de cifrado, que se pueden usar para cifrar los secretos. [AWS Secrets Manager](https://docs.aws.amazon.com/secretsmanager/latest/userguide/intro.html) Los datos se almacenan en Amazon S3 y en Parameter Store.

1. SP-API las solicitudes se limitan mediante el uso del algoritmo token bucket. Por lo tanto, se recomienda un cliente de API para limitar la velocidad.

1. [AWS CloudTrail](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-user-guide.html)y [Amazon CloudWatch](https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/WhatIsCloudWatch.html) se utilizan para monitorear y registrar en todo el Servicios de AWS. Estos registros proporcionan trazabilidad.