Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

# Membangun saluran konsumsi data untuk data mitra penjualan Amazon Anda
<a name="ingestion-pipeline"></a>

Bagian ini menyediakan strategi untuk menyerap data vendor dan penjual Amazon dari Amazon Selling Partner API (SP-API) ke data lake di Anda Akun AWS. Arsitektur pipa data ini dirancang untuk kelincahan. Setelah data tersedia di akun Anda, Anda dapat menerapkan analitik dan kemampuan AI generatif untuk mendapatkan wawasan bisnis tingkat lanjut dari data ini. Data ini membantu Anda memahami bisnis, detail inventaris, dan analitik dalam skala besar di semua pasar.

Diagram arsitektur berikut menunjukkan bagaimana Anda menggunakan [AWS Lambda](https://docs.aws.amazon.com/lambda/latest/dg/welcome.html)fungsi dalam [AWS Step Functions](https://docs.aws.amazon.com/step-functions/latest/dg/welcome.html)alur kerja untuk menyerap data dari SP-API ke dalam data lake di Anda. Akun AWS Data disimpan di [Amazon Simple Storage Service (Amazon S3](https://docs.aws.amazon.com/AmazonS3/latest/userguide/Welcome.html)) dan [di Parameter](https://docs.aws.amazon.com/systems-manager/latest/userguide/systems-manager-parameter-store.html) Store, yang merupakan kemampuan. AWS Systems Manager



![Arsitektur tanpa server yang menyerap data dari SP-API dan menyimpannya di danau data.](https://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/strategy-gen-ai-selling-partner-api/images/ingestion-pipeline.png)


Diagram arsitektur mencakup komponen-komponen berikut:

1. Step Functions digunakan sebagai layanan orkestrasi tanpa server untuk mengelola alur kerja secara terpusat untuk diintegrasikan dengan. SP-API

1. [API Mitra Penjualan untuk Laporan](https://developer-docs.amazon.com/sp-api/docs/reports-api-v2021-06-30-use-case-guide) (API Laporan) mendukung notifikasi untuk mengotomatiskan alur kerja laporan. Untuk ini, Anda menggunakan fungsi Lambda **SP-APInotifikasi** untuk berlangganan aplikasi ke jenis `REPORT_PROCESSING_FINISHED` notifikasi.

1. Untuk melakukan panggilan ke SP-API, Anda menggunakan fungsi Lambda **Otentikasi** untuk mendapatkan token akses Login with Amazon (LWA).

1. Token akses LWA dari fungsi otentikasi diteruskan ke fungsi **Lambda pembuat Laporan**. Fungsi ini membuat `createReport` panggilan ke SP-API dengan menggunakan token akses LWA dan titik akhir regional, ID pasar, dan data konfigurasi laporan yang disimpan di Parameter Store.

1.  SP-API Menghasilkan laporan. Setelah selesai, peristiwa `REPORT_PROCESSING_FINISHED` notifikasi dikirim ke antrean [Amazon Simple Queue Service (Amazon SQS](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/welcome.html)), yang menyediakan informasi saat pemrosesan laporan, atau. `CANCELLED` `DONE` `FATAL` Ini memicu fungsi Lambda **pemrosesan Pemberitahuan** untuk memproses acara. Jika acara notifikasi memiliki status`DONE`, a `reportDocumentId` disertakan.

1. Peristiwa notifikasi diteruskan ke fungsi Lambda **pemrosesan Data** dalam alur kerja Step Functions. Fungsi ini menggunakan `reportDocumentId` untuk membuat `getReportDocument` panggilan ke SP-API. SP-API Mengembalikan URL pra-ditandatangani untuk lokasi dokumen laporan dan algoritma kompresi yang digunakan, jika isi dokumen laporan telah dikompresi.

1. Respons ini diteruskan ke fungsi Lambda **Penyimpanan**, yang mengunduh dokumen laporan, mendekompresnya (jika ada), dan menyimpan dokumen laporan di Amazon S3.

1. [AWS Key Management Service (AWS KMS)](https://docs.aws.amazon.com/kms/latest/developerguide/overview.html) digunakan untuk mengelola kunci enkripsi secara terpusat, yang dapat digunakan untuk mengenkripsi rahasia di. [AWS Secrets Manager](https://docs.aws.amazon.com/secretsmanager/latest/userguide/intro.html) Data disimpan di Amazon S3 dan Parameter Store.

1. SP-API permintaan dibatasi dengan menggunakan algoritma token bucket. Oleh karena itu, klien API direkomendasikan untuk membatasi tarif.

1. [AWS CloudTrail](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-user-guide.html)dan [Amazon CloudWatch](https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/WhatIsCloudWatch.html) digunakan untuk memantau dan mencatat seluruh file Layanan AWS. Log ini memberikan keterlacakan.